很早以前,在剛開始搞Spring Cloud基礎教程的時候,寫過這樣一篇文章: 《微服務架構的基礎架構選擇:Spring Cloud還是Dubbo?》
,可能不少讀者也都看過。之後也就一直有關于這兩個架構怎麼選的問題出來,其實文中我有明确的提過,Spring Cloud與Dubbo的比較本身是不公平的,主要前者是一套較為完整的架構方案,而Dubbo隻是服務治理與RPC實作方案。
由于Dubbo在國内有着非常大的使用者群體,但是其周邊設施與元件相對來說并不那麼完善。很多開發者使用者又很希望享受Spring Cloud的生态,是以也會有一些Spring Cloud與Dubbo一起使用的案例與方法出現,但是一直以來大部分Spring Cloud整合Dubbo的使用方案都比較别扭。這主要是由于Dubbod的注冊中心采用了ZooKeeper,而開始時Spring Cloud體系中的注冊中心并不支援ZooKeeper,是以很多方案是存在兩個不同注冊中心的,之後即使Spring Cloud支援了ZooKeeper,但是由于服務資訊的粒度與存儲也不一緻。是以,長期以來,在服務治理層面上,這兩者一直都一套完美的融合方案。
直到Spring Cloud Alibaba的出現,才得以解決這樣的問題。在之前的教程中,我們已經介紹過使用Spring Cloud Alibaba中的Nacos來作為服務注冊中心,并且在此之下可以如傳統的Spring Cloud應用一樣地使用Ribbon或Feign來實作服務消費。這篇,我們就來繼續說說Spring Cloud Alibaba下額外支援的RPC方案:Dubbo。
https://blog.didispace.com/spring-cloud-alibaba-dubbo-1/#%E5%85%A5%E9%97%A8%E6%A1%88%E4%BE%8B 入門案例
我們先通過一個簡單的例子,來直覺地感受Nacos服務注冊中心之下,利用Dubbo來實作服務提供方與服務消費方。這裡省略Nacos的安裝與使用,如果對Nacos還不了解,可以檢視本系列的
使用Nacos實作服務注冊與發現,下面就直接進入Dubbo的使用步驟。
https://blog.didispace.com/spring-cloud-alibaba-dubbo-1/#%E6%9E%84%E5%BB%BA%E6%9C%8D%E5%8A%A1%E6%8E%A5%E5%8F%A3 建構服務接口
建立一個簡單的Java項目,并在下面定義一個抽象接口,比如:
public interface HelloService {
String hello(String name);
}
建構服務接口提供方
第一步:建立一個Spring Boot項目,在
pom.xml
中引入第一步中建構的API包以及Spring Cloud Alibaba對Nacos和Dubbo的依賴,比如:
<dependencies>
<!-- 第一步中建構的API包 -->
<dependency>
<groupId>com.didispace</groupId>
<artifactId>alibaba-dubbo-api</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<!--<groupId>com.alibaba.cloud</groupId>-->
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
//...
</dependencies>
這裡需要注意兩點:
- 必須包含
包,不然啟動會報錯。spring-boot-starter-actuator
-
包需要注意spring-cloud-starter-dubbo
,根據具體使用的spring cloud alibaba版本依賴來确定。groupId
-
- 項目孵化期間,使用的
為:groupId
;org.springframework.cloud
- 項目孵化之後,使用的
修改為了groupId
,是以使用者需要注意是否使用正确。避免加載不到對應JAR包的問題。com.alibaba.cloud
- 項目孵化期間,使用的
第二步:實作Dubbo接口
@Service
public class HelloServiceImpl implements HelloService {
@Override
public String hello(String name) {
return "hello " + name;
}
}
注意:這裡的
@Service
注解不是Spring的,而是
org.apache.dubbo.config.annotation.Service
注解。
第三步:配置Dubbo服務相關的資訊,比如:
spring.application.name=alibaba-dubbo-server
server.port=8001
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
# 指定 Dubbo 服務實作類的掃描基準包
dubbo.scan.base-packages=com.didispace.alibaba.dubbo.server
dubbo.protocol.name=dubbo
dubbo.protocol.port=-1
dubbo.registry.address=spring-cloud://localhost
配置說明如下:
-
: 指定 Dubbo 服務實作類的掃描基準包dubbo.scan.base-packages
-
: Dubbo 服務暴露的協定配置,其中子屬性 name 為協定名稱,port 為協定端口( -1 表示自增端口,從 20880 開始)dubbo.protocol
-
: Dubbo 服務注冊中心配置,其中子屬性 address 的值 “spring-cloud://localhost”,說明挂載到 Spring Cloud 注冊中心dubbo.registry
注意:如果使用Spring Boot 2.1及更高版本時候,需要增加配置
spring.main.allow-bean-definition-overriding=true
第四步:建立應用主類,比如:
@EnableDiscoveryClient
@SpringBootApplication
public class DubboServerApplication {
public static void main(String[] args) {
SpringApplication.run(DubboServerApplication.class, args);
}
}
建構服務接口消費方
pom.xml
中引入第一步中建構的API包以及Spring Cloud Alibaba對Nacos和Dubbo的依賴,具體内容與服務提供方一緻:
<dependencies>
<!-- 第一步中建構的API包 -->
<dependency>
<groupId>com.didispace</groupId>
<artifactId>alibaba-dubbo-api</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<!--<groupId>com.alibaba.cloud</groupId>-->
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
//...
</dependencies>
第二步:配置Dubbo服務相關的資訊,比如:
spring.application.name=alibaba-dubbo-client
server.port=8002
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
dubbo.protocol.name=dubbo
dubbo.protocol.port=-1
dubbo.registry.address=spring-cloud://localhost
dubbo.cloud.subscribed-services=alibaba-dubbo-server
注意:
- 這裡多增加了
參數,表示要訂閱服務的服務名,這裡配置的dubbo.cloud.subscribed-services
對應的就是上一節服務提供方的alibaba-dubbo-server
的值,也就是服務提供方的應用名。spring.application.name
- 如果使用Spring Boot 2.1及更高版本時候,需要增加配置
。spring.main.allow-bean-definition-overriding=true
第三步:建立應用主類,并實作一個接口,在這個接口中調用Dubbo服務,比如:
@EnableDiscoveryClient
@SpringBootApplication
public class DubboClientApplication {
public static void main(String[] args) {
SpringApplication.run(DubboClientApplication.class, args);
}
@Slf4j
@RestController
static class TestController {
@Reference
HelloService helloService;
@GetMapping("/test")
public String test() {
return helloService.hello("didispace.com");
}
}
}
@Reference
注解是
org.apache.dubbo.config.annotation.Reference
https://blog.didispace.com/spring-cloud-alibaba-dubbo-1/#%E6%B5%8B%E8%AF%95%E9%AA%8C%E8%AF%81 測試驗證
完成了上面的所有開發之後,我們可以将Nacos、服務提供者、服務消費者依次啟動起來。在完成啟動之後,我們可以在Nacos控制台的服務清單中看到上面定義的兩個服務,比如:
接下來,我們就可以通過調用服務消費者中定義的
/test
接口來觸發dubbo服務的消費了。如果一切順暢,應該可以得到如下結果:
$ curl localhost:8002/test
hello didispace.com
小結
通過上面的例子,如果你曾經同時玩過Spring Cloud和Dubbo,一定會深有感觸。你不用再同時顧慮Eureka和Zookeeper的配置,也不同同時關注這兩個中間件的健康,隻需要關注和維護好Nacos一個即可。而對于Dubbo的配置和使用來說,配置還是相當簡單的,而代碼編寫上與以往的Dubbo沒什麼大的不同。在Spring Cloud Alibaba的整合之下,Dubbo使用者既可以享受到原本RPC帶來性能優勢,又可以更好的享受Spring Cloud的各種福利;而對于Spring Cloud使用者來說,在服務治理層面,又對了一個不錯的可選項。可以說這塊的整合是真正的讓這兩大使用者群體得到了很好的融合,起到了互相成就的作用。
參考資料:
官方文檔https://blog.didispace.com/spring-cloud-alibaba-dubbo-1/#%E4%BB%A3%E7%A0%81%E7%A4%BA%E4%BE%8B 代碼示例
本文介紹内容的用戶端代碼,示例讀者可以通過檢視下面倉庫中的
alibaba-dubbo-api
、
alibaba-dubbo-server
alibaba-dubbo-client
項目:
- Github: https://github.com/dyc87112/SpringCloud-Learning/
- Gitee: https://gitee.com/didispace/SpringCloud-Learning/
如果您對這些感興趣,歡迎star、follow、收藏、轉發給予支援!