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

Posted 2021-08-13 go大鸡腿

文章目录

• 官网
• 基本流程
• SofaRpc学习
• 代码入手
• • 服务端-发布过程
  • 服务端-构造执行链
  • 服务端-注册到注册中心
  • 客户端
  • 客户端-生成代理类
  • 客户端-连接初始化
  • • netty
  • 客户端-得到服务端列表
  • 客户端-创建代理类
  • 客户端-具体调用
  • 客户端-解码
  • 客户端-配置接口，方法用处

官网

• SOFARPC

基本流程

https://www.sofastack.tech/projects/sofa-rpc/client-invoke-flow/

最简单：一个service，一个client，一个注册中心。

service注册自己到registry注册中心，包括service-name,还有相应的ip，port，然后client去监听注册中心，然后拿到service的地址，调用的时候会通过生成一个代理，去invoke调用结果返回

SofaRpc学习

代码入手

我们在项目里面先实现这个简单的demo，然后debug进去跟着学习。

这一块没什么谈的，端口号，ip，对应的协议，然后开启一个线程去监听。

服务端-发布过程

服务提供者配置 com.alipay.sofa.rpc.config.ProviderConfig#export

com.alipay.sofa.rpc.bootstrap.DefaultProviderBootstrap#export

会根据接口，uid，协议拼接成一个key，来保证同一个服务只发布一次。

服务端-构造执行链

com.alipay.sofa.rpc.filter.FilterChain#FilterChain

com.alipay.sofa.rpc.config.AbstractInterfaceConfig#filter

com.alipay.sofa.rpc.filter.FilterChain#selectActualFilters

蚂蚁自己封装的扩展类，然后通过ExtensionLoader去加载扩展点

服务端-注册到注册中心

初始化过程

RegistryFactory.getRegistry(registryConfig);

com.alipay.sofa.rpc.registry.RegistryFactory#getRegistry

不同注册中心会有不同的扩展点，然后根据不同的扩展点去加载注册中心

注册到注册中心

// 注册到注册中心
providerConfig.setConfigListener(new ProviderAttributeListener());
register()；

register()

会根据不同的配置去进行注册相应的配置

到这里完成第一步service注册到registry

客户端

看代码

一样是有配置，服务service-name，协议，超时时间，对于的接口的类，注意这些，为下面讲解埋下伏笔！！！

客户端-生成代理类

com.alipay.sofa.rpc.config.ConsumerConfig#refer

也是为了避免客户端重复发布

cluster.init();

初始化过程

com.alipay.sofa.rpc.client.LoadBalancerFactory#getLoadBalancer(com.alipay.sofa.rpc.bootstrap.ConsumerBootstrap)

负载均衡下面单独一个点展开讲

这一块代码的实现。

客户端-连接初始化

com.alipay.sofa.rpc.client.AllConnectConnectionHolder#doReconnect

这一块netty的可用性重试

netty

我们可以看到底层使用netty进行通信，在下面一些解码中埋下伏笔。

客户端-得到服务端列表

List all = consumerBootstrap.subscribe();

初始化服务端连接（建立长连接)

ProviderInfo 抽象的服务提供列表

com.alipay.sofa.rpc.client.AllConnectConnectionHolder#addNode

经常面试遇到CountDownLatch使用，这里就有

com.alipay.sofa.rpc.client.AllConnectConnectionHolder#initClientRunnable
— >
com.alipay.sofa.rpc.client.AllConnectConnectionHolder#initClientRunnable

这里是获取长连接的，然后使用map往里面塞服务者配置以及链接

客户端-创建代理类

客户端-具体调用

com.alipay.sofa.rpc.filter.ConsumerInvoker#invoke

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

doSendMsg(providerInfo, clientTransport, request)

同步调用
com.alipay.sofa.rpc.transport.http.AbstractHttp2ClientTransport#syncSend


看到没有底层通过netty去发送

客户端-解码

这里就涉及netty解码
com.alipay.sofa.rpc.transport.http.AbstractHttpClientHandler#onResponse
com.alipay.sofa.rpc.transport.http.SyncInvokeClientHandler#doOnResponse

decode(response);

会把一些上下文塞进去

客户端-配置接口，方法用处

com.alipay.sofa.rpc.core.request.SofaRequest

服务端拿到这个配置的类名，还有方法，参数进行反射的调用