dubbo的集群容错和路由负载

前面看完了服务的引用:dubbo的服务引用

在服务引用最终的就是生成了一个代理类,那么在调用某个被代理的接口时,实际上就是通过代理类去调用的,同时在实际调用之前做了容错、路由、负载等等。实际上每个调用都会从org.apache.dubbo.rpc.proxy.InvokerInvocationHandler#invoke代理
dubbo的集群容错和路由负载
在这个方法中,会把我们的目标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
dubbo的集群容错和路由负载

这个方法里面我们依旧继续跟进会到达:org.apache.dubbo.rpc.cluster.support.AbstractClusterInvoker#invoke
dubbo的集群容错和路由负载

  1. 这里我们先看list(invocation);方法,跟进去继续看dubbo的集群容错和路由负载
    这里开始进入目录查找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
  2. 然后回到org.apache.dubbo.rpc.cluster.support.AbstractClusterInvoker#invoke,开始负载均衡:initLoadBalance(invokers, invocation)
    dubbo的集群容错和路由负载
    这里是个SPI获取的动态代理类,实际获取的是org.apache.dubbo.rpc.cluster.loadbalance.RoundRobinLoadBalance
  3. 然后回到org.apache.dubbo.rpc.cluster.support.AbstractClusterInvoker#invoke,继续跟进到:doInvoke(invocation, invokers, loadbalance),然后会走到:org.apache.dubbo.rpc.cluster.support.FailoverClusterInvoker#doInvoke失败转移容错,当出现失败是尝试其他服务器dubbo的集群容错和路由负载
    然后跟进到:Invoker<T> invoker = select(loadbalance, invocation, copyInvokers, invoked)dubbo的集群容错和路由负载
    这个方法是在从负载规则中查找一个可用的Invoker,进入doSelect(loadbalance, invocation, invokers, selected)
    dubbo的集群容错和路由负载
    这个方法中看:loadbalance.select(invokers, getUrl(), invocation),跟进会到达org.apache.dubbo.rpc.cluster.loadbalance.AbstractLoadBalance#select抽象类dubbo的集群容错和路由负载
    doSelect(invokers, url, invocation)会进入:org.apache.dubbo.rpc.cluster.loadbalance.RoundRobinLoadBalance#doSelectdubbo的集群容错和路由负载
    这个是dubbo的随机取模算法,后面有空写一下这个算法的详细过程补到这里,这里我们先了解他从多个服务invokers(该方法入参)中选择一个可用的进行返回就行,这个入参invokers一个接口的多个集群提供。

然后回到了org.apache.dubbo.rpc.cluster.support.FailoverClusterInvoker#doInvoke中:
dubbo的集群容错和路由负载
选择到一个Invoker之后去执行这个方法获取结果并把结果返回。

上一篇:asp.net(C#) 中 怎么使用 MongoDb


下一篇:Dubbo源码分析(八)集群容错机制