天天看點
傳回

分布式服務治理架構Dubbo的前世今生及應用實戰

分布式服務治理架構Dubbo的前世今生及應用實戰

Dubbo的出現背景

Dubbo從開源到現在，已經出現了接近10年時間，在國内各大企業被廣泛應用。 它到底有什麼魔力值得大家去追捧呢？本篇文章給大家做一個詳細的說明。

大規模服務化對于服務治理的要求

當企業開始大規模的服務化以後，遠端通信帶來的弊端就越來越明顯了。比如說

  1. 服務鍊路變長了，如何實作對服務鍊路的跟蹤和監控呢？
  2. 服務的大規模叢集使得服務之間需要依賴第三方注冊中心來解決服務的發現和服務的感覺問題
  3. 服務通信之間的異常，需要有一種保護機制防止一個節點故障引發大規模的系統故障，是以要有容錯機制
  4. 服務大規模叢集會是的用戶端需要引入負載均衡機制實作請求分發

而這些對于服務治理的要求，傳統的RPC技術在這樣的場景中顯得有點力不從心，是以很多企業開始研發自己的RPC架構，比如阿裡的HSF、Dubbo；京東的JSF架構、當當的dubbox、新浪的motan、螞蟻金服的sofa等等

有技術輸出能力的公司，都會研發适合自己場景的rpc架構，要麼是從0到1開發，要麼是基于現有的思想結合公司業務特色進行改造。而沒有技術輸出能力的公司，遇到服務治理的需求時，會優先選擇那些比較成熟的開源架構。而Dubbo就是其中一個

dubbo主要是一個分布式服務治了解決方案，那麼什麼是服務治理？服務治理主要是針對大規模服務化以後，服務之間的路由、負載均衡、容錯機制、服務降級這些問題的解決方案，而Dubbo實作的不僅僅是遠端服務通信，并且還解決了服務路由、負載、降級、容錯等功能。

Dubbo的發展曆史

Dubbo是阿裡巴巴内部使用的一個分布式服務治理架構，2012年開源，因為Dubbo在公司内部經過了很多的驗證相對來說比較成熟，是以在很短的的還是件就被很多網際網路公司使用，再加上阿裡出來的很多技術大牛進入各個創業公司擔任技術架構以後，都以Dubbo作為主推的RPC架構使得dubbo很快成為了很多網際網路公司的首要選擇。并且很多公司在應用dubbo時，會基于自身業務特性進行優化和改進，是以也衍生了很多版本，比如京東的JSF、比如新浪的Motan、比如當當的dubbox.

在2014年10月份，Dubbo停止了維護。後來在2017年的9月份，阿裡宣布重新開機Dubbo，并且對于Dubbo做好了長期投入的準備，并且在這段時間Dubbo進行了非常多的更新，目前的版本已經到了2.7.

2018年1月8日，Dubbo創始人之一梁飛在Dubbo交流群裡透露了Dubbo 3.0正在動工的消息。Dubbo 3.0核心與Dubbo2.0完全不同，但相容Dubbo 2.0。Dubbo 3.0将支援可選Service Mesh

2018年2月份， Dubbo捐給了Apache。另外，阿裡巴巴對于Spring Cloud Alibaba生态的完善，以及Spring Cloud團隊對于alibaba整個服務治理生态的支援，是以Dubbo未來依然是國内絕大部分公司的首要選擇。

Dubbo的整體架構

分布式服務治理架構Dubbo的前世今生及應用實戰

Dubbo的使用

首先，建構兩個maven項目

  • user-service
    • user-service-api
    • user-service-provider
  • user-service-consumer

user-service提供服務的公共契約，裡面提供了user-service對外的服務。

public interface ILoginService {

    String login(String username,String password);
}

在user-service-provider服務中，提供ILoginService的實作

public class LoginServiceImpl implements ILoginService{
    @Override
    public String login(String username, String password) {
        if(username.equals("admin")&&password.equals("admin")){
            return "SUCCESS";
        }
        return "FAILED";
    }
}
           

public class App 
{
    public static void main( String[] args ){
        ILoginService loginService=null;

        System.out.println(loginService.login("admin","admin"));
    }
}

問題來了，現在user-service-consumer作為服務消費者，如何去調用遠端服務user-service-provider呢？

按照前面對于服務遠端通信的原理來說，服務提供方必然需要将服務釋出到網絡上，并且提供對應的通路協定。而服務消費端必然需要基于這個協定來進行通路。

這個時候，dubbo這個中間件就派上用場了，它的最基本作用就是提供服務的釋出和服務的遠端通路。

引入Dubbo釋出服務

  • 引入dubbo依賴包 
    <dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo</artifactId>
    <version>2.7.8</version>
</dependency>
  • 在/src/main/resource/META-INF/spring目錄下添加application.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="user-service"/>
    <!-- 使用multicast廣播注冊中心暴露服務位址 -->
    <dubbo:registry address="N/A" />
    <!-- 用dubbo協定在20880端口暴露服務 -->
    <dubbo:protocol name="dubbo" port="20880" />
    <!-- 聲明需要暴露的服務接口 -->
    <dubbo:service interface="com.gupaoedu.demo.ILoginService" ref="loginService" />
    <!-- 和本地bean一樣實作服務 -->
    <bean id="loginService" class="com.gupaoedu.demo.LoginServiceImpl" />

</beans>
  • 啟動服務 
    public class App 
{
    public static void main( String[] args ){
        Main.main(args);
    }
}
  • 啟動成功後，會在控制台看到如下日志 
    資訊:  [DUBBO] Export dubbo service com.gupaoedu.demo.ILoginService to url dubbo://192.168.1.104:20880/com.gupaoedu.demo.ILoginService?anyhost=true&application=user-service&bind.ip=192.168.1.104&bind.port=20880&deprecated=false&dubbo=2.0.2&dynamic=true&generic=false&interface=com.gupaoedu.demo.ILoginService&methods=login&pid=24280&release=2.7.8&side=provider&timestamp=1596550697070, dubbo version: 2.7.8, current host: 192.168.152.1
八月 04, 2020 10:18:17 下午 org.apache.dubbo.remoting.transport.AbstractServer info
資訊:  [DUBBO] Start NettyServer bind /0.0.0.0:20880, export /192.168.1.104:20880, dubbo version: 2.7.8, current host: 192.168.152.1

通過上述步驟，就表示ILoginService已經釋出到了網絡上，基于NettyServer的形式，預設監聽20880端口

服務消費者引入dubbo

  • 添加jar包依賴 
    <dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo</artifactId>
    <version>2.7.8</version>
</dependency>
  • 在/src/main/resources/META-INF/spring目錄下添加application.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="user-service-consumer"/>
    <!-- 使用multicast廣播注冊中心暴露服務位址 -->
    <dubbo:registry address="N/A" />
    <dubbo:reference id="loginService" interface="com.gupaoedu.demo.ILoginService"/>
</beans>
  • 修改main方法
    • 通過ApplicationContext加載spring的配置檔案
    • 從容器中獲得一個ILoginService的bean 
    public class App 
{
    public static void main( String[] args ){
        ILoginService loginService=null;
        ApplicationContext applicationContext=new ClassPathXmlApplicationContext("classpath:META-INF/spring/application.xml");
        loginService=applicationContext.getBean(ILoginService.class);

        System.out.println(loginService.login("admin","admin"));
    }
}

指定服務提供端的url

在上述的配置完成之後，運作項目後發現會提示如下錯誤

IllegalStateException: No such any registry to reference com.gupaoedu.demo.ILoginService on the consumer 192.168.152.1 use dubbo version 2.7.8, please config <dubbo:registry address="..." /> to your spring config.

原因是，我們配置的dubbo:registry指定的注冊中心是N/A，表示沒有配置注冊中心。

其次，我們也沒有明确的指明服務提供者在什麼位置。是以解決這個問題的方法有兩種

  • 指向服務提供者的位址
  • 配置服務注冊中心，把服務提供者注冊到注冊中心，然後服務消費者指向注冊中心從注冊中心擷取服務位址

修改方式如下，修改服務消費者中application.xml中的dubbo:reference。

<dubbo:reference id="loginService" interface="com.gupaoedu.demo.ILoginService"
     url="dubbo://192.168.1.104:20880/com.gupaoedu.demo.ILoginService"/>

總結

簡單總結一下上面的整個過程，其實不難發現，Dubbo這個中間件為我們提供了服務遠端通信的解決方案。通過dubbo這個架構，可以開發者快速高效的建構微服務架構下的遠端通信實作。

不知道大家是否發現，我們在使用dubbo釋出服務，或者消費服務的時候，全程都是采用spring的配置來完成的，這樣的好處是我們在學習或者使用dubbo時，如果你用過spring這個架構，那麼對于它的學習難度會大大的降低。而且我們也可以看到，dubbo是完全內建Spring 的，是以後續我們去分析dubbo的源碼時，還是會有一些和spring有關的内容。

而且如果大家之前學習過我手寫RPC的那節課，也基本能猜測到它的整個實作結構，大家不妨大膽的去猜測dubbo的一些實作細節，以助于後續在深度學習dubbo時更好的了解。

引入注冊中心

Dubbo并不僅僅隻是一個RPC架構，他還是一個服務治理架構，它提供了對服務的統一管理、以及服務的路由等功能。

在上面的案例中，我們隻是掩飾了Dubbo作為RPC通信的點對點服務，但是就像咱們前面在學習spring cloud的内容一樣，服務多了以後，如何管理和維護，以及動态發現呢？

而且，從Dubbo的架構圖中可以看到，Dubbo天然就支援服務注冊與發現，官方最早推薦的服務注冊中心是zookeeper，當然，目前dubbo能夠支援的注冊中心已經非常多了，比如

consul、etcd、nacos、sofa、zookeeper、eureka、redis等等，很顯然，Dubbo已經在往一個獨立微服務解決方案的生态在發展。

內建Zookeeper作為服務注冊中心

  • 添加zookeeper的jar包依賴 
    <dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-dependencies-zookeeper</artifactId>
    <version>2.7.8</version>
</dependency>
  • 修改服務提供者和服務消費者的配置 
    <dubbo:registry address="zookeeper://192.168.216.128:2181" />

內建Nacos作為服務注冊中心

  • 啟動nacos 
    docker run --name nacos -d -p 8848:8848 --privileged=true --restart=always -e JVM_XMS=512m -e JVM_XMX=2048m -e MODE=standalone -e PREFER_HOST_MODE=hostname -v /home/nacos/logs:/home/nacos/logs nacos/nacos-server
    • privileged: 使用該參數，container内的root擁有真正的root權限。否則，container内的root隻是外部的一個普通使用者權限。
    • 當 Docker 重新開機時，容器自動重新開機
    • PREFER_HOST_MODE: ip #如果支援主機名可以使用hostname,否則使用ip，預設也是ip
  • 添加依賴 
    <dependency>
    <groupId>com.alibaba.nacos</groupId>
    <artifactId>nacos-client</artifactId>
    <version>1.2.1</version>
</dependency>
  • 修改配置 
    <dubbo:registry address="nacos://192.168.216.128:8848" timeout="10000" />

Dubbo Spring Cloud

既然我們講的是Spring Cloud Alibaba這個專題，那麼我們就有必要去了解一下Dubbo是如何內建Spring Cloud去使用的。

Dubbo Spring Cloud是建構在原生的Spring Cloud之上，涵蓋了Spring Cloud原生特性，而且相對于Spring Cloud原生治理來說，Dubbo Spring Cloud提供了更加穩定和成熟的實作。

具體的特性對比如下：

分布式服務治理架構Dubbo的前世今生及應用實戰

為什麼叫Dubbo Spring Cloud，而不是Spring Cloud Dubbo呢，在我看來，Dubbo本身是自成一個生态體系，并且在本身的服務治理以及成熟度上要比Spring cloud 更加突出。

是以實際上Dubbo整合Spring Cloud，是Dubbo這個成熟的生态去擁抱spring cloud的标準體系。

Dubbo Spring Cloud 基于 Dubbo Spring Boot 2.7.1[1] 和 Spring Cloud 2.x 開發，無論開發人員是 Dubbo 使用者還是 Spring Cloud 使用者， 都能輕松地駕馭，并以接近“零”成本的代價使應用向上遷移

從 2.7.0 開始，Dubbo Spring Boot 與 Dubbo 在版本上保持一緻

接下來，我們可以去利用Dubbo Spring Cloud來做一個簡單的案例實作

建立一個項目

  • 建立一個spring-cloud-dubbo-example的maven工程
  • 分别添加三個子產品
    • spring-cloud-dubbo-sample-api
    • spring-cloud-dubbo-sample-provider
    • spring-cloud-dubbo-sample-consumer
其中後面兩個子產品都是spring boot的應用。

修改

spring-cloud-dubbo-sample-provider

這個子產品中。

  • 将dependencyManagement部分的依賴移動到parent pom.xml
  • 修改spring-cloud-dubbo-sample-provider中的pom.xml,增加parent子產品的依賴 
    <parent>
    <groupId>com.gupaoedu.dubbo</groupId>
    <artifactId>spring-cloud-dubbo-example</artifactId>
    <version>1.0-SNAPSHOT</version>
</parent>
  • 添加maven依賴 
    <dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>
<dependency>
    <groupId>com.gupaoedu.dubbo</groupId>
    <version>1.0-SNAPSHOT</version>
    <artifactId>spring-cloud-dubbo-sample-api</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

定義服務接口

在spring-boot-dubbo-sample-api子產品中，定義接口

public interface IHelloService {

    String sayHello();
}

實作服務

在spring-boot-dubbo-sample-provider中，實作IHelloService接口

public class HelloServiceImpl implements IHelloService{

    @Override
    public String sayHello() {
        return "Hello GuPao";
    }
}

添加

@EnableDiscoveryClient

注解

@EnableDiscoveryClient
@SpringBootApplication
public class SpringCloudDubboSampleProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringCloudDubboSampleProviderApplication.class, args);
    }

}

配置dubbo服務釋出

  • 在服務實作類中添加

    @Service

     
    @Service
public class HelloServiceImpl implements IHelloService{

    @Override
    public String sayHello() {
        return "Hello GuPao";
    }
}
  • 配置dubbo提供方資訊 
    # dubbo 服務掃描基礎包路徑
dubbo.scan.base-packages=com.gupaoedu.dubbo.springclouddubbosampleprovider

dubbo.protocol.id=dubbo
# Dubbo 服務暴露的協定配置，其中子屬性 name 為協定名稱，port 為協定端口（ -1 表示自增端口，從 20880 開始）
dubbo.protocol.name=dubbo
dubbo.protocol.port=-1

spring.cloud.nacos.discovery.server-addr=192.168.216.128:8848

    • dubbo.scan.base-packages

       : 指定 Dubbo 服務實作類的掃描基準包

    • dubbo.protocol

       : Dubbo 服務暴露的協定配置，其中子屬性

      name

       為協定名稱，

      port

       為協定端口（ -1 表示自增端口，從 20880 開始）

    • dubbo.registry

       : Dubbo 服務注冊中心配置，其中子屬性

      address

       的值 "spring-cloud://localhost"，說明挂載到 Spring Cloud 注冊中心

    • spring.cloud.nacos.discovery

       : Nacos 服務發現與注冊配置，其中子屬性 server-addr 指定 Nacos 伺服器主機和端口

版本規範

項目的版本号格式為 x.x.x 的形式，其中 x 的數值類型為數字，從 0 開始取值，且不限于 0~9 這個範圍。項目處于孵化器階段時，第一位版本号固定使用 0，即版本号為 0.x.x 的格式。

由于 Spring Boot 1 和 Spring Boot 2 在 Actuator 子產品的接口和注解有很大的變更，且 spring-cloud-commons 從 1.x.x 版本更新到 2.0.0 版本也有較大的變更，是以我們采取跟 SpringBoot 版本号一緻的版本:

  • 1.5.x 版本适用于 Spring Boot 1.5.x
  • 2.0.x 版本适用于 Spring Boot 2.0.x
  • 2.1.x 版本适用于 Spring Boot 2.1.x
  • 2.2.x 版本适用于 Spring Boot 2.2.x

建構服務消費者 

  • <dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-actuator</artifactId>
</dependency>
<dependency>
    <groupId>com.gupaoedu.dubbo</groupId>
    <version>1.0-SNAPSHOT</version>
    <artifactId>spring-cloud-dubbo-sample-api</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
  • 添加配置檔案 
    spring.application.name=spring-cloud-dubbo-sample-consumer
dubbo.application.name=spring-cloud-dubbo-sample-consumer

dubbo.cloud.subscribed-services=spring-cloud-dubbo-sample-provider
spring.cloud.nacos.discovery.server-addr=192.168.216.128:8848
    除應用名稱

    spring.application.name

     存在差異外，

    spring-cloud-dubbo-client-sample

     新增了屬性

    dubbo.cloud.subscribed-services

    的設定。并且該值為服務提供方應用 "spring-cloud-dubbo-sample-provider"。

    它的主要作用是服務消費方訂閱服務提供方的應用名稱的清單，若需訂閱多應用，使用 "," 分割。 不推薦使用預設值為 "*"，它将訂閱所有應用。

  • 編寫測試代碼 
    @RestController
@EnableDiscoveryClient
@SpringBootApplication
public class SpringCloudDubboSampleConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringCloudDubboSampleConsumerApplication.class, args);
    }
    @Reference
    IHelloService helloService;

    @GetMapping("/say")
    public String say(){
        return helloService.sayHello();
    }

}

多注冊中心的支援

dubbo相對于spring cloud來說，它的強大之處在于，提供了很多不同場景的功能支援，比如多注冊中心的支援。

所謂的多注冊中心，就是指dubbo可以同時配置多個注冊中心的位址，然後針對于不同類型的服務注冊到不同的注冊中心上。

Dubbo多注冊中心可以支援幾種場景

一個服務部署到多個注冊中心

基于spring cloud的配置方式 

  • <dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-dependencies-zookeeper</artifactId>
    <version>2.7.8</version>
    <exclusions>
        <exclusion>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
        <exclusion>
            <artifactId>log4j</artifactId>
            <groupId>log4j</groupId>
        </exclusion>
    </exclusions>
</dependency>
  • 修改application配置 
    dubbo.registries.registry1.address=nacos://192.168.216.128:8848
dubbo.registries.registry1.timeout=10000
dubbo.registries.registry2.address=zookeeper://192.168.216.128:2181
dubbo.registries.registry2.timeout=10000

#spring.cloud.nacos.discovery.server-addr=192.168.216.128:8848
spring.cloud.nacos.discovery.register-enabled=false
spring.cloud.nacos.discovery.watch.enabled=false
spring.cloud.service-registry.auto-registration.enabled=false
    • spring.cloud.service-registry.auto-registration.enabled 關閉spring cloud的自動注冊
    • spring.cloud.nacos.discovery.watch.enabled/spring.cloud.nacos.discovery.register-enabled關閉nacos的服務注冊和監聽
    這麼做的目的是，規避spring cloud本身的服務注冊發現機制，走dubbo本身的服務注冊與發現
  • 修改服務配置 
    @Service(registry = {"registry1","registry2"})
public class HelloServiceImpl implements IHelloService{

    @Override
    public String sayHello() {
        return "Hello GuPao";
    }
}

多注冊中心的引用

  • 修改消費端的application.properties 
    dubbo.registries.registry1.address=nacos://192.168.216.128:8848
dubbo.registries.registry1.timeout=10000
dubbo.registries.registry2.address=zookeeper://192.168.216.128:2181
dubbo.registries.registry2.timeout=10000

spring.cloud.nacos.discovery.register-enabled=false
spring.cloud.nacos.discovery.watch.enabled=false
spring.cloud.service-registry.auto-registration.enabled=false
           
  • <dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-dependencies-zookeeper</artifactId>
    <version>2.7.8</version>
    <exclusions>
        <exclusion>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
        <exclusion>
            <artifactId>log4j</artifactId>
            <groupId>log4j</groupId>
        </exclusion>
    </exclusions>
</dependency>

基于spring boot內建Dubbo方式

實際上，在dubbo spring cloud的使用方式中，對于配置多個服務注冊中心不是很友好而且還有一些潛在的問題， 畢竟dubbo和spring cloud兩個本質上是屬于完全不同的生态耦合在一起，必然會導緻一些相容問題。比如剛剛我們去配置的這些多注冊中心的支援，它需要去關閉spring cloud本身的服務自動注冊和發現的支援，本質上就是在兩個生态中選擇其中一個生态作為主要方式來使用。

是以，如果是在spring cloud的生态中，可以盡量減少對于dubbo本身靈活性的使用，擁抱spring cloud的标準生态，當然如果希望以dubbo作為獨立的生态來使用，大家可以采用spring boot+Dubbo來內建，

這裡同樣也給大家快速建構一下。

另外，dubbo內建到spring boot中還有一個好處，就是它可以繼承spring boot本身的特性

  • 自動裝配（注解驅動、自動裝配）
  • production-ready（安全機制、健康檢測、外部化配置）

建立項目結構

建立基礎的項目結構

  • spring-boot-dubbo-example [maven]
    • spring-boot-dubbo-sample-api [maven]
    • spring-boot-dubbo-sample-provider [spring boot]
    • spring-boot-dubbo-sample-consumerp [spring-boot]

從2.7開始，dubbo的版本和dubbo-spring-boot的版本是保持一緻的，是以大家不用再去擔心版本的問題。

<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>2.7.7</version>
</dependency>
<dependency>
    <groupId>com.alibaba.nacos</groupId>
    <artifactId>nacos-client</artifactId>
    <version>1.2.1</version>
</dependency>

添加服務以及釋出 

@DubboService
public class SayHelloServiceImpl implements ISayHelloService{
    @Override
    public String sayHello() {
        return "Hello GuPaoEdu.com";
    }
}
           
spring.application.name=spring-boot-dubbo-sample-provider

dubbo.registry.address=nacos://192.168.216.128:8848
dubbo.scan.base-packages=com.gupaoedu.springboot.dubbo.springbootdubbosampleprovider.service

dubbo.protocol.name=dubbo
dubbo.protocol.port=-1

編寫服務引用代碼 

  • <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>com.gupaoedu.com</groupId>
    <version>1.0-SNAPSHOT</version>
    <artifactId>spring-boot-dubbo-sample-api</artifactId>
</dependency>
<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>2.7.7</version>
</dependency>
<dependency>
    <groupId>com.alibaba.nacos</groupId>
    <artifactId>nacos-client</artifactId>
    <version>1.2.1</version>
</dependency>
  • 添加web測試類 
    @DubboReference
ISayHelloService sayHelloService;

@GetMapping("/get")
public String get(){
    return sayHelloService.sayHello();
}
           
    dubbo.registry.address=nacos://192.168.216.128:8848

不同服務注冊到不同的注冊中心

從上面的配置可以發現，我們開可以針對不同的服務配置到不同的注冊中心，這個就不再浪費時間去示範了。

多個注冊中心的叢集

如果一個服務消費者引用了多個注冊中心，那麼這個時候服務消費者首先要做的就是先針對注冊中心的負載均衡，然後得到一個目标注冊中心之後，再從目标注冊中心上獲得服務提供者的位址清單再進行叢集通路，實作原理如下圖所示

分布式服務治理架構Dubbo的前世今生及應用實戰

當然，有三種方式來指定注冊中心的負載均衡配置

  • 指定優先級 
    <!-- 來自 preferred=“true” 注冊中心的位址将被優先選擇，隻有該中心無可用位址時才 Fallback 到其他注冊中心 -->
<dubbo:registry address="zookeeper://${zookeeper.address1}" preferred="true" />
  • 同zone優先 
    <!-- 選址時會和流量中的 zone key 做比對，流量會優先派發到相同 zone 的位址 -->
<dubbo:registry address="zookeeper://${zookeeper.address1}" zone="beijing" />
  • 權重輪詢 
    <!-- 來自北京和上海叢集的位址，将以 10:1 的比例來配置設定流量 -->
<dubbo:registry id="beijing" address="zookeeper://${zookeeper.address1}" weight=”100“ />
<dubbo:registry id="shanghai" address="zookeeper://${zookeeper.address2}" weight=”10“ />

接口多版本支援

平時我們在開發接口的時候，可能會面臨到一個接口的修改，但是這個時候因為線上會有一些項目正在使用這個接口，如果直接修改，很可能會對線上的服務造成比較大的影響。

是以對于這種情況，dubbo提供了接口版本的支援。

具體的配置方式

  • 服務端針對同一個接口提供不同版本的實作
  • 并在dubboservice注解中配置版本的聲明 
    @DubboService(registry = {"registry1","registry2"},version = "1.0")
  • 服務消費端指定消費版本号 
    @DubboReference(registry = {"registry1","registry2"},version = "2.0")
ISayHelloService sayHelloService;

多協定的支援

當公司原本采用其他的rpc架構，這個時候如果想遷移到dubbo這個架構上來，那麼Dubbo提供的多協定支援就能夠提供幾乎零成本的遷移。

對于一個服務，可以同時釋出多種不同協定的接口，也可以針對不同的接口釋出不同的協定類型。并且從2.7開始，dubbo對于一些主流的協定做了支援，目前已經支援的協定有

dubbo協定、hessian協定、http協定、thrift、rmi、webservice、grpc、rest等。初次之外，dubbo還提供了非常靈活的可擴充性機制，對于有定制化需求或者目前正在使用的協定，dubbo不支援的公司，是可以自己去進行擴充。

整體的靈活性以及可插拔性的特性，相比spring cloud來說，更加強大。

JAX-RS協定說明

Dubbo中的REST（表述性資源轉移）支援，是基于JAX-RS2.0(Java API for RESTful Web Services)來實作的。

REST是一種架構風格，簡單來說就是對于api接口的限制，基于URL定位資源，使用http動詞（GET/POST/DELETE）來描述操作

REST很早就提出來了，在早期開發人員為了實作REST，會使用各種工具來實作，比如Servlets就經常用來開發RESTful的程式。随着REST被越來越多的開發人員采用，是以JCP(Java community process)提出了JAX-RS規範，并且提供了一種新的基于注解的方式來開發RESTful服務。有了這樣的一個規範，使得開發人員不需要關心通訊層的東西，隻需要關注資源以以及資料對象。

JAX-RS規範的實作有：Apache CXF、Jersey(由Sun公司提供的JAX-RS的參考實作)、RESTEasy(jboss實作)等。

而Dubbo裡面實作的REST就是基于Jboss提供的RESTEasy架構來實作的

SpringMVC中的RESTful實作我們用得比較多，它也是JAX-RS規範的一種實作

添加REST支援 

  • <dependency>
    <groupId>org.jboss.resteasy</groupId>
    <artifactId>resteasy-jaxrs</artifactId>
    <version>3.13.0.Final</version>
</dependency>
<dependency>
    <groupId>org.jboss.resteasy</groupId>
    <artifactId>resteasy-client</artifactId>
    <version>3.13.0.Final</version>
</dependency>
<dependency>
    <groupId>org.eclipse.jetty</groupId>
    <artifactId>jetty-server</artifactId>
    <version>9.4.19.v20190610</version>
</dependency>
<dependency>
    <groupId>org.eclipse.jetty</groupId>
    <artifactId>jetty-servlet</artifactId>
    <version>9.4.19.v20190610</version>
</dependency>
  • 修改配置檔案 
    dubbo.protocols.dubbo.name=dubbo
dubbo.protocols.dubbo.port=-1

dubbo.protocols.rest.name=rest
dubbo.protocols.rest.port=8888
dubbo.protocols.rest.server=jetty
  • 修改api的接口定義 
    @Path("/")
public interface ISayHelloService {

    @GET
    @Path("say")
    String sayHello();

}
版權聲明：本部落格所有文章除特别聲明外，均采用 CC BY-NC-SA 4.0 許可協定。轉載請注明來自

Mic帶你學架構

！

如果本篇文章對您有幫助，還請幫忙點個關注和贊，您的堅持是我不斷創作的動力。歡迎關注「跟着Mic學架構」公衆号公衆号擷取更多技術幹貨！

分布式服務治理架構Dubbo的前世今生及應用實戰
Apache Dubbo Dubbo
上一篇: 深度剖析Spring Boot自動裝配機制實作原理
下一篇: TCP三向交握四次揮手，通俗易懂版

繼續閱讀