Spring Cloud與Dubbo的完美融合之手「Spring Cloud Alibaba」


圖片


很早之前,在剛開始搞Spring Cloud基礎教程的時候,寫過這樣一篇文章:《微服務架構的基礎框架選擇:Spring Cloud仍是Dubbo?》,可能很多讀者也都看過。以後也就一直有關於這兩個框架怎麼選的問題出來,其實文中我有明確的提過,Spring Cloud與Dubbo的比較自己是不公平的,主要前者是一套較爲完整的架構方案,而Dubbo只是服務治理與RPC實現方案。git

因爲Dubbo在國內有着很是大的用戶羣體,可是其周邊設施與組件相對來講並不那麼完善。不少開發者用戶又很但願享受Spring Cloud的生態,所以也會有一些Spring Cloud與Dubbo一塊兒使用的案例與方法出現,可是一直以來大部分Spring Cloud整合Dubbo的使用方案都比較彆扭。這主要是因爲Dubbod的註冊中心採用了ZooKeeper,而開始時Spring Cloud體系中的註冊中心並不支持ZooKeeper,因此不少方案是存在兩個不一樣註冊中心的,以後即便Spring Cloud支持了ZooKeeper,可是因爲服務信息的粒度與存儲也不一致。因此,長期以來,在服務治理層面上,這二者一直都一套完美的融合方案。github

直到Spring Cloud Alibaba的出現,才得以解決這樣的問題。在以前的教程中,咱們已經介紹過使用Spring Cloud Alibaba中的Nacos來做爲服務註冊中心,而且在此之下能夠如傳統的Spring Cloud應用同樣地使用Ribbon或Feign來實現服務消費。這篇,咱們就來繼續說說Spring Cloud Alibaba中特別支持的RPC方案:Dubbo。web

入門案例

咱們先經過一個簡單的例子,來直觀地感覺Nacos服務註冊中心之下,利用Dubbo來實現服務提供方與服務消費方。這裏省略Nacos的安裝與使用,若是對Nacos還不瞭解,能夠查看本系列的使用Nacos實現服務註冊與發現,下面就直接進入Dubbo的使用步驟。spring

構建服務接口

建立一個簡單的Java項目,並在下面定義一個抽象接口,好比:apache

 
 
  1. public interface HelloService {api


  2.    String hello(String name);架構


  3. }app

構建服務接口提供方

第一步:建立一個Spring Boot項目,在 pom.xml中引入第一步中構建的API包以及Spring Cloud Alibaba對Nacos和Dubbo的依賴,好比:框架

 
 
  1.    <dependencies>curl

  2.        <!-- 第一步中構建的API包 -->

  3.        <dependency>

  4.            <groupId>com.didispace</groupId>

  5.            <artifactId>alibaba-dubbo-api</artifactId>

  6.            <version>0.0.1-SNAPSHOT</version>

  7.        </dependency>

  8.        <dependency>

  9.            <groupId>org.springframework.boot</groupId>

  10.            <artifactId>spring-boot-starter-actuator</artifactId>

  11.        </dependency>

  12.        <dependency>

  13.            <groupId>org.springframework.boot</groupId>

  14.            <artifactId>spring-boot-starter-web</artifactId>

  15.        </dependency>

  16.        <dependency>        

  17.            <!--<groupId>com.alibaba.cloud</groupId>-->

  18.            <groupId>org.springframework.cloud</groupId>

  19.            <artifactId>spring-cloud-starter-dubbo</artifactId>

  20.        </dependency>

  21.        <dependency>

  22.            <groupId>org.springframework.cloud</groupId>

  23.            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>

  24.        </dependency>


  25.        //...

  26.    </dependencies>

這裏須要注意兩點:

  1. 必須包含 spring-boot-starter-actuator包,否則啓動會報錯。

  2. spring-cloud-starter-dubbo包須要注意 groupId,根據具體使用的spring cloud alibaba版本依賴來肯定。

  • 項目孵化期間,使用的 groupId爲: org.springframework.cloud

  • 項目孵化以後,使用的 groupId修改成了 com.alibaba.cloud,因此用戶須要注意是否使用正確。避免加載不到對應JAR包的問題。

第二步:實現Dubbo接口

 
 
  1. @Service

  2. public class HelloServiceImpl implements HelloService {


  3.    @Override

  4.    public String hello(String name) {

  5.        return "hello " + name;

  6.    }


  7. }

注意:這裏的 @Service註解不是Spring的,而是 org.apache.dubbo.config.annotation.Service註解。

第三步:配置Dubbo服務相關的信息,好比:

 
 
  1. spring.application.name=alibaba-dubbo-server

  2. server.port=8001


  3. spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848


  4. # 指定 Dubbo 服務實現類的掃描基準包

  5. dubbo.scan.base-packages=com.didispace.alibaba.dubbo.server

  6. dubbo.protocol.name=dubbo

  7. dubbo.protocol.port=-1

  8. dubbo.registry.address=spring-cloud://localhost

配置說明以下:

  • dubbo.scan.base-packages: 指定 Dubbo 服務實現類的掃描基準包

  • dubbo.protocol: Dubbo 服務暴露的協議配置,其中子屬性 name 爲協議名稱,port 爲協議端口( -1 表示自增端口,從 20880 開始)

  • dubbo.registry: Dubbo 服務註冊中心配置,其中子屬性 address 的值 "spring-cloud://localhost",說明掛載到 Spring Cloud 註冊中心

注意:若是使用Spring Boot 2.1及更高版本時候,須要增長配置 spring.main.allow-bean-definition-overriding=true

第四步:建立應用主類,好比:

 
 
  1. @EnableDiscoveryClient

  2. @SpringBootApplication

  3. public class DubboServerApplication {


  4.    public static void main(String[] args) {

  5.        SpringApplication.run(DubboServerApplication.class, args);

  6.    }


  7. }

構建服務接口消費方

第一步:建立一個Spring Boot項目,在 pom.xml中引入第一步中構建的API包以及Spring Cloud Alibaba對Nacos和Dubbo的依賴,具體內容與服務提供方一致:

 
 
  1.    <dependencies>

  2.        <!-- 第一步中構建的API包 -->

  3.        <dependency>

  4.            <groupId>com.didispace</groupId>

  5.            <artifactId>alibaba-dubbo-api</artifactId>

  6.            <version>0.0.1-SNAPSHOT</version>

  7.        </dependency>

  8.        <dependency>

  9.            <groupId>org.springframework.boot</groupId>

  10.            <artifactId>spring-boot-starter-actuator</artifactId>

  11.        </dependency>

  12.        <dependency>

  13.            <groupId>org.springframework.boot</groupId>

  14.            <artifactId>spring-boot-starter-web</artifactId>

  15.        </dependency>

  16.        <dependency>        

  17.            <!--<groupId>com.alibaba.cloud</groupId>-->

  18.            <groupId>org.springframework.cloud</groupId>

  19.            <artifactId>spring-cloud-starter-dubbo</artifactId>

  20.        </dependency>

  21.        <dependency>

  22.            <groupId>org.springframework.cloud</groupId>

  23.            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>

  24.        </dependency>


  25.        //...

  26.    </dependencies>

第二步:配置Dubbo服務相關的信息,好比:

 
 
  1. spring.application.name=alibaba-dubbo-client

  2. server.port=8002


  3. spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848


  4. dubbo.protocol.name=dubbo

  5. dubbo.protocol.port=-1

  6. dubbo.registry.address=spring-cloud://localhost

  7. dubbo.cloud.subscribed-services=alibaba-dubbo-server

注意:

  1. 這裏多增長了 dubbo.cloud.subscribed-services參數,表示要訂閱服務的服務名,這裏配置的 alibaba-dubbo-server對應的就是上一節服務提供方的 spring.application.name的值,也就是服務提供方的應用名。

  2. 若是使用Spring Boot 2.1及更高版本時候,須要增長配置 spring.main.allow-bean-definition-overriding=true

第三步:建立應用主類,並實現一個接口,在這個接口中調用Dubbo服務,好比:

 
 
  1. @EnableDiscoveryClient

  2. @SpringBootApplication

  3. public class DubboClientApplication {


  4.    public static void main(String[] args) {

  5.        SpringApplication.run(DubboClientApplication.class, args);

  6.    }


  7.    @Slf4j

  8.    @RestController

  9.    static class TestController {


  10.        @Reference

  11.        HelloService helloService;


  12.        @GetMapping("/test")

  13.        public String test() {

  14.            return helloService.hello("didispace.com");

  15.        }

  16.    }


  17. }

注意:這裏的 @Reference註解是 org.apache.dubbo.config.annotation.Reference

測試驗證

完成了上面的全部開發以後,咱們能夠將Nacos、服務提供者、服務消費者依次啓動起來。在完成啓動以後,咱們能夠在Nacos控制檯的服務列表中看到上面定義的兩個服務,好比:

圖片

接下來,咱們就能夠經過調用服務消費者中定義的 /test接口來觸發dubbo服務的消費了。若是一切順暢,應該能夠獲得以下結果:

$ curl localhost:8002/testhello didispace.com

小結

經過上面的例子,若是你曾經同時玩過Spring Cloud和Dubbo,必定會深有感觸。你不用再同時顧慮Eureka和Zookeeper的配置,也不一樣同時關注這兩個中間件的健康,只須要關注和維護好Nacos一個便可。而對於Dubbo的配置和使用來講,配置仍是至關簡單的,而代碼編寫上與以往的Dubbo沒什麼大的不一樣。在Spring Cloud Alibaba的整合之下,Dubbo用戶既能夠享受到本來RPC帶來性能優點,又能夠更好的享受Spring Cloud的各類福利;而對於Spring Cloud用戶來講,在服務治理層面,又對了一個不錯的可選項。能夠說這塊的整合是真正的讓這兩大用戶羣體獲得了很好的融合,起到了互相成就的做用。更多關於Spring Cloud與Spring Cloud Alibaba教程內容可點擊查看。

參考資料:官方文檔

代碼示例

本文介紹內容的客戶端代碼,示例讀者能夠經過查看下面倉庫中的 alibaba-dubbo-apialibaba-dubbo-serveralibaba-dubbo-client項目:

  • Github:https://github.com/dyc87112/SpringCloud-Learning/

  • Gitee:https://gitee.com/didispace/SpringCloud-Learning/

相關文章
相關標籤/搜索