SpringBoot整合Dubbo框架,實現(xiàn)RPC服務(wù)遠程調(diào)用
一、Dubbo框架簡介
1、框架依賴
圖例說明：
1)圖中小方塊 Protocol, Cluster, Proxy, Service, Container, Registry, Monitor 代表層或模塊，藍色的表示與業(yè)務(wù)有交互，綠色的表示只對 Dubbo 內(nèi)部交互。
2)圖中背景方塊 Consumer, Provider, Registry, Monitor 代表部署邏輯拓撲節(jié)點。
3)圖中藍色虛線為初始化時調(diào)用，紅色虛線為運行時異步調(diào)用，紅色實線為運行時同步調(diào)用。
4)圖中只包含 RPC 的層，不包含 Remoting 的層，Remoting 整體都隱含在 Protocol 中。
2、核心角色說明
1）Provider 暴露服務(wù)的服務(wù)提供方
2）Consumer 調(diào)用遠程服務(wù)的服務(wù)消費方（負載均衡）
3）Registry 服務(wù)注冊與發(fā)現(xiàn)的注冊中心（監(jiān)控、心跳、踢出、重入）
4）Monitor 服務(wù)消費者和提供者在內(nèi)存中累計調(diào)用次數(shù)和調(diào)用時間，主動定時每分鐘發(fā)送一次統(tǒng)計數(shù)據(jù)到監(jiān)控中心。
5）Container 服務(wù)運行容器：遠程調(diào)用、序列化
二、與SpringBoot2.0整合
1、核心依賴
<!-- 這里包含了Zookeeper依賴和Dubbo依賴 --> <dependency> <groupId>com.alibaba.boot</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>0.2.0</version> </dependency>
2、項目結(jié)構(gòu)說明
結(jié)構(gòu)說明
dubbo-consume：服務(wù)消費方 dubbo-provider：服務(wù)提供方 dubbo-common：公共代碼塊，Dubbo接口，實體類
3、核心配置
1）提供方配置
server: tomcat: uri-encoding: UTF-8 max-threads: 1000 min-spare-threads: 30 port: 7007 connection-timeout: 5000ms spring: application: name: block-dubbo-provider # Dubbo 配置文件 dubbo: application: name: block-dubbo-provider registry: address: 127.0.0.1:2181 protocol: zookeeper protocol: name: dubbo port: 20880 scan: base-packages: com.boot.consume
2) 消費方配置
server: tomcat: uri-encoding: UTF-8 max-threads: 1000 min-spare-threads: 30 port: 7008 connection-timeout: 5000ms spring: application: name: block-dubbo-consume # Dubbo 配置文件 dubbo: application: name: block-dubbo-consume registry: address: 127.0.0.1:2181 protocol: zookeeper
三、演示案例
1、服務(wù)遠程調(diào)用
1）提供方服務(wù)接口
- 注意這里的注解
- com.alibaba.dubbo.config.annotation.Service
@Service
@Component
public class DubboServiceImpl implements DubboService {
private static Logger LOGGER = LoggerFactory.getLogger(DubboServiceImpl.class) ;
@Override
public String getInfo(String param) {
LOGGER.info("字符參數(shù)：{}",param);
return "[Hello,Cicada]";
}
@Override
public UserEntity getUserInfo(UserEntity userEntity) {
LOGGER.info("實體類參數(shù)：{}",userEntity);
return userEntity;
}
}
2）消費方接口
- 注意這里注解
- com.alibaba.dubbo.config.annotation.Reference
- org.springframework.stereotype.Service
@Service
public class ConsumeService implements DubboService {
@Reference
private DubboService dubboService ;
@Override
public String getInfo(String param) {
return dubboService.getInfo(param);
}
@Override
public UserEntity getUserInfo(UserEntity userEntity) {
return dubboService.getUserInfo(userEntity);
}
}
2、接口超時配置
該配置可以在服務(wù)提供方配置，也可以在服務(wù)消費方配置，這里演示在提供方的配置。
注解：timeout
1）服務(wù)接口注解
@Service(timeout = 2000)
@Component
public class DubboServiceImpl implements DubboService {
}
2）消費方調(diào)用
@Override
public String timeOut(Integer time) {
return dubboService.timeOut(time);
}
3）測試接口
服務(wù)超時拋出異常
com.alibaba.dubbo.remoting.TimeoutException
3、接口多版本配置
1）服務(wù)提供方
相同接口提供兩個版本實現(xiàn)。注解：version。
版本一：
@Service(version = "1.0.0")
@Component
public class VersionOneImpl implements VersionService {
@Override
public String getVersion() {
return "{當前版本：1.0.0}";
}
}
版本二：
@Service(version = "2.0.0")
@Component
public class VersionTwoImpl implements VersionService {
@Override
public String getVersion() {
return "{當前版本：2.0.0}";
}
}
2）消費方調(diào)用
通過@Reference(version)注解，將指向不同版本的接口實現(xiàn)。
@Service
public class VersionServiceImpl implements VersionService {
@Reference(version = "1.0.0")
private VersionService versionService1 ;
@Reference(version = "2.0.0")
private VersionService versionService2 ;
@Override
public String getVersion() {
return versionService1.getVersion();
}
public String version2 (){
return versionService2.getVersion() ;
}
}
以上案例都是參照Dubbo官網(wǎng)的流程編寫的，Dubbo許多強大功能都可以參考官網(wǎng)一步步的配置。
四、源代碼地址
GitHub地址：知了一笑
https://github.com/cicadasmile/middle-ware-parent
以上就是SpringBoot整合Dubbo框架,實現(xiàn)RPC服務(wù)遠程調(diào)用的詳細內(nèi)容，更多關(guān)于SpringBoot整合Dubbo框架的資料請關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
這篇文章主要介紹了一個可以修改圖片分辨率的java工具類，文中的示例代碼講解詳細，對學習JAVA有一定的幫助，感興趣的小伙伴快來跟隨小編一起學習吧2021-12-12
在程序運行期間，隨時可能產(chǎn)生一些臨時數(shù)據(jù)，應(yīng)用程序會將這些數(shù)據(jù)保存在一些內(nèi)存單元中，每個內(nèi)存單元都用一個標識符來標識。這些內(nèi)存單元被稱為變量，定義的標識符就是變量名，內(nèi)存單元中存儲的數(shù)據(jù)就是變量的值2021-10-10
基于Java實現(xiàn)Json文件轉(zhuǎn)換為Excel文件
這篇文章主要為大家詳細介紹了如何利用Java實現(xiàn)Json文件轉(zhuǎn)換為Excel文件，文中的示例代碼講解詳細，具有一定的借鑒價值，需要的可以參考一下2022-12-12
為什么mybatis中的SqlSession一定要關(guān)閉
這篇文章主要介紹了為什么mybatis中的SqlSession一定要關(guān)閉，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-12-12
Java代碼實現(xiàn)對properties文件有序的讀寫的示例
本篇文章主要介紹了Java代碼實現(xiàn)對properties文件有序的讀寫的示例，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-11-11
SpringBoot集成Mybatis-Plus多租戶架構(gòu)實現(xiàn)
本文主要介紹了SpringBoot集成Mybatis-Plus多租戶架構(gòu)實現(xiàn)，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-09-09
這篇文章主要介紹了Spring maven filtering使用方法詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-09-09
這篇文章主要介紹了pagehelper插件顯示total為-1或1,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-09-09
IntelliJ IDEA基于Maven構(gòu)建Java項目
在 Java 開發(fā)中,使用 Maven 是一種廣泛采用的構(gòu)建工具,本文主要介紹了IntelliJ IDEA基于Maven構(gòu)建Java項目,具有一定的參考價值,感興趣的可以了解一下2024-03-03
今天寫代碼遇到了一個問題，請求參數(shù)是個路徑“D:/ExcelFile”，本文就詳細的介紹一下該錯誤的解決方法，感興趣的可以了解一下2021-06-06