前面看完了服务的引用:dubbo的服务引用
在服务引用最终的就是生成了一个代理类,那么在调用某个被代理的接口时,实际上就是通过代理类去调用的,同时在实际调用之前做了容错、路由、负载等等。实际上每个调用都会从org.apache.dubbo.rpc.proxy.InvokerInvocationHandler#invoke
代理
在这个方法中,会把我们的目标Invoker和参数封装成org.apache.dubbo.rpc.RpcInvocation#RpcInvocation(java.lang.reflect.Method, java.lang.String, java.lang.Object[])
,然后会调用invoker.invoke(rpcInvocation)
到达集群处理:org.apache.dubbo.rpc.cluster.support.wrapper.MockClusterInvoker#invoke
这个方法里面我们依旧继续跟进会到达:org.apache.dubbo.rpc.cluster.support.AbstractClusterInvoker#invoke
- 这里我们先看
list(invocation);
方法,跟进去继续看
这里开始进入目录查找directory.list(invocation)
,这里接下来是一个很长的调用链路,就直接标记一下走过去:org.apache.dubbo.rpc.cluster.directory.AbstractDirectory#list
➡️org.apache.dubbo.registry.integration.RegistryDirectory#doList
➡️org.apache.dubbo.rpc.cluster.RouterChain#route
➡️org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector#route
➡️org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector#getNormalInvokers
这一串调用下来,目的就是进入directory通过route获取目标的Invoker - 然后回到
org.apache.dubbo.rpc.cluster.support.AbstractClusterInvoker#invoke
,开始负载均衡:initLoadBalance(invokers, invocation)
:
这里是个SPI获取的动态代理类,实际获取的是org.apache.dubbo.rpc.cluster.loadbalance.RoundRobinLoadBalance
- 然后回到
org.apache.dubbo.rpc.cluster.support.AbstractClusterInvoker#invoke
,继续跟进到:doInvoke(invocation, invokers, loadbalance)
,然后会走到:org.apache.dubbo.rpc.cluster.support.FailoverClusterInvoker#doInvoke
失败转移容错,当出现失败是尝试其他服务器
然后跟进到:Invoker<T> invoker = select(loadbalance, invocation, copyInvokers, invoked)
这个方法是在从负载规则中查找一个可用的Invoker,进入doSelect(loadbalance, invocation, invokers, selected)
这个方法中看:loadbalance.select(invokers, getUrl(), invocation)
,跟进会到达org.apache.dubbo.rpc.cluster.loadbalance.AbstractLoadBalance#select
抽象类doSelect(invokers, url, invocation)
会进入:org.apache.dubbo.rpc.cluster.loadbalance.RoundRobinLoadBalance#doSelect
这个是dubbo的随机取模算法,后面有空写一下这个算法的详细过程补到这里,这里我们先了解他从多个服务invokers(该方法入参)中选择一个可用的进行返回就行,这个入参invokers一个接口的多个集群提供。
然后回到了org.apache.dubbo.rpc.cluster.support.FailoverClusterInvoker#doInvoke
中:
选择到一个Invoker之后去执行这个方法获取结果并把结果返回。