文章目录

前言
netty
- NettyHelper
- com.alipay.sofa.rpc.client.AbstractCluster
- 调用实现方式
- - 异步调用
  - 同步调用
  - - 跟dubbo一样骚操作
  - 同步异步对比
优雅关闭（计算器作用）
负载均衡

前言

这是作为sofarpc学习的子篇，主要学习netty在rpc里面的使用。

蚂蚁金服开源-SofaRpc源码学习篇

netty

很重要的三个类NettyByteBuffer（直接跳过没啥好讲）,NettyChannel,NettyHelper（也直接跳过，比较简单）

NettyHelper

简单介绍：保存服务端boss，work线程池，还有客户端对应io线程池 EventLoopGroup

我们来看下在哪里set进去
com.alipay.sofa.rpc.transport.http.AbstractHttp2ServerTransport#start

com.alipay.sofa.rpc.client.AbstractCluster

很多功能

连接init
调用的时候进行负载均衡
调用的方式，同步异步，或者future
心跳，重试等等

调用的实现

com.alipay.sofa.rpc.client.AbstractCluster#doSendMsg

同步

Callback调用

request.setSofaResponseCallback(methodResponseCallback)一个重点关注点

Future调用

调用实现方式

有很多种协议，主要看下http

com.alipay.sofa.rpc.transport.http.AbstractHttp2ClientTransport

基本参数

异步调用

com.alipay.sofa.rpc.transport.http.AbstractHttp2ClientTransport#asyncSend

com.alipay.sofa.rpc.transport.http.AbstractHttp2ClientTransport#doInvokeAsync

会分有回调callback还是future调用，最终通过doSend(request, callback, timeoutMillis);去调用

过程是这样，会去生成一个requestId,然后放到map里头，搞个超时机制去remove，如果超时的时候还在里头就会塞入异常信息

requestId是AtomicInteger去递增，channel.write(httpRequest)输出到netty服务端。

responseChannelHandler.put(requestId,channel.write(httpRequest),callback);

把streamId跟future，AbstractHttpClientHandler塞到map里头

这里处理链读到数据之后怎么一个处理过程

com.alipay.sofa.rpc.transport.http.Http2ClientChannelHandler#channelRead0

会根据header streamId去拿到对应的AbstractHttpClientHandler，处理器
callback.receiveHttpResponse(msg);

序列化，然后去setData

在这里实现前面callback或者future等等

com.alipay.sofa.rpc.transport.http.FutureInvokeClientHandler#doOnResponse
com.alipay.sofa.rpc.message.AbstractResponseFuture#setSuccess

往future里头塞result

整个过程流程图

客户端----future,callback调用，会保存requestId,跟对应的future或者callback
在服务端发送消息之后，客户端----进行解析，从header里头拿到streamId，还有future进行塞入数据
这时也是会从private final Map<Integer, Entry<ChannelFuture, AbstractHttpClientHandler>> streamIdPromiseMap;去踢出这个请求，不会造成超时报错

同步调用

com.alipay.sofa.rpc.transport.http.AbstractHttp2ClientTransport#syncSend

同步调用有个很骚的操作，就是它实际还是一个future去调用，作为一个callback

跟dubbo一样骚操作

面试官：Dubbo是如何同时支持同步调用和异步调用的？

就是同步帮你get一个结果，异步丢给你个future，你自己去get结果，哈哈哈，你好骚~

同步异步对比

最后还是调用doSend方法
同步方法是框架请求完直接帮你调用DefaultFuture的get方法阻塞获取结果，
异步方法是把DefaultFuture返回给用户，让用户决定获取调用get()方法的时机

优雅关闭（计算器作用）

这里不是线程池优雅关闭，是调用线程，它会一直等到计数器为0，再关闭

负载均衡

com.alipay.sofa.rpc.client.AbstractCluster#select(com.alipay.sofa.rpc.core.request.SofaRequest, java.util.List<com.alipay.sofa.rpc.client.ProviderInfo>)

com.alipay.sofa.rpc.client.AbstractLoadBalancer#select

负载均衡

SofaRpc源码学习篇-netty以及跟dubbo骚操作，负载均衡相关推荐

蚂蚁金服开源-SofaRpc源码学习篇
大家好,我叫大鸡腿,大家可以关注下我,会持续更新技术文章还有人生感悟,感谢~ 文章目录官网基本流程 SofaRpc学习代码入手服务端-发布过程服务端-构造执行链服务端-注册到注册中心客户 ...
mybatis源码学习篇之——执行流程分析
前言在正式学习mybatis框架源码之前,需要先弄懂几个问题?myabtis框架是什么?为什么需要mybatis框架?使用mybatis框架带来的好处是什么? 回答这几个问题之前,我们先来看一下,之 ...
SpringCloud Feign 源码底层如何调用Ribbon实现服务调用的负载均衡
在SpringCloud微服务中调用都不是直接用Ribbon进行服务调用,因为那样的化项目中的代码量会增加很多,微服务之间的调用是用Feign来进行调用,下面就是普通的一个接口调用例子这样就可以进行 ...
KBEngine warring项目源码阅读（二）登录和baseapp的负载均衡
原本不打算把登录拿出来写的,但是阅读登录部分的代码的时候发现登录和注册还不太一回事,因为登录涉及到分配baseapp的ip,负载均衡的实现,所以水一下. 流程图: 和上次一样,先是找unity控件找 ...
mq补偿机制java代码_RocketMQ源码分析之消息消费机制-消费端消息负载均衡机制与重新分布 - Java 技术驿站-Java 技术驿站...
1.消息消费需要解决的问题首先再次重复啰嗦一下RocketMQ消息消费的一些基本元素的关系主题 ---> 消息队列(MessageQueue) 1 对多主题 ----> 消息生产者, ...
mutations vuex 调用_Vuex源码学习（六）action和mutation如何被调用的（前置准备篇）...
前言 Vuex源码系列不知不觉已经到了第六篇.前置的五篇分别如下: 长篇连载:Vuex源码学习(一)功能梳理长篇连载:Vuex源码学习(二)脉络梳理作为一个Web前端,你知道Vuex的instal ...
action mutation 调用_Vuex源码学习（六）action和mutation如何被调用的（前置准备篇）...
module与moduleCollection你一定要会啊!Vuex源码学习(五)加工后的module 在组件中使用vuex的dispatch和commit的时候,我们只要把action.mutati ...
第十四课 k8s源码学习和二次开发原理篇-调度器原理
第十四课 k8s源码学习和二次开发原理篇-调度器原理 tags: k8s 源码学习 categories: 源码学习二次开发文章目录第十四课 k8s源码学习和二次开发原理篇-调度器原理第一节 ...
第八课 k8s源码学习和二次开发原理篇-KubeBuilder使用和Controller-runtime原理
第八课 k8s源码学习和二次开发原理篇-KubeBuilder使用和Controller-runtime原理 tags: k8s 源码学习 categories: 源码学习二次开发文章目录第八课 ...
开源中国源码学习UI篇（一）之FragmentTabHost的使用分析
最近在有意读开源中国的源码来提升Android开发能力,开通博客来提升一下自己的积极性- -我参考的是开源中国2.2版,完整源码地址为http://git.oschina.net/oschina/an ...

SofaRpc源码学习篇-netty以及跟dubbo骚操作，负载均衡