Dubbo框架

1、Dubbo是什麼？

Dubbo是一個分佈式服務框架，致力於提供高性能和透明化的RPC遠程服務調用方案，以及SOA服務治理方案。說白了就是個遠程服務調用的分佈式框架（告別Web Service模式中的WSdl，以服務者與消費者的方式在dubbo上註冊）。

其核心部分包含:
1. 遠程通信: 提供對多種基於長鏈接的NIO框架抽象封裝，包括多種線程模型，序列化，以及「請求-響應」模式的信息交換方式。
2. 集羣容錯: 提供基於接口方法的透明遠程過程調用，包括多協議支持，以及軟負載均衡，失敗容錯，地址路由，動態配置等集羣支持。
3. 自動發現: 基於註冊中心目錄服務，使服務消費方能動態的查找服務提供方，使地址透明，使服務提供方能夠平滑增長或減小機器。

2、Dubbo的做用

1.透明化的遠程方法調用，就像調用本地方法同樣調用遠程方法，只需簡單配置，沒有任何API侵入。      
2.軟負載均衡及容錯機制，可在內網替代F5等硬件負載均衡器，下降成本，減小單點。
3. 服務自動註冊與發現，再也不須要寫死服務提供方地址，註冊中心基於接口名查詢服務提供者的IP地址，而且可以平滑添加或刪除服務提供者。

 

3、Dubbo的架構

dubbo架構圖：

節點角色說明：

       Provider: 暴露服務的服務提供方。

       Consumer: 調用遠程服務的服務消費方。

       Registry: 服務註冊與發現的註冊中心。

       Monitor: 統計服務的調用次調和調用時間的監控中心。

       Container: 服務運行容器。

調用關係說明：

0 服務容器負責啓動，加載，運行服務提供者。

1. 服務提供者在啓動時，向註冊中心註冊本身提供的服務。

2. 服務消費者在啓動時，向註冊中心訂閱本身所需的服務。

3. 註冊中心返回服務提供者地址列表給消費者，若是有變動，註冊中心將基於長鏈接推送變動數據給消費者。

4. 服務消費者，從提供者地址列表中，基於軟負載均衡算法，選一臺提供者進行調用，若是調用失敗，再選另外一臺調用。

5. 服務消費者和提供者，在內存中累計調用次數和調用時間，定時每分鐘發送一次統計數據到監控中心。

 

 4、Dubbo的使用方法

Dubbo採用全Spring配置方式，透明化接入應用，對應用沒有任何API侵入，只需用Spring加載Dubbo的配置便可，Dubbo基於Spring的Schema擴展進行加載。

 服務提供者：

1. 下載zookeeper註冊中心，下載地址：http://www.apache.org/dyn/closer.cgi/zookeeper/  下載後解壓便可，進入D:\apach-zookeeper-3.4.5\bin，

雙擊zkServer.cmd啓動註冊中心服務。

2. 定義服務接口: (該接口需單獨打包，在服務提供方和消費方共享)

 1     package com.unj.dubbotest.provider;  2       
 3     import java.util.List;  4       
 5     public interface DemoService {  6       
 7  String sayHello(String name);  8       
 9         public List getUsers(); 10       
11     }  

在服務提供方實現接口：(對服務消費方隱藏實現)

 1     package com.unj.dubbotest.provider;  2       
 3     import java.util.ArrayList;  4     import java.util.LinkedList;  5     import java.util.List;  6       
 7       
 8     public class DemoServiceImpl implements DemoService{  9           
10          public String sayHello(String name) { 11                 return "Hello " + name; 12  } 13          public List getUsers() { 14              List list = new ArrayList(); 15              User u1 = new User(); 16              u1.setName("jack"); 17              u1.setAge(20); 18              u1.setSex("男"); 19                
20              User u2 = new User(); 21              u2.setName("tom"); 22              u2.setAge(21); 23              u2.setSex("女"); 24                
25              User u3 = new User(); 26              u3.setName("rose"); 27              u3.setAge(19); 28              u3.setSex("女"); 29                
30  list.add(u1); 31  list.add(u2); 32  list.add(u3); 33              return list; 34  } 35     }  

用Spring配置聲明暴露服務：

    <?xml version="1.0" encoding="UTF-8"?>  
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd ">  
       
        <!-- 具體的實現bean -->  
        <bean id="demoService" class="com.unj.dubbotest.provider.DemoServiceImpl" />  
          
        <!-- 提供方應用信息，用於計算依賴關係 -->  
        <dubbo:application name="xixi_provider"  />  
       
        <!-- 使用multicast廣播註冊中心暴露服務地址 <dubbo:registry address="multicast://224.5.6.7:1234" />-->  
        
        <!-- 使用zookeeper註冊中心暴露服務地址 -->  
        <dubbo:registry address="zookeeper://127.0.0.1:2181" />   
        
        <!-- 用dubbo協議在20880端口暴露服務 -->  
        <dubbo:protocol name="dubbo" port="20880" />  
       
        <!-- 聲明須要暴露的服務接口 -->  
        <dubbo:service interface="com.unj.dubbotest.provider.DemoService" ref="demoService" />  
          
    </beans>  

說明：

dubbo:registry 標籤一些屬性的說明：

1）register是否向此註冊中心註冊服務，若是設爲false，將只訂閱，不註冊。

2）check註冊中心不存在時，是否報錯。

3）subscribe是否向此註冊中心訂閱服務，若是設爲false，將只註冊，不訂閱。

4）timeout註冊中心請求超時時間(毫秒)。

5）address能夠Zookeeper集羣配置，地址能夠多個以逗號隔開等。

 

dubbo:service 標籤的一些屬性說明：

1）interface服務接口的路徑

2）ref引用對應的實現類的Bean的ID

3）registry向指定註冊中心註冊，在多個註冊中心時使用，值爲<dubbo:registry>的id屬性，多個註冊中心ID用逗號分隔，若是不想將該服務註冊到任何registry，可將值設爲N/A

4）register 默認true ，該協議的服務是否註冊到註冊中心。

 

 

服務消費者：

1.經過Spring配置引用遠程服務：

 1     <?xml version="1.0" encoding="UTF-8"?>  
 2     <beans xmlns="http://www.springframework.org/schema/beans"  
 3  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  
 4  xsi:schemaLocation="http://www.springframework.org/schema/beans  5  http://www.springframework.org/schema/beans/spring-beans.xsd  6  http://code.alibabatech.com/schema/dubbo  7  http://code.alibabatech.com/schema/dubbo/dubbo.xsd  8  ">  
 9       
10         <!-- 消費方應用名，用於計算依賴關係，不是匹配條件，不要與提供方同樣 -->  
11         <dubbo:application name="hehe_consumer" />  
12       
13         <!-- 使用zookeeper註冊中心暴露服務地址 -->  
14         <!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->  
15         <dubbo:registry address="zookeeper://127.0.0.1:2181" />  
16       
17         <!-- 生成遠程服務代理，能夠像使用本地bean同樣使用demoService -->  
18         <dubbo:reference id="demoService"  
19  interface="com.unj.dubbotest.provider.DemoService" />  
20       
21     </beans>  

2.消費方調用遠程服務：

@Autowired
DemoService demoService；

 

5、dubbo服務治理

 

6、dubbo的集羣容錯和負載均衡

各節點關係：

　　Invoker：是Provider的一個可調用Service的抽象，Invoker封裝了Provider地址及Service接口信息。

　　Directory：表明多個Invoker，能夠把它當作List<Invoker>，但與List不一樣的是，它的值多是動態變化的，好比註冊中心推送變動。

　　Cluster：將Directory中的多個Invoker假裝成一個Invoker，對上層透明，假裝過程包含了容錯邏輯，調用失敗後，重試另外一個。

　　Router：負責從多個Invoker中按路由規則選出子集，好比讀寫分離，應用隔離等。

　　LoadBalance：負責從多個Invoker中選出具體的一個用於本次調用，選的過程包含了負載均衡算法，調用失敗後，須要重選。

 

一、集羣容錯

 集羣容錯模式：

①Failover Cluster

失敗自動切換，當出現失敗，重試其它服務器。(缺省)一般用於讀操做，但重試會帶來更長延遲。可經過retries="2"來設置重試次數(不含第一次)。

②Failfast Cluster

快速失敗，只發起一次調用，失敗當即報錯。一般用於非冪等性的寫操做，好比新增記錄。

③Failsafe Cluster

失敗安全，出現異常時，直接忽略。一般用於寫入審計日誌等操做。

④Failback Cluster

失敗自動恢復，後臺記錄失敗請求，定時重發。一般用於消息通知操做。

⑤Forking Cluster

並行調用多個服務器，只要一個成功即返回。一般用於實時性要求較高的讀操做，但須要浪費更多服務資源。可經過forks="2"來設置最大並行數。

⑥Broadcast Cluster

廣播調用全部提供者，逐個調用，任意一臺報錯則報錯。(2.1.0開始支持)一般用於通知全部提供者更新緩存或日誌等本地資源信息。

 

重試次數配置如：(failover集羣模式生效)

<dubbo:service retries="2"/>

或：

<dubbo:reference retries="2"/>

或：

<dubbo:reference>

   <dubbo:methodname="findFoo" retries="2"/>

</dubbo:reference>

 

集羣模式配置如：

<dubbo:service cluster="failsafe"/>

或：

<dubbo:reference cluster="failsafe"/>

 

二、負載均衡

 均衡策略：（缺省爲random隨機調用）

①Random LoadBalance

隨機，按權重設置隨機機率。

在一個截面上碰撞的機率高，但調用量越大分佈越均勻，並且按機率使用權重後也比較均勻，有利於動態調整提供者權重。

②RoundRobin LoadBalance

輪循，按公約後的權重設置輪循比率。

存在慢的提供者累積請求問題，好比：第二臺機器很慢，但沒掛，當請求調到第二臺時就卡在那，長此以往，全部請求都卡在調到第二臺上。

③LeastActive LoadBalance

最少活躍調用數，相同活躍數的隨機，活躍數指調用先後計數差。

使慢的提供者收到更少請求，由於越慢的提供者的調用先後計數差會越大。

④ConsistentHash LoadBalance

一致性Hash，相同參數的請求老是發到同一提供者。

當某一臺提供者掛時，本來發往該提供者的請求，基於虛擬節點，平攤到其它提供者，不會引發劇烈變更。

 

均衡策略配置：

例如：

<dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" loadbalance="roundrobin"/>