Dubbo學習小記

前言

周一入職的新公司，到了公司第一件事自然是要熟悉新公司使用的各種技術，搭建本地的環境。

熟悉新公司技術的過程中，首先就是Maven，這個前面已經寫過文章了，然後就是Dubbo----公司的服務都是通過Dubbo來治理的。其實之前我就對SOA、RPC等分散式服務的概念有所瞭解，Dubbo也多多少少知道一些，不過能親身使用那是再好不過的了。

此文就對我的Dubbo學習做一個小的總結，基本我總結的這些內容對於入門應該是足夠了。關於Dubbo的更詳細信息，阿裡有專門出手冊，手冊地址為http://dubbo.io/User+Guide-zh.htm，本文也只是對手冊的重點進行一些提煉而已（看過就知道了，這篇手冊實在是太龐大了），要進一步地瞭解Dubbo的朋友們還是應當去看Dubbo的官方手冊。

Dubbo是什麼

Dubbo是一個分散式服務框架，致力於提供高性能和透明化的RPC遠程服務調用方案，以及SOA服務治理方案。其核心部分包括：

• 遠程通訊：提供對多種基於長連接的NIO框架抽象封裝，包括多種線程模型、序列化、"請求-響應"模式的信息交換方案
• 集群容錯：提供基於藉口方法的透明遠程過程調用，包括多協議支持、軟負載均衡、失敗容錯、地址路由、動態配置等集群支持
• 自動發現：基於註冊中心目錄服務，使服務消費方能動態地查找服務提供方，使地址透明，使服務提供方可以平滑增加或減少機器

Dubbo能做什麼

Dubbo功能強大，總結下來，它大致可以做以下幾件事：

• 透明化的遠程方法調用，就像調用本地方法一樣調用遠程方法，只需要簡單配置，沒有任何API侵入
• 軟負載均衡及容錯機制，可在內網替代F5等硬體負載均衡器，降低成本、減少多拿點
• 服務自動註冊與發現，不再需要寫死服務提供方地址，註冊中心基於介面名查詢服務提供者的IP地址，並且能夠平滑添加或刪除服務提供者

Dubbo架構圖

這是最重要的，理解Dubbo的架構圖是理解Dubbo的第一步，我從Dubbo官網手冊上截了一下Dubbo架構圖：

在接下來的講解之前，說明一個概念：所謂SOA也好，分散式服務框架也好，不是服務消費者從中間件（一般都是Zookeeper）上去拿數據，而是服務消費者從中間件上拿到可用的服務生產者的集群地址，再從集群地址中選出一個進行直連。

接下來認識一下圖中的結點：

• Provider：暴露服務的服務提供方，或者直白點說就是服務生產者
• Consumer：調用遠程服務的服務消費方，也就是服務消費者
• Registry：服務註冊與發現的註冊中心
• Monitor：統計服務的調用次數和調用時間的監控中心
• Container：服務（生產者）運行容器

圖中已經有了調用步驟了，接著對步驟進行說明：

• 0：服務容器負責啟動、載入、運行服務提供者（生產者）
• 1：服務提供者（生產者）在啟動時，向註冊中心註冊自己提供的服務
• 2：服務消費者在啟動時，向註冊中心訂閱自己所需的服務
• 3：註冊中心返回服務提供者地址列表給消費者，如果有變更，註冊中細膩將基於長連接推送變更數據給消費者
• 4：服務消費者從服務生產者地址列表中，基於軟負載均衡演算法，選擇一臺提供者（生產者）進行調用，如果調用失敗，再選另一臺調用
• 5：服務消費者和提供者（生產者），在記憶體中累計調用次數和調用時間，定時每分鐘發送一次統計數據到監控中心

Dubbo用法

Dubbo採用全Spring配置方式，透明化接入應用，對應用沒有任何API侵入（這句話的意思是應用程式不會、不需要手動調用Dubbo的任何類和任何介面），只需用Spring載入Dubbo的配置即可（意思是對Dubbo的使用只需要寫Spring配置文件或註解），Dubbo基於Spring的Schema擴展進行載入。

如果不想使用Spring配置，而希望通過API的方式進行調用，可以自己看一下官方手冊Dubbo API配置，但是，這種做法十分不推薦。

下麵簡單說明一下Dubbo的用法，首先要定義服務生產者的介面及其實現，那麼定義一個介面（該介面需要單獨打包，在生產者和消費者之間共用）：

package com.xrq.dubbo.demo;

public interface DemoService
{
    String sayHello(String name);    
}

在服務生產者處實現介面（對服務消費者隱藏介面實現細節）：

package com.xrq.dubbo.demo.provider;

import com.xrq.dubbo.demo.DemoService;

public class DemoServiceImpl implements DemoService
{
    public String sayHello(String name)
    {
        return "Hello " + name;
    }
}

寫一個provider.xml，在服務生產者使用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">
 
    <!-- 提供方應用信息，用於計算依賴關係 -->
    <dubbo:application name="hello-world-app"  />
 
    <!-- 使用multicast廣播註冊中心暴露服務地址 -->
    <dubbo:registry address="multicast://224.5.6.7:1234" />
 
    <!-- 用dubbo協議在20880埠暴露服務 -->
    <dubbo:protocol name="dubbo" port="20880" />
 
    <!-- 聲明需要暴露的服務介面 -->
    <dubbo:service interface="com.xrq.dubbo.demo.DemoService" ref="demoService" />
 
    <!-- 和本地bean一樣實現服務 -->
    <bean id="demoService" class="com.xrq.dubbo.demo.provider.DemoServiceImpl" />
 
</beans>

在服務消費者處寫一個consumer.xml引用遠程服務：

<?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">
 
    <!-- 消費方應用名，用於計算依賴關係，不是匹配條件，不要與提供方一樣 -->
    <dubbo:application name="consumer-of-helloworld-app"  />
 
    <!-- 使用multicast廣播註冊中心暴露發現服務地址 -->
    <dubbo:registry address="multicast://224.5.6.7:1234" />
 
    <!-- 生成遠程服務代理，可以和本地bean一樣使用demoService -->
    <dubbo:reference id="demoService" interface="com.alibaba.dubbo.demo.DemoService" />
 
</beans>

服務消費者處只要通過Spring拿到demoService，即可像使用本地介面一樣使用DemoService這個介面裡面的方法：

import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.xrq.dubbo.demo.DemoService;
 
public class Consumer 
{
    public static void main(String[] args) throws Exception    
    {
        ClassPathXmlApplicationContext context = 
            new ClassPathXmlApplicationContext(new String[] {"http://aaa.bbb.ccc:dddd/eee/fff/consumer.xml"});
        context.start();
 
        DemoService demoService = (DemoService)context.getBean("demoService"); // 獲取遠程服務代理
        String hello = demoService.sayHello("world"); // 執行遠程方法
 
        System.out.println(hello); // 顯示調用結果
    }
}

看到整個過程中：

1、沒有任何Dubbo的代碼，使用Dubbo的時候全部都是Spring配置，這就是前面提到的Dubbo對應用沒有任何API侵入

2、不需要考慮底層線程模型、序列化、反序列化、url解析等問題，這些都是Dubbo底層做好的

Dubbo常用標簽

首先說一個優先順序的問題，在dubbo中比如timeout、retries、loadbalance等參數可以在多個標簽內同時配置，它們之間的優先順序，dubbo手冊上是這麼說的：

OK，下麵羅列一些Dubbo常用的，也就是說每個項目的Dubbo的xml文件中基本都會出現的標簽，並以表格形式列舉標簽中常見的可用屬性。

1、<dubbo:service /> 用於服務生產者暴露服務配置

2、<dubbo:reference /> 用於服務消費者引用服務配置

3、<dubbo:protocol /> 用於服務生產者協議配置（如果需要支持多協議，可以聲明多個此標簽，併在<dubbo:service />通過protocol屬性指定使用的協議）

4、<dubbo:registry /> 用於註冊中心配置（如果有多個不同的註冊中心可以聲明多個標簽並且<dubbo:service />或<dubbo:reference />中使用registry屬性指定）

5、<dubbo:method />用於方法級配置（該標簽為<dubbo:service/>或<dubbo:reference/>的子標簽，用於控制到方法級）

另外，還有<dubbo:provider/>和<dubbo:consumer/>分別表示服務提供者（生產者）和服務消費者的預設值配置，就不列舉了。

Dubbo協議dubbo://

前面有說到一個Dubbo協議，下麵來看一下Dubbo協議。

Dubbo協議Dubbo的預設協議，使用基於mina1.1.7+hessian3.2.1的tbremoting交互。

• 連接個數：單連接
• 連接方式：長連接
• 傳輸協議：TCP
• 傳輸方式：NIO非同步傳輸
• 序列化：Hessian二進位序列化
• 適用範圍：傳入傳出參數數據包較小（建議小於100K），消費者比提供者個數多，單一消費者無法壓滿提供者，儘量不要使用dubbo協議傳輸大文件或超大字元串
• 使用場景：常規遠程服務方法調用

從上面的適用範圍總結，dubbo適合小數據量大併發的服務調用，以及消費者機器遠大於生產者機器數的情況，不適合傳輸大數據量的服務比如文件、視頻等，除非請求量很低。

另外，Dubbo手冊還給開發者列出了Dubbo協議使用的約束：

1. 參數及返回值需要實現Serializable介面
2. 參數及返回值自定義實現List、Map、Number、Date、Calendar等介面，只能用JDK自帶的實現，因為hessian會做特殊處理，自定義實現類中的屬性值都會丟失