Dubbo 2.7中的远程调用是其核心功能之一,涉及从客户端发起请求到服务端处理并返回结果的整个过程。这个过程高度抽象且灵活,支持多种协议、序列化方式和负载均衡策略。以下是远程调用的关键流程和相关源码解析:
远程调用流程概览
-
构建请求:消费者通过代理对象(由
ProxyFactory
创建的Invoker
实例)发起调用时,Dubbo会构造一个包含调用参数、调用方法等信息的Invocation
对象。 -
选择调用链路:Dubbo会根据配置选择合适的调用链路(Invoker链)。这个过程可能涉及路由(
Router
)、负载均衡(LoadBalance
)等策略,以确定最终的服务提供者。 -
序列化请求参数:根据配置的序列化策略,将
Invocation
对象及其参数转换为二进制流,准备网络传输。 -
网络传输:使用所选协议(如Dubbo协议、HTTP等)的客户端发送请求至服务提供方。Dubbo协议下,通过Netty等NIO框架实现高效网络通信。
-
服务端接收并反序列化:服务提供方接收到请求后,通过相应协议的服务器端解码请求,反序列化
Invocation
,准备调用实际服务。 -
服务执行:调用具体服务实现,执行业务逻辑。
-
结果序列化与返回:将执行结果再次序列化,通过网络返回给消费者。
-
反序列化结果:消费者端接收响应,反序列化结果,最终通过代理对象返回给调用方。
关键源码位置
-
Invoker.invoke(Invocation inv):位于
com.alibaba.dubbo.rpc.Invoker
接口,这是远程调用的入口方法,具体Invoker实现(如AbstractProxyInvoker
)会根据配置执行后续调用链路。 -
Directory.list(Invocation invocation):位于
com.alibaba.dubbo.rpc.cluster.Directory
,用于根据调用信息列出可用的服务提供者列表,这一步可能经过路由筛选。 -
LoadBalance.select(List<Invoker> invokers, URL url, Invocation invocation):位于
com.alibaba.dubbo.rpc.cluster.LoadBalance
,根据负载均衡策略选择具体的服务提供者Invoker。 -
Protocol.invoker(Request request):位于
com.alibaba.dubbo.rpc.Protocol
接口,负责协议级别的请求发送与响应接收。Dubbo协议下的实现在DubboProtocol
中。 -
ExchangeHandler.received(Channel channel, Response response):位于
com.alibaba.dubbo.remoting.exchange.ExchangeHandler
,服务端接收到请求后的处理入口,通过调用链最终执行业务逻辑。
注意事项
-
并发控制与线程模型:Dubbo支持多种并发模型,如同步、异步、回调等,通过配置可以调整,影响调用的性能与响应模式。
-
容错与重试:远程调用过程中可能出现网络故障、服务不可用等情况,Dubbo提供了容错机制和重试策略来提升系统的稳定性。
-
调用上下文传递:Dubbo支持在调用过程中传递附加信息,如
RpcContext
,可用于跟踪、传递安全凭证等。
深入理解远程调用的源码,有助于开发者优化调用性能、自定义负载均衡策略、以及进行问题排查。
标签:Dubbo,调用,com,源码,Invoker,Invocation,序列化,2.7 From: https://blog.csdn.net/qq_33240556/article/details/140225477