DubboInvoker接口群有哪些

Invoker,負(fù)載網(wǎng)絡(luò)調(diào)用組件，底層依懶與網(wǎng)絡(luò)通信，Invoker主要負(fù)責(zé)服務(wù)調(diào)用，自然與路由（比如集群）等功能息息相關(guān)，本節(jié)先從整體上把控一下Dubbo服務(wù)調(diào)用體系，服務(wù)發(fā)現(xiàn)、集群、負(fù)載均衡、路由機(jī)制等整個(gè)知識(shí)體系。

1. Invocation(調(diào)用上下文環(huán)境)

• Invocation：
  1、String getMethodName()    獲取調(diào)用方法名。
  2、Class< ? >[] getParameterTypes()    獲取被調(diào)用方法的參數(shù)列表（參數(shù)類型）
  3、Object[] getArguments()    獲取被調(diào)用方法的參數(shù)值數(shù)組。
  4、Map< String, String> getAttachments()    獲取附加屬性。
  5、String getAttachment(String key)    根據(jù)key獲取附加屬性值。
  6、String getAttachment(String key, String defaultValue)    根據(jù)key獲取附加屬性，如果不存在，取默認(rèn)值。
  7、Invoker< ?> getInvoker() 獲取當(dāng)前的invoker。

• RpcInvocation rpc服務(wù)調(diào)用實(shí)現(xiàn)類
   Invocation執(zhí)行調(diào)用上下文環(huán)境，就是用一個(gè)Bean存儲(chǔ)當(dāng)前調(diào)用方法的參數(shù)，其本質(zhì)就是一個(gè)普通的Bean而已。

• MockInvocation
   用于mock單元測(cè)試用。

• DecodeableRpcInvocation 帶解碼功能的rpc調(diào)用上下文
   該實(shí)現(xiàn)主要能從RPC服務(wù)調(diào)用請(qǐng)求中解析二進(jìn)制流（二進(jìn)制包）得到RPC服務(wù)調(diào)用上下文（方法調(diào)用元數(shù)據(jù)）。

1. Invoker 服務(wù)調(diào)用器，Dubbo中調(diào)用服務(wù)的抽象。
   Invoer的抽象接口，繼承自com.alibaba.dubbo.common.Node接口

• Node：
  1、URL getUrl();      獲取URL，在dubbo中，注冊(cè)中心、服務(wù)提供者、服務(wù)消費(fèi)者、監(jiān)控中心等都使用URL描述。
  2、boolean isAvailable()    ：判斷是否可用。
  3、void destroy()    ：資源銷毀。

• Invoker:
  1、Class getInterface()    :獲取服務(wù)提供者的接口。
  Result invoke(Invocation invocation) throws RpcException    ：調(diào)用服務(wù)，返回調(diào)用結(jié)果。

• AbstractInvoker Invoker默認(rèn)實(shí)現(xiàn)（模板類）
  該方法主要實(shí)現(xiàn)public Result invoke(Invocation inv) throws RpcException,定義執(zhí)行invoker的基礎(chǔ)流程（模板），然后根據(jù)不同的實(shí)現(xiàn)子類（不同的協(xié)議）執(zhí)行各自個(gè)性化的執(zhí)行任務(wù)。其抽象方法：protected abstract Result doInvoke(Invocation invocation) throws Throwable，具體實(shí)現(xiàn)將在后文中分析。

• DubboInvoker dubbo協(xié)議調(diào)用器具體實(shí)現(xiàn)。

• InjvmInvoker injvm協(xié)議調(diào)用其具體實(shí)現(xiàn)（本地協(xié)議）

1. AbstractClusterInvoker 集群模式調(diào)用模板類
   該類為Dubbo集群模式的調(diào)用模板類，主題解決一個(gè)服務(wù)服務(wù)有多個(gè)服務(wù)提供者，此時(shí)消息消費(fèi)端在調(diào)用服務(wù)時(shí)如何選擇具體的服務(wù)提供者。該類需要組織多個(gè)服務(wù)提供者，并按照指定算法選擇一服務(wù)提供者進(jìn)行調(diào)用。

• AvailableClusterInvoker
  通過< dubbo:service cluster = "available" …/> 或 < dubbo:reference cluster="available" …/>
  集群策略：總是選擇第一個(gè)可用的服務(wù)提供者。

• BroadcastClusterInvoker
  通過< dubbo:service cluster = "broadcast" …/> 或 < dubbo:reference cluster="broadcast" …/>
  集群策略：廣播模式，向所有服務(wù)提供者都發(fā)送請(qǐng)求，任何一個(gè)調(diào)用失敗，則認(rèn)為失敗。

• FailbackClusterInvoker
  通過< dubbo:service cluster = "failback" …/> 或 < dubbo:reference cluster="failback" …/>
  集群策略：服務(wù)調(diào)用失敗后，定時(shí)重試，重試次數(shù)無線次，重試頻率：5s。并不會(huì)切換服務(wù)提供者。

• FailfastClusterInvoker
  通過< dubbo:service cluster = "failfast" …/> 或 < dubbo:reference cluster="failfast" …/>
  集群策略：服務(wù)調(diào)用后，快速失敗，直接拋出異常，并不重試，也不受retries參數(shù)的制約，適合新增、修改類操作。

• FailoverClusterInvoker
  通過< dubbo:service cluster = "failover" …/> 或 < dubbo:reference cluster="failover" …/>
  集群策略：服務(wù)調(diào)用后，如果出現(xiàn)失敗，則重試其他服務(wù)提供者，默認(rèn)重試2次，總共執(zhí)行3次，重試次數(shù)由retries配置，dubbo集群默認(rèn)方式。

• FailsafeClusterInvoker
  通過< dubbo:service cluster = "failsafe" …/> 或 < dubbo:reference cluster="failsafe" …/>
  集群策略：服務(wù)調(diào)用后，只打印錯(cuò)誤日志，然后直接返回。

• ForkingClusterInvoker  
  通過< dubbo:service cluster = "forking" …/> 或 < dubbo:reference cluster="forking" …/>
  集群策略：并發(fā)調(diào)用多個(gè)服務(wù)提供者，取第一個(gè)返回的結(jié)果。可以通過forks設(shè)置并發(fā)調(diào)用的服務(wù)臺(tái)提供者個(gè)數(shù)。

4. LoadBalance 集群負(fù)載算法
   當(dāng)一個(gè)服務(wù)有多個(gè)服務(wù)提供者時(shí)，消費(fèi)端在進(jìn)行服務(wù)調(diào)用時(shí)選擇服務(wù)服務(wù)提供者的負(fù)載均衡算法。
   LoadBalance定義的接口為：
   < T> Invoker select(List< Invoker> invokers, URL url, Invocation invocation) throws RpcException;

• ConsistentHashLoadBalance
  可以通過< dubbo:service loadbalance="consistenthash" …/>或< dubbo:provider loadbalance = "consistenthash" …/>
  負(fù)載均衡算法：一致性Hash算法，在AbstractClusterInvoker中從多個(gè)服務(wù)提供者中選擇一個(gè)服務(wù)提供者時(shí)被調(diào)用。

• LeastActiveLoadBalance
  可以通過< dubbo:service loadbalance="leastactive" …/>或< dubbo:provider loadbalance = "leastactive" …/>
  負(fù)載均衡算法：最小活躍調(diào)用。

• RandomLoadBalance
  可以通過< dubbo:service loadbalance="random" …/>或< dubbo:service loadbalance = "random" …/>
  負(fù)載均衡算法：隨機(jī)，如果weight（權(quán)重越大，機(jī)會(huì)越高）

• RoundRobinLoadBalance
  可以通過< dubbo:service loadbalance="roundrobin" …/>或< dubbo:provider loadbalance = "roundrobin" …/>
  負(fù)載均衡算法：加權(quán)輪詢算法。

4. Directory（目錄服務(wù)，Invoker的目錄服務(wù)）
   該接口主要的作用是服務(wù)提供者的目錄服務(wù)，管理多個(gè)服務(wù)提供者。

• Directory
  1、Class< T> getInterface() 獲取該服務(wù)接口類別。
  2、List< Invoker< T>> list(Invocation invocation) throws RpcException 根據(jù)調(diào)用上下文獲取當(dāng)前所有該服務(wù)的服務(wù)提供者。
  4.2 AbstractDirectory 目錄服務(wù)實(shí)現(xiàn)的抽象列（模板類）
  4.3 StaticDirectory 靜態(tài)目錄服務(wù)
  所謂靜態(tài)目錄服務(wù)就是在創(chuàng)建StaticDirectory時(shí)指定一個(gè)服務(wù)提供者集合，則該目錄服務(wù)實(shí)例在其生命周期中，只會(huì)返回這些服務(wù)提供者。

• RegistryDirectory 動(dòng)態(tài)目錄服務(wù)（基于注冊(cè)中心）、
  從注冊(cè)中心動(dòng)態(tài)獲取發(fā)現(xiàn)服務(wù)提供，默認(rèn)消息消費(fèi)者并不會(huì)指定特定的服務(wù)提供者URL，所以會(huì)向注冊(cè)中心訂閱服務(wù)的服務(wù)提供者（監(jiān)聽注冊(cè)中心providers目錄），利用RegistryDirectory自動(dòng)獲取注冊(cè)中心服務(wù)器列表。

4. Router 路由功能
   根據(jù)消息消費(fèi)者URL，結(jié)合路由表達(dá)式或JS引擎，從Directory中選擇符合路由規(guī)則的Invoker，再執(zhí)行負(fù)載均衡算法。

• Router
  1、URL getUrl();    獲取消息消費(fèi)者URL。
  2、< T> List< Invoker< T>> route(List<  Invoker< T>> invokers, URL url, Invocation invocation) throws RpcException  根據(jù)消息消費(fèi)者URL，從invokers中篩選合適的Invokers。

• ConditionRouter 基于條件表達(dá)式的路由實(shí)現(xiàn)。

• ScriptRouter 基于JS引擎的路由實(shí)現(xiàn)。