Dubbo項目入門

Dubbo是一款高性能、輕量級的開源Java RPC框架，它提供了三大核心能力：面向接口的遠程方法調用，智能容錯和負載均衡，以及服務自動注冊和發現。
它的特性如下

• 面向接口代理的高性能RPC調用
• 智能負載均衡
• 服務自動注冊與發現
• 高度可擴展能力
• 運行期流量調度
• 可視化的服務治理與運維

Talk is cheap， Show me the code。現在來着手搭建一個Dubbo項目吧。

搭建一個xml配置的Dubbo項目

創建三個項目

• service-api 服務提供者和服務消費者共用的接口

• service-consumer 服務消費者

• service-provider 服務提供者

共用的接口

先在service-api定義一個公用接口

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

服務提供者

服務提供者service-provider提供一個DemoService的實現類

public class DemoServiceImpl implements DemoService {

    @Override
    public String sayHello(String name) {
        System.out.println("[" + LocalDate.now() + "] Hello " + name );
        return "Hello " + name;
    }

}

編寫xml配置文件

配置應用名稱

<dubbo:application name="demo-provider"/>

配置注冊中心

可以使用Multicast、Redis、Zookeeper、Simple這四個作為注冊中心。

<dubbo:registry address="multicast://224.5.6.7:1234"/>

配置協議

默認為dubbo

<dubbo:protocol name="dubbo" port="20880"/>

定義bean

然后定義bean，以及將bean作為服務暴露出去

<bean id="demoService" class="com.learnDubbo.demo.provider.DemoServiceImpl"/>

<dubbo:service interface="com.learnDubbo.demo.DemoService" ref="demoService"/>

main函數

編寫一個main函數用於啟動服務提供者

public static void main(String[] args) throws Exception {

    ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("dubbo-provider.xml");
    context.start();

    System.in.read();//用於阻塞函數，使其一直運行
}

服務消費者

服務消費者需要調用service-provider 服務提供者提供的DemoService實現類
同樣需要編寫xml文件，配置文件和服務提供者的類似，不同的是需要將暴露服務的配置修改為引用服務的配置，如下

引用服務

<dubbo:reference id="demoService" interface="com.learnDubbo.demo.DemoService"/>

main函數

編寫一個main函數用於啟動服務消費者,然后一直循環調用服務提供者提供的服務

public static void main(String[] args) {
    ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("dubbo-consumer.xml");
    context.start();
    DemoService demoService = (DemoService) context.getBean("demoService"); // 調用服務提供者提供的服務
    while (true) {
        try {
            Thread.sleep(1000);
            String hello = demoService.sayHello("Dubbo"); // call remote method
            System.out.println(hello); // get result
        } catch (Throwable throwable) {
            throwable.printStackTrace();
        }
    }
}

測試

先啟動service-provider項目，然后在啟動service-consumer，輸出結果如下

搭建一個注解的Dubbo項目

服務提供者和服務消費者共用的接口還是使用service-api，新建下面兩個項目

• service-consumer-annotation 基於注解的服務消費者

• service-provider-annotation 基於注解的服務提供者

基於注解的服務提供者

新建一個springboot項目
同樣需要提供一個DemoService的實現類，且在類上增加@Service注解

注：是com.alibaba.dubbo.config.annotation.Service
不是org.springframework.stereotype.Service
別導錯了

接下來需要增加dubbo的配置類

@Configuration
public class DubboConfiguration {

    /**
     * 對應xml配置:<dubbo:application name="demo-provider"/>
     * @return
     */
    @Bean
    public ApplicationConfig applicationConfig() {
        ApplicationConfig applicationConfig = new ApplicationConfig();
        applicationConfig.setName("demo-provider--annotation");
        return applicationConfig;
    }

    /**
     * 對應xml配置:<dubbo:registry address="multicast://224.5.6.7:1234"/>
     * @return
     */
    @Bean
    public RegistryConfig registryConfig() {
        RegistryConfig registryConfig = new RegistryConfig();
        registryConfig.setAddress("multicast://224.5.6.7:1234");
        return registryConfig;
    }
}

最后一步在啟動類上增加注解@DubboComponentScan(basePackages = "com.learnDubbo.demo.provider.service")basePackages自行修改為提供服務類所在的包路徑

基於注解的服務消費者

也是需要有一個配置類，和服務提供者類似，這里就不貼代碼了
接下來創建一個Controller，用於測試結果，代碼如下

@RestController
public class DemoController {

    @Reference
    private DemoService demoService;

    @GetMapping("sayHello")
    public String sayHello(){
        return demoService.sayHello("Dubbo");
    }
}

@Reference注解表示引用服務類似於xml配置

<dubbo:reference id="demoService" interface="com.learnDubbo.demo.DemoService"/>

在項目啟動類上同樣需要注解@DubboComponentScan指定dubbo掃描路徑

測試

同xml配置的一樣，需要先啟動服務提供者

---

配置信息

配置信息主要包括3大塊，注冊中心、協議和schema配置

注冊中心

注冊中心總共有4個，如下

注冊中心	簡要說明	dubbo文檔介紹
Multicast	不需要啟動任何中心節點，只要廣播地址一樣，就可以互相發現。	鏈接
zookeeper	Apacahe Hadoop 的子項目，是一個樹型的目錄服務，支持變更推送，適合作為 Dubbo 服務的注冊中心，工業強度較高，可用於生產環境，並推薦使用。	鏈接
Redis	一個高效的 KV 存儲服務器 ， 從 2.1.0 版本開始支持 。	鏈接
Simple	一個普通的 Dubbo 服務，可以減少第三方依賴，使整體通訊方式一致。	鏈接

使用Redis注冊中心

當使用Redis注冊中心，需先把服務提供方和消費放的注冊中心xml配置修改為下方

<dubbo:registry address="redis://localhost:6379"/>

對應的redis會產生如下數據

可以看到有兩個key，分別對應服務提供者和消費者。兩個key對應的數據類型為Hash，可以看到服務消費者key的數據如下

1) "consumer://192.168.79.170/com.learnDubbo.demo.DemoService?application=demo-consumer&category=consumers&check=false&dubbo=2.6.2&interface=com.learnDubbo.demo.DemoService&methods=sayHello&pid=14208&side=consumer&timestamp=1534389723130"
2) "1534389813690"

第一個為URL址，第二個為過期時間。
官網給的圖如下

使用Zookeeper注冊中心

當使用Zookeeper注冊中心，需先把服務提供方和消費放的注冊中心xml配置修改為下方

<dubbo:registry address="zookeeper://localhost:2181"/>

對應的Zookeeper會產生如下數據

下圖是官網給出的數據圖

有些出入，但大致還是相同的，多了configurators和routers。
當服務提供者啟動時: 會創建對應的目錄結構，例如我上面代碼中的共用接口名為com.learnDubbo.demo.DemoService，就會創建 /dubbo/com.learnDubbo.demo.DemoService目錄，然后在創建providers目錄，再在providers目錄下寫入自己的 URL 地址。
當服務消費者啟動時：會在/dubbo/com.learnDubbo.demo.DemoService目錄創建 consumers目錄，並在consumers目錄寫入自己的 URL 地址。
當監控中心啟動時: 訂閱 /dubbo/com.learnDubbo.demo.DemoService 目錄下的所有提供者和消費者 URL 地址。

協議

協議	簡要說明	dubbo文檔介紹
dubbo	Dubbo 缺省協議采用單一長連接和 NIO 異步通訊，適合於小數據量大並發的服務調用，以及服務消費者機器數遠大於服務提供者機器數的情況。	鏈接
rmi	RMI 協議采用 JDK 標准的 java.rmi.* 實現，采用阻塞式短連接和 JDK 標准序列化方式。	鏈接
hessian	Hessian 協議用於集成 Hessian 的服務，Hessian 底層采用 Http 通訊，采用 Servlet 暴露服務，Dubbo 缺省內嵌 Jetty 作為服務器實現。	鏈接
http	基於 HTTP 表單的遠程調用協議，采用 Spring 的 HttpInvoker 實現。	鏈接
webservice	基於 WebService 的遠程調用協議，基於 Apache CXF 的 frontend-simple 和 transports-http 實現 。	鏈接
thrift	當前 dubbo 支持的 thrift 協議是對 thrift 原生協議的擴展，在原生協議的基礎上添加了一些額外的頭信息，比如 service name，magic number 等。	鏈接
memcached	基於 memcached實現的 RPC 協議。	鏈接
redis	基於 Redis 實現的 RPC 協議。	鏈接
rest	基於標准的Java REST API——JAX-RS 2.0（Java API for RESTful Web Services的簡寫）實現的REST調用支持	鏈接

schema配置的涉及的東西有點多這里就不列出來了

---

參考資料：Dubbo官網

官網的介紹都很詳細了，從官網中一般都能獲取到你想到的信息。

有需要查看這篇博文的源碼的可以點這里：Github地址