文章詳情頁

Spring Boot 整合 Apache Dubbo的示例代碼

瀏覽：8日期：2023-07-04 15:58:14

Apache Dubbo是一款高性能、輕量級的開源 Java RPC 框架，它提供了三大核心能力：面向接口的遠程方法調(diào)用，智能容錯和負載均衡，以及服務自動注冊和發(fā)現(xiàn)。

注意，是 Apache Dubbo，不再是 Alibaba Dubbo。簡單來說就是 Alibaba 將 Dubbo 移交給 Apache 開源社區(qū)進行維護。參見 dubbo-spring-boot-project

Spring Boot 系列：整合 Alibaba Dubbo

一、本文示例說明

1.1 框架版本Dubbo 版本

<dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.5</version></dependency>

Spring Boot 版本

<parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.1.1.RELEASE</version> <relativePath/></parent>

1.2 模塊關系

根工程 order：管理工程信息；子工程 order-api：定義RPC服務的接口、參數(shù)以及響應結(jié)果的結(jié)果集；子工程 order-provider：RPC服務的提供端；子工程 order-consumer：RPC服務的消費端，實際開發(fā)過程中實際情況是其它服務的調(diào)用該訂單RPC服務二、根工程

2.1 創(chuàng)建項目 order

我這里為了和之前老版本的alibaba的dubbo項目區(qū)分，文件名取為apache-dubbo-demo，maven 項目名稱為order。

該項目主要作用是定義工程信息、管理整個項目依賴版本等等，所以src目錄不需要。

2.2 pom.xml

根工程中使用了<dependencyManagement>和<dependencies>進行依賴管理。

<dependencyManagement>：聲明全局依賴，當子項目指定引用才會繼承依賴；<dependencies>：聲明全局依賴，子項目直接自動繼承依賴。

<?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>  <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.1.RELEASE</version><relativePath/> </parent>  <groupId>cn.van.order</groupId> <artifactId>order</artifactId> <version>1.0.0-SNAPSHOT</version> <name>${project.artifactId}</name> <description>Apache Dubbo 根項目</description>  <properties><java.version>1.8</java.version><dubbo.version>2.7.5</dubbo.version><zookeeper.version>3.4.14</zookeeper.version> </properties>  <modules><module>order-api</module><module>order-provider</module><module>order-consumer</module> </modules>  <dependencyManagement><dependencies>  <dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>${dubbo.version}</version> </dependency>  <dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-dependencies-zookeeper</artifactId><version>${dubbo.version}</version><type>pom</type><exclusions> <exclusion><artifactId>slf4j-log4j12</artifactId><groupId>org.slf4j</groupId> </exclusion></exclusions> </dependency></dependencies> </dependencyManagement>  <dependencies><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId></dependency><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> <exclusions><exclusion> <groupId>org.junit.vintage</groupId> <artifactId>junit-vintage-engine</artifactId></exclusion> </exclusions></dependency> </dependencies>  <build><plugins> <plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId> </plugin></plugins> </build></project>三、order-api

3.1 項目依賴

無需更多依賴，所以很簡單。

3.2 封裝 RPC 結(jié)果集先封裝一個返回碼枚舉類ResultCodeEnum.java

public enum ResultCodeEnum { /*** 通用部分 100 - 599***/ // 成功請求 SUCCESS(200, 'successful'),/*** 這里可以根據(jù)不同模塊用不同的區(qū)級分開錯誤碼，例如: ***/ // 1000～1999 區(qū)間表示用戶模塊錯誤 // 2000～2999 區(qū)間表示訂單模塊錯誤 // 3000～3999 區(qū)間表示商品模塊錯誤 // 。。。 ORDER_NOT_FOUND(2000, 'order not found'), ; /** * 響應狀態(tài)碼 */ private Integer code; /** * 響應信息 */ private String message; ResultCodeEnum(Integer code, String msg) {this.code = code;this.message = msg; } public Integer getCode() {return code; } public String getMessage() {return message; } public void setMessage(String message) {this.message = message; }}

先封裝一個RPC 響應結(jié)果集RpcResult.java

public class RpcResult <T> implements Serializable { /** * 是否響應成功 */ private Boolean success; /** * 響應狀態(tài)碼 */ private Integer code; /** * 響應數(shù)據(jù) */ private T data; /** * 錯誤信息 */ private String message; // 構(gòu)造器開始 /** * 無參構(gòu)造器(構(gòu)造器私有，外部不可以直接創(chuàng)建) */ private RpcResult() {this.code = 200;this.success = true; } /** * 有參構(gòu)造器 * @param obj */ private RpcResult(T obj) {this.code = 200;this.data = obj;this.success = true; } /** * 有參構(gòu)造器 * @param resultCode */ private RpcResult(ResultCodeEnum resultCode) {this.success = false;this.code = resultCode.getCode();this.message = resultCode.getMessage(); } // 構(gòu)造器結(jié)束 /** * 通用返回成功（沒有返回結(jié)果） * @param <T> * @return */ public static<T> RpcResult<T> success(){return new RpcResult(); } /** * 返回成功（有返回結(jié)果） * @param data * @param <T> * @return */ public static<T> RpcResult<T> success(T data){return new RpcResult<T>(data); } /** * 通用返回失敗 * @param resultCode * @param <T> * @return */ public static<T> RpcResult<T> failure(ResultCodeEnum resultCode){return new RpcResult<T>(resultCode); } public Boolean getSuccess() {return success; } public void setSuccess(Boolean success) {this.success = success; } public Integer getCode() {return code; } public void setCode(Integer code) {this.code = code; } public T getData() {return data; } public void setData(T data) {this.data = data; } public String getMessage() {return message; } public void setMessage(String message) {this.message = message; } @Override public String toString() {return 'RpcResult{' +'success=' + success +', code=' + code +', data=' + data +', message=’' + message + ’’’ +’}’; }}

3.3 編寫一個 RPC 接口

public interface OrderDubboService { RpcResult<OrderDomain> getOrder();}

實體OrderDomain.java挺簡單的，詳見 Github 倉庫。

四、order-provider

此子項目是一個服務類項目，也就是將接口服務注冊到zookeeper注冊中心供消費端調(diào)取使用。

4.1 項目依賴

4.2 服務實現(xiàn)接口

@Servicepublic class OrderDubboServiceImpl implements OrderDubboService {@Override public RpcResult<OrderDomain> getOrder() {return RpcResult.success(new OrderDomain(1, 10086, LocalDateTime.now())); }}

注意：@Service 是 dubbo 包下面的注解不是 Spring 里面的注解。

4.3 項目配置

dubbo 的配置直接用 dubbo，不再以 Spring 開頭; base-packages：指定接口實現(xiàn)所在路徑。

server: # 服務端口 port: 7777spring: application: name: order-provider# dubbo 相關配置(dubbo 的配置不再以 Spring 開頭)dubbo: application: # 應用名稱 name: order-provider scan: # 接口實現(xiàn)者（服務實現(xiàn)）包 base-packages: cn.van.order.service.impl # 注冊中心信息 registry: address: zookeeper://127.0.0.1:2181 protocol: # 協(xié)議名稱 name: dubbo # 協(xié)議端口 port: 20880五、order-consumer

此子項目就是一個消費項目，比如商品模塊、財務模塊等等。

5.1 項目依賴

5.2 測試接口

模擬一個接口獲取訂單詳情。

@RestController@RequestMapping('/order')public class OrderConsumerController { @Reference OrderDubboService orderDubboService; @GetMapping('getOrder') public RpcResult getOrder() {return orderDubboService.getOrder(); }}

注意：@Reference引入的是 Dubbo 接口，所以是 Dubbo 的注解。

5.3 配置文件

server: port: 7000spring: application: name: order-consumer# dubbo 相關配置dubbo: application: name: order-consumer registry: address: zookeeper://127.0.0.1:2181六、測試

一切就緒，如果在order-consumer 的測試接口能成功請求到數(shù)據(jù)，則證明 Dubbo 服務搭建成功。

6.1 啟動 zookeeper

我們選用zookeeper作為注冊中心，因此啟動項目之前需要先啟動它。

6.2 dubbo-admin

dubbo-admin 便于觀察 order-provider 是否成功將接口注冊，具體安裝步驟詳見apache/dubbo-admin

默認端口：8080。

6.3 啟動 dubbo-provider

成功啟動后可以在dubbo-admin：已經(jīng)成功將接口 OrderService 注冊到 zookeeper 上如下：

Spring Boot 整合 Apache Dubbo的示例代碼

成功將借口注冊到注冊中心，說明dubbo-provider 注冊成功。

6.4 啟動 order-cosumer

啟動消費者項目，在瀏覽器請求消費接口：http://localhost:7000/order/getOrder，成功返回數(shù)據(jù)如下：

{ 'success':true, 'code':200, 'data':{'id':1,'orderNum':10086,'gmtCreate':'2020-05-06T11:59:45.535' }, 'message':null}

成功請求到 order-provider 提供的數(shù)據(jù)，說明 Dubbo 搭建成功！

七、總結(jié)

以上的完整代碼我已上傳到 Github，需要的可以自取測試，歡迎star！

Spring

上一條：Spring緩存注解@Cacheable @CacheEvit @CachePut使用介紹下一條：spring boot 如何指定profile啟動

相關文章：

1. ASP常用日期格式化函數(shù) FormatDate()2. 利用FastReport傳遞圖片參數(shù)在報表上展示簽名信息的實現(xiàn)方法3. ASP中if語句、select 、while循環(huán)的使用方法4. HTML中的XML數(shù)據(jù)島記錄編輯與添加5. ASP.NET Core按用戶等級授權(quán)的方法6. 詳解瀏覽器的緩存機制7. phpstudy apache開啟ssi使用詳解8. ASP新手必備的基礎知識9. 推薦一個好看Table表格的css樣式代碼詳解10. .NET 中配置從xml轉(zhuǎn)向json方法示例詳解

排行榜

					
					Python 圖片處理庫exifread詳解
PHP 工程師面試的四個環(huán)節(jié)
詳解瀏覽器的緩存機制
Android Studio中一套代碼多渠道打包的實現(xiàn)方法
springboot項目整合mybatis并配置mybatis中間件的實現(xiàn)
Java實現(xiàn)簡單LRU緩存機制的方法
JS實現(xiàn)炫酷輪播圖
Lore Article.PHP SQL注入漏洞
JavaScript forEach中return失效問題解決方案
Python Opencv中用compareHist函數(shù)進行直方圖比較對比圖片
使用python編寫一個語音朗讀鬧鐘功能的示例代碼
				