Dubbo使用教程

http://dubbo.apache.org/zh-cn/docs/dev/implementation.html

https://www.cnblogs.com/tiancai/p/9573912.html

1.背景

在互聯網的發展過程中，在以前，我們只需要一個服務器，將程序全部打包好就可以，但是，隨着流量的增大，常規的垂直應用架構已無法應對，所以，架構就發生了演變。

1 單一應用架構

2 應用和數據庫單獨部署

3 應用和數據庫集群部署

4 數據庫壓力變大，讀寫分離

5 使用緩存技術加快速度

6 數據庫分庫分表

7 應用分為不同的類型拆分

發展到這個階段的時候，我們發現，應用與應用之間的關系已經十分的復雜了，就會出現以下幾個問題（以下摘錄於官網）：

① 當服務越來越多時，服務 URL 配置管理變得非常困難，F5 硬件負載均衡器的單點壓力也越來越大。
② 當進一步發展，服務間依賴關系變得錯蹤復雜，甚至分不清哪個應用要在哪個應用之前啟動，架構師都不能完整的描述應用的架構關系。
③ 接着，服務的調用量越來越大，服務的容量問題就暴露出來，這個服務需要多少機器支撐？什么時候該加機器？

為了解決這由於架構的演變所產生的問題幾個問題，於是，dubbo 產生了。當然，解決這個問題的技術不止 dubbo 。

二 Dubbo的結構圖

                                 

 

從上圖中我們可以看到，Dubbo結構很像生產者-消費者模型，只是在上面這個模型基礎上，加了注冊中心和監控模塊，分別用於管理服務提供方的url，以及監控管理整個流程。生產者(Provider)

整個發布，訂閱流程：

• 啟動容器，加載，運行服務提供者
• 服務提供者在啟動時，在注冊中心發布注冊自己提供的服務
• 服務消費者在啟動時，在注冊中心訂閱自己所需的服務。

如果存在服務失敗或者變更的情況，Dubbo就進行如下的操作：

• 注冊中心返回服務提供者地址列表給消費者，如果有變更，注冊中心將基於長連接推送變更數據給消費者。
• 服務消費者，從提供者地址列表中，基於軟負載均衡算法，選一台提供者進行調用，如果調用失敗，再選另一台調用。
• 服務消費者和提供者，在內存中累計調用次數和調用時間，定時每分鍾發送一次統計數據到監控中心。

三Dubbo實例教程

3.1導入Maven依賴

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.ouyangsihai</groupId>
    <artifactId>dubbo-provider</artifactId>
    <version>1.0-SNAPSHOT</version>

    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>3.8.1</version>
            <scope>test</scope>
        </dependency>
        <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.6</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.10</version>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.5</version>
        </dependency>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-all</artifactId>
            <version>4.1.32.Final</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.8.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.8.0</version>
        </dependency>

    </dependencies>
</project>

3.2定義Provider接口

首先，定義Provider的接口，並實現provider接口， Dubbo 的作用簡單來說就是給消費端提供接口。Dubbo將Provider接口在服務中心注冊，Consumer端就可以調用該注冊的接口。

/**
 * 定義provider接口 
 */
public interface ProviderService {

    String SayHello(String word);
}

/**
 * 定義provider接口的實現類
 */
public class ProviderServiceImpl implements ProviderService{

    public String SayHello(String word) {
        return word;
    }
}

3.3暴露Provider接口的配置方式

包括：xml配置，api配置和注解配置。下面只介紹下xml配置的方式，這種方式比較常用。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
    http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <dubbo:application name="項目名" organization="項目部門"
                       owner="san.zhang"/>
    <dubbo:protocol port="${端口號}" threadpool="dynamic.dubbo.thread.pool">
        <dubbo:parameter key="threadname" value="dubbo.thread"/>
        <dubbo:parameter key="corethreads" value="150"/>
        <dubbo:parameter key="threads" value="250"/>
        <dubbo:parameter key="queues" value="1000"/>
    </dubbo:protocol>

  //注冊需要暴露的服務providerServiceImp，
    <dubbo:service ref="providerServiceImp"
                   registry="ttsi_flight_detail"
                   interface="com.api.ProviderService"
                   version="1.0.0"
                   timeout="30000">
        <dubbo:parameter key="qloglevel" value="${dubboLog.level:10}"/>
    </dubbo:service>
 <!--Bean bean定義-->
    <bean id="providerServiceImp" class="com.dubbo.ProviderServiceImp"/>
//dubbo.zk.address一般指定zk地址，dubbo.group指定項目的組，id作為標識
    <dubbo:registry address="${dubbo.zk.address}" group="${dubbo.group}" protocol="zookeeper"
                    id="oag"/>

</beans>

3.4Consumer端

3.4.1 Maven配置跟Provider端配置一樣

3.4.2 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" owner="jie"/>

    <!--dubbo這個服務所要暴露的服務地址所對應的注冊中心-->
    <!--點對點的方式-->
    <!--<dubbo:registry address="N/A" />-->
    <dubbo:registry address="{zk.address}" port="{port}" check="false"/>

    <!--生成一個遠程服務的調用代理-->
    <dubbo:reference id="providerService"
                     interface="Service.ProviderService"/>

</beans>

 未完待續。。。