SpringBoot整合Dubbo框架,實現(xiàn)RPC服務(wù)遠(yuǎn)程調(diào)用
圖例說明：1)圖中小方塊 Protocol, Cluster, Proxy, Service, Container, Registry, Monitor 代表層或模塊，藍(lán)色的表示與業(yè)務(wù)有交互，綠色的表示只對 Dubbo 內(nèi)部交互。2)圖中背景方塊 Consumer, Provider, Registry, Monitor 代表部署邏輯拓?fù)涔?jié)點。3)圖中藍(lán)色虛線為初始化時調(diào)用，紅色虛線為運行時異步調(diào)用，紅色實線為運行時同步調(diào)用。4)圖中只包含 RPC 的層，不包含 Remoting 的層，Remoting 整體都隱含在 Protocol 中。
2、核心角色說明
1）Provider 暴露服務(wù)的服務(wù)提供方2）Consumer 調(diào)用遠(yuǎn)程服務(wù)的服務(wù)消費方（負(fù)載均衡）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ù)運行容器：遠(yuǎn)程調(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: 5000msspring: 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: 5000msspring: application: name: block-dubbo-consume# Dubbo 配置文件dubbo: application: name: block-dubbo-consume registry: address: 127.0.0.1:2181 protocol: zookeeper三、演示案例 1、服務(wù)遠(yuǎn)程調(diào)用
1）提供方服務(wù)接口
注意這里的注解 com.alibaba.dubbo.config.annotation.Service@Service@Componentpublic 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@Servicepublic 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)@Componentpublic class DubboServiceImpl implements DubboService {}
2）消費方調(diào)用
@Override public String timeOut(Integer time) { return dubboService.timeOut(time); }
3）測試接口
服務(wù)超時拋出異常
com.alibaba.dubbo.remoting.TimeoutException3、接口多版本配置
1）服務(wù)提供方
相同接口提供兩個版本實現(xiàn)。注解：version。版本一：
@Service(version = '1.0.0')@Componentpublic class VersionOneImpl implements VersionService { @Override public String getVersion() {return '{當(dāng)前版本：1.0.0}'; }}
版本二：
@Service(version = '2.0.0')@Componentpublic class VersionTwoImpl implements VersionService { @Override public String getVersion() {return '{當(dāng)前版本：2.0.0}'; }}
2）消費方調(diào)用
通過@Reference(version)注解，將指向不同版本的接口實現(xiàn)。
@Servicepublic 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ù)遠(yuǎn)程調(diào)用的詳細(xì)內(nèi)容，更多關(guān)于SpringBoot整合Dubbo框架的資料請關(guān)注好吧啦網(wǎng)其它相關(guān)文章！
網(wǎng)公網(wǎng)安備