Dubbo前世今生

Dubbo的出現(xiàn)背景

Dubbo從開源到現(xiàn)在，已經(jīng)出現(xiàn)了接近10年時間，在國內(nèi)各大企業(yè)被廣泛應(yīng)用砌们。 它到底有什么魔力值得大家去追捧呢？本篇文章給大家做一個詳細的說明搁进。

大規(guī)模服務(wù)化對于服務(wù)治理的要求

當(dāng)企業(yè)開始大規(guī)模的服務(wù)化以后怨绣，遠程通信帶來的弊端就越來越明顯了。比如說

1. 服務(wù)鏈路變長了拷获，如何實現(xiàn)對服務(wù)鏈路的跟蹤和監(jiān)控呢篮撑？

2. 服務(wù)的大規(guī)模集群使得服務(wù)之間需要依賴第三方注冊中心來解決服務(wù)的發(fā)現(xiàn)和服務(wù)的感知問題

3. 服務(wù)通信之間的異常，需要有一種保護機制防止一個節(jié)點故障引發(fā)大規(guī)模的系統(tǒng)故障匆瓜，所以要有容錯機制

4. 服務(wù)大規(guī)模集群會是的客戶端需要引入負載均衡機制實現(xiàn)請求分發(fā)

而這些對于服務(wù)治理的要求赢笨，傳統(tǒng)的RPC技術(shù)在這樣的場景中顯得有點力不從心，因此很多企業(yè)開始研發(fā)自己的RPC框架驮吱，比如阿里的HSF茧妒、Dubbo；京東的JSF框架左冬、當(dāng)當(dāng)?shù)膁ubbox桐筏、新浪的motan、螞蟻金服的sofa等等

有技術(shù)輸出能力的公司拇砰，都會研發(fā)適合自己場景的rpc框架梅忌，要么是從0到1開發(fā)，要么是基于現(xiàn)有的思想結(jié)合公司業(yè)務(wù)特色進行改造除破。而沒有技術(shù)輸出能力的公司牧氮，遇到服務(wù)治理的需求時，會優(yōu)先選擇那些比較成熟的開源框架瑰枫。而Dubbo就是其中一個

dubbo主要是一個分布式服務(wù)治理解決方案踱葛，那么什么是服務(wù)治理？服務(wù)治理主要是針對大規(guī)模服務(wù)化以后光坝，服務(wù)之間的路由尸诽、負載均衡、容錯機制盯另、服務(wù)降級這些問題的解決方案性含，而Dubbo實現(xiàn)的不僅僅是遠程服務(wù)通信，并且還解決了服務(wù)路由土铺、負載胶滋、降級板鬓、容錯等功能。

Dubbo的發(fā)展歷史

Dubbo是阿里巴巴內(nèi)部使用的一個分布式服務(wù)治理框架究恤，2012年開源俭令，因為Dubbo在公司內(nèi)部經(jīng)過了很多的驗證相對來說比較成熟，所以在很短的的還是件就被很多互聯(lián)網(wǎng)公司使用部宿，再加上阿里出來的很多技術(shù)大牛進入各個創(chuàng)業(yè)公司擔(dān)任技術(shù)架構(gòu)以后抄腔，都以Dubbo作為主推的RPC框架使得dubbo很快成為了很多互聯(lián)網(wǎng)公司的首要選擇。并且很多公司在應(yīng)用dubbo時理张，會基于自身業(yè)務(wù)特性進行優(yōu)化和改進赫蛇，所以也衍生了很多版本，比如京東的JSF雾叭、比如新浪的Motan悟耘、比如當(dāng)當(dāng)?shù)膁ubbox.

在2014年10月份，Dubbo停止了維護织狐。后來在2017年的9月份暂幼，阿里宣布重啟Dubbo，并且對于Dubbo做好了長期投入的準(zhǔn)備移迫，并且在這段時間Dubbo進行了非常多的更新旺嬉，目前的版本已經(jīng)到了2.7.

2018年1月8日，Dubbo創(chuàng)始人之一梁飛在Dubbo交流群里透露了Dubbo 3.0正在動工的消息厨埋。Dubbo 3.0內(nèi)核與Dubbo2.0完全不同邪媳，但兼容Dubbo 2.0。Dubbo 3.0將支持可選Service Mesh

2018年2月份荡陷， Dubbo捐給了Apache雨效。另外，阿里巴巴對于Spring Cloud Alibaba生態(tài)的完善亲善，以及Spring Cloud團隊對于alibaba整個服務(wù)治理生態(tài)的支持设易，所以Dubbo未來依然是國內(nèi)絕大部分公司的首要選擇。

Dubbo的整體架構(gòu)

img

Dubbo的使用

首先蛹头，構(gòu)建兩個maven項目

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

user-service-api

user-service提供服務(wù)的公共契約，里面提供了user-service對外的服務(wù)戏溺。

public interface ILoginService {

    String login(String username,String password);
}

user-service-provider

在user-service-provider服務(wù)中渣蜗，提供ILoginService的實現(xiàn)

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

user-service-consumer

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

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

問題來了，現(xiàn)在user-service-consumer作為服務(wù)消費者旷祸，如何去調(diào)用遠程服務(wù)user-service-provider呢耕拷？

按照前面對于服務(wù)遠程通信的原理來說，服務(wù)提供方必然需要將服務(wù)發(fā)布到網(wǎng)絡(luò)上托享，并且提供對應(yīng)的訪問協(xié)議骚烧。而服務(wù)消費端必然需要基于這個協(xié)議來進行訪問浸赫。

這個時候，dubbo這個中間件就派上用場了赃绊，它的最基本作用就是提供服務(wù)的發(fā)布和服務(wù)的遠程訪問既峡。

引入Dubbo發(fā)布服務(wù)

• 引入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">
      <!-- 提供方應(yīng)用信息，用于計算依賴關(guān)系 -->
      <dubbo:application name="user-service"/>
      <!-- 使用multicast廣播注冊中心暴露服務(wù)地址 -->
      <dubbo:registry address="N/A" />
      <!-- 用dubbo協(xié)議在20880端口暴露服務(wù) -->
      <dubbo:protocol name="dubbo" port="20880" />
      <!-- 聲明需要暴露的服務(wù)接口 -->
      <dubbo:service interface="com.gupaoedu.demo.ILoginService" ref="loginService" />
      <!-- 和本地bean一樣實現(xiàn)服務(wù) -->
      <bean id="loginService" class="com.gupaoedu.demo.LoginServiceImpl" />
  
  </beans>
  

• 啟動服務(wù)

  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已經(jīng)發(fā)布到了網(wǎng)絡(luò)上，基于NettyServer的形式忠售，默認(rèn)監(jiān)聽20880端口

服務(wù)消費者引入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">
      <!-- 提供方應(yīng)用信息传惠，用于計算依賴關(guān)系 -->
      <dubbo:application name="user-service-consumer"/>
      <!-- 使用multicast廣播注冊中心暴露服務(wù)地址 -->
      <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"));
      }
  }
  

指定服務(wù)提供端的url

在上述的配置完成之后，運行項目后發(fā)現(xiàn)會提示如下錯誤

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卦方，表示沒有配置注冊中心。

其次泰佳，我們也沒有明確的指明服務(wù)提供者在什么位置盼砍。因此解決這個問題的方法有兩種

• 指向服務(wù)提供者的地址
• 配置服務(wù)注冊中心，把服務(wù)提供者注冊到注冊中心乐纸，然后服務(wù)消費者指向注冊中心從注冊中心獲取服務(wù)地址

修改方式如下衬廷，修改服務(wù)消費者中application.xml中的dubbo:reference。

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

總結(jié)

簡單總結(jié)一下上面的整個過程汽绢，其實不難發(fā)現(xiàn)吗跋，Dubbo這個中間件為我們提供了服務(wù)遠程通信的解決方案。通過dubbo這個框架宁昭，可以開發(fā)者快速高效的構(gòu)建微服務(wù)架構(gòu)下的遠程通信實現(xiàn)跌宛。

不知道大家是否發(fā)現(xiàn)，我們在使用dubbo發(fā)布服務(wù)积仗，或者消費服務(wù)的時候疆拘，全程都是采用spring的配置來完成的，這樣的好處是我們在學(xué)習(xí)或者使用dubbo時寂曹，如果你用過spring這個框架哎迄，那么對于它的學(xué)習(xí)難度會大大的降低。而且我們也可以看到隆圆，dubbo是完全集成Spring 的漱挚，因此后續(xù)我們?nèi)シ治鰀ubbo的源碼時，還是會有一些和spring有關(guān)的內(nèi)容渺氧。

而且如果大家之前學(xué)習(xí)過我手寫RPC的那節(jié)課旨涝，也基本能猜測到它的整個實現(xiàn)結(jié)構(gòu)，大家不妨大膽的去猜測dubbo的一些實現(xiàn)細節(jié)侣背，以助于后續(xù)在深度學(xué)習(xí)dubbo時更好的理解白华。

引入注冊中心

Dubbo并不僅僅只是一個RPC框架慨默，他還是一個服務(wù)治理框架，它提供了對服務(wù)的統(tǒng)一管理弧腥、以及服務(wù)的路由等功能厦取。

在上面的案例中，我們只是掩飾了Dubbo作為RPC通信的點對點服務(wù)鸟赫，但是就像咱們前面在學(xué)習(xí)spring cloud的內(nèi)容一樣蒜胖，服務(wù)多了以后，如何管理和維護抛蚤，以及動態(tài)發(fā)現(xiàn)呢台谢？

而且，從Dubbo的架構(gòu)圖中可以看到岁经，Dubbo天然就支持服務(wù)注冊與發(fā)現(xiàn)朋沮，官方最早推薦的服務(wù)注冊中心是zookeeper，當(dāng)然缀壤，目前dubbo能夠支持的注冊中心已經(jīng)非常多了樊拓，比如

consul、etcd塘慕、nacos筋夏、sofa、zookeeper图呢、eureka条篷、redis等等，很顯然蛤织，Dubbo已經(jīng)在往一個獨立微服務(wù)解決方案的生態(tài)在發(fā)展赴叹。

集成Zookeeper作為服務(wù)注冊中心

• 添加zookeeper的jar包依賴

  <dependency>
      <groupId>org.apache.dubbo</groupId>
      <artifactId>dubbo-dependencies-zookeeper</artifactId>
      <version>2.7.8</version>
  </dependency>
  

• 修改服務(wù)提供者和服務(wù)消費者的配置

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

集成Nacos作為服務(wù)注冊中心

• 啟動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: 使用該參數(shù)，container內(nèi)的root擁有真正的root權(quán)限指蚜。否則乞巧，container內(nèi)的root只是外部的一個普通用戶權(quán)限。
  • 當(dāng) Docker 重啟時摊鸡，容器自動重啟
  • PREFER_HOST_MODE: ip #如果支持主機名可以使用hostname,否則使用ip绽媒，默認(rèn)也是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是構(gòu)建在原生的Spring Cloud之上些椒，涵蓋了Spring Cloud原生特性，而且相對于Spring Cloud原生治理來說掸刊，Dubbo Spring Cloud提供了更加穩(wěn)定和成熟的實現(xiàn)。

具體的特性對比如下：

image-20200804224645852

為什么叫Dubbo Spring Cloud赢乓，而不是Spring Cloud Dubbo呢忧侧，在我看來石窑，Dubbo本身是自成一個生態(tài)體系，并且在本身的服務(wù)治理以及成熟度上要比Spring cloud 更加突出蚓炬。

所以實際上Dubbo整合Spring Cloud松逊，是Dubbo這個成熟的生態(tài)去擁抱spring cloud的標(biāo)準(zhǔn)體系。

Dubbo Spring Cloud 基于 Dubbo Spring Boot 2.7.1[1] 和 Spring Cloud 2.x 開發(fā)肯夏，無論開發(fā)人員是 Dubbo 用戶還是 Spring Cloud 用戶经宏， 都能輕松地駕馭，并以接近“零”成本的代價使應(yīng)用向上遷移

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

接下來烁兰，我們可以去利用Dubbo Spring Cloud來做一個簡單的案例實現(xiàn)

創(chuàng)建一個項目

• 創(chuàng)建一個spring-cloud-dubbo-example的maven工程
• 分別添加三個模塊
  • spring-cloud-dubbo-sample-api
  • spring-cloud-dubbo-sample-provider
  • spring-cloud-dubbo-sample-consumer

其中后面兩個模塊都是spring boot的應(yīng)用。

修改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>
  

定義服務(wù)接口

在spring-boot-dubbo-sample-api模塊中沪斟，定義接口

public interface IHelloService {

    String sayHello();
}

實現(xiàn)服務(wù)

在spring-boot-dubbo-sample-provider中，實現(xiàn)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服務(wù)發(fā)布

• 在服務(wù)實現(xiàn)類中添加@Service注解

  @Service
  public class HelloServiceImpl implements IHelloService{
  
      @Override
      public String sayHello() {
          return "Hello GuPao";
      }
  }
  

• 配置dubbo提供方信息

  # dubbo 服務(wù)掃描基礎(chǔ)包路徑
  dubbo.scan.base-packages=com.gupaoedu.dubbo.springclouddubbosampleprovider
  
  dubbo.protocol.id=dubbo
  # Dubbo 服務(wù)暴露的協(xié)議配置暇矫，其中子屬性 name 為協(xié)議名稱主之，port 為協(xié)議端口（ -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 服務(wù)實現(xiàn)類的掃描基準(zhǔn)包
  • dubbo.protocol : Dubbo 服務(wù)暴露的協(xié)議配置李根，其中子屬性 name 為協(xié)議名稱槽奕，port 為協(xié)議端口（ -1 表示自增端口，從 20880 開始）
  • dubbo.registry : Dubbo 服務(wù)注冊中心配置房轿，其中子屬性 address 的值 "spring-cloud://localhost"粤攒，說明掛載到 Spring Cloud 注冊中心
  • spring.cloud.nacos.discovery : Nacos 服務(wù)發(fā)現(xiàn)與注冊配置，其中子屬性 server-addr 指定 Nacos 服務(wù)器主機和端口

版本規(guī)范

項目的版本號格式為 x.x.x 的形式冀续，其中 x 的數(shù)值類型為數(shù)字琼讽，從 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

構(gòu)建服務(wù)消費者

• 添加jar包依賴

  <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
  

  除應(yīng)用名稱 spring.application.name 存在差異外粒蜈，spring-cloud-dubbo-client-sample 新增了屬性 dubbo.cloud.subscribed-services 的設(shè)置顺献。并且該值為服務(wù)提供方應(yīng)用 "spring-cloud-dubbo-sample-provider"。

  它的主要作用是服務(wù)消費方訂閱服務(wù)提供方的應(yīng)用名稱的列表枯怖，若需訂閱多應(yīng)用注整，使用 "," 分割。 不推薦使用默認(rèn)值為 "*"，它將訂閱所有應(yīng)用。

• 編寫測試代碼

  @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可以同時配置多個注冊中心的地址驹暑，然后針對于不同類型的服務(wù)注冊到不同的注冊中心上玫恳。

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

一個服務(wù)部署到多個注冊中心

基于spring cloud的配置方式

• 添加jar包依賴

  <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 關(guān)閉spring cloud的自動注冊
  • spring.cloud.nacos.discovery.watch.enabled/spring.cloud.nacos.discovery.register-enabled關(guān)閉nacos的服務(wù)注冊和監(jiān)聽

  這么做的目的是，規(guī)避spring cloud本身的服務(wù)注冊發(fā)現(xiàn)機制优俘，走dubbo本身的服務(wù)注冊與發(fā)現(xiàn)

• 修改服務(wù)配置

  @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
  

• 添加jar包依賴

  <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的使用方式中，對于配置多個服務(wù)注冊中心不是很友好而且還有一些潛在的問題兼吓， 畢竟dubbo和spring cloud兩個本質(zhì)上是屬于完全不同的生態(tài)耦合在一起臂港，必然會導(dǎo)致一些兼容問題。比如剛剛我們?nèi)ヅ渲玫倪@些多注冊中心的支持视搏，它需要去關(guān)閉spring cloud本身的服務(wù)自動注冊和發(fā)現(xiàn)的支持审孽，本質(zhì)上就是在兩個生態(tài)中選擇其中一個生態(tài)作為主要方式來使用。

所以浑娜，如果是在spring cloud的生態(tài)中佑力，可以盡量減少對于dubbo本身靈活性的使用，擁抱spring cloud的標(biāo)準(zhǔn)生態(tài)筋遭，當(dāng)然如果希望以dubbo作為獨立的生態(tài)來使用打颤，大家可以采用spring boot+Dubbo來集成，

這里同樣也給大家快速構(gòu)建一下漓滔。

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

• 自動裝配（注解驅(qū)動响驴、自動裝配）
• production-ready（安全機制透且、健康檢測、外部化配置）

創(chuàng)建項目結(jié)構(gòu)

創(chuàng)建基礎(chǔ)的項目結(jié)構(gòu)

• 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]

添加jar包依賴

從2.7開始豁鲤，dubbo的版本和dubbo-spring-boot的版本是保持一致的秽誊，所以大家不用再去擔(dān)心版本的問題。

<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>

添加服務(wù)以及發(fā)布

@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

編寫服務(wù)引用代碼

• 添加jar包依賴

  <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
  

不同服務(wù)注冊到不同的注冊中心

從上面的配置可以發(fā)現(xiàn)琳骡，我們開可以針對不同的服務(wù)配置到不同的注冊中心锅论，這個就不再浪費時間去演示了。

多個注冊中心的集群

如果一個服務(wù)消費者引用了多個注冊中心楣号，那么這個時候服務(wù)消費者首先要做的就是先針對注冊中心的負載均衡最易，然后得到一個目標(biāo)注冊中心之后怒坯，再從目標(biāo)注冊中心上獲得服務(wù)提供者的地址列表再進行集群訪問，實現(xiàn)原理如下圖所示

image-20200805174638634

當(dāng)然耘纱，有三種方式來指定注冊中心的負載均衡配置

• 指定優(yōu)先級

  <!-- 來自 preferred=“true” 注冊中心的地址將被優(yōu)先選擇敬肚，只有該中心無可用地址時才 Fallback 到其他注冊中心 -->
  <dubbo:registry address="zookeeper://${zookeeper.address1}" preferred="true" />
  

• 同zone優(yōu)先

  <!-- 選址時會和流量中的 zone key 做匹配，流量會優(yōu)先派發(fā)到相同 zone 的地址 -->
  <dubbo:registry address="zookeeper://${zookeeper.address1}" zone="beijing" />
  

• 權(quán)重輪詢

  <!-- 來自北京和上海集群的地址束析，將以 10:1 的比例來分配流量 -->
  <dubbo:registry id="beijing" address="zookeeper://${zookeeper.address1}" weight=”100“ />
  <dubbo:registry id="shanghai" address="zookeeper://${zookeeper.address2}" weight=”10“ />
  

接口多版本支持

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

因此對于這種情況蝶锋，dubbo提供了接口版本的支持。

具體的配置方式

• 服務(wù)端針對同一個接口提供不同版本的實現(xiàn)

• 并在dubboservice注解中配置版本的聲明

  @DubboService(registry = {"registry1","registry2"},version = "1.0")
  

• 服務(wù)消費端指定消費版本號

  @DubboReference(registry = {"registry1","registry2"},version = "2.0")
  ISayHelloService sayHelloService;
  

多協(xié)議的支持

當(dāng)公司原本采用其他的rpc框架什往，這個時候如果想遷移到dubbo這個框架上來扳缕，那么Dubbo提供的多協(xié)議支持就能夠提供幾乎零成本的遷移。

對于一個服務(wù)别威，可以同時發(fā)布多種不同協(xié)議的接口躯舔，也可以針對不同的接口發(fā)布不同的協(xié)議類型。并且從2.7開始省古，dubbo對于一些主流的協(xié)議做了支持粥庄，目前已經(jīng)支持的協(xié)議有

dubbo協(xié)議、hessian協(xié)議豺妓、http協(xié)議惜互、thrift、rmi琳拭、webservice训堆、grpc、rest等白嘁。初次之外坑鱼，dubbo還提供了非常靈活的可擴展性機制，對于有定制化需求或者目前正在使用的協(xié)議权薯，dubbo不支持的公司姑躲，是可以自己去進行擴展。

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

JAX-RS協(xié)議說明

Dubbo中的REST（表述性資源轉(zhuǎn)移）支持屎开，是基于JAX-RS2.0(Java API for RESTful Web Services)來實現(xiàn)的阐枣。

REST是一種架構(gòu)風(fēng)格，簡單來說就是對于api接口的約束，基于URL定位資源蔼两，使用http動詞（GET/POST/DELETE）來描述操作

REST很早就提出來了甩鳄，在早期開發(fā)人員為了實現(xiàn)REST，會使用各種工具來實現(xiàn)额划，比如Servlets就經(jīng)常用來開發(fā)RESTful的程序妙啃。隨著REST被越來越多的開發(fā)人員采用，所以JCP(Java community process)提出了JAX-RS規(guī)范俊戳，并且提供了一種新的基于注解的方式來開發(fā)RESTful服務(wù)揖赴。有了這樣的一個規(guī)范，使得開發(fā)人員不需要關(guān)心通訊層的東西抑胎，只需要關(guān)注資源以以及數(shù)據(jù)對象燥滑。

JAX-RS規(guī)范的實現(xiàn)有：Apache CXF、Jersey(由Sun公司提供的JAX-RS的參考實現(xiàn))阿逃、RESTEasy(jboss實現(xiàn))等铭拧。

而Dubbo里面實現(xiàn)的REST就是基于Jboss提供的RESTEasy框架來實現(xiàn)的

SpringMVC中的RESTful實現(xiàn)我們用得比較多，它也是JAX-RS規(guī)范的一種實現(xiàn)

添加REST支持

• 添加jar包依賴

  <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();
  
  }