新聞中心
這篇文章主要講解了“SpringBoot2.0如何實(shí)現(xiàn)RPC服務(wù)遠(yuǎn)程調(diào)用”,文中的講解內(nèi)容簡單清晰,易于學(xué)習(xí)與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學(xué)習(xí)“SpringBoot2.0如何實(shí)現(xiàn)RPC服務(wù)遠(yuǎn)程調(diào)用”吧!
成都創(chuàng)新互聯(lián)公司長期為數(shù)千家客戶提供的網(wǎng)站建設(shè)服務(wù),團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年,關(guān)注不同地域、不同群體,并針對不同對象提供差異化的產(chǎn)品和服務(wù);打造開放共贏平臺(tái),與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為五家渠企業(yè)提供專業(yè)的成都做網(wǎng)站、網(wǎng)站制作、成都外貿(mào)網(wǎng)站建設(shè),五家渠網(wǎng)站改版等技術(shù)服務(wù)。擁有十年豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開發(fā)。
一、Dubbo框架簡介
1、框架依賴
圖例說明:
1)圖中小方塊 Protocol, Cluster, Proxy, Service, Container, Registry, Monitor 代表層或模塊,藍(lán)色的表示與業(yè)務(wù)有交互,綠色的表示只對 Dubbo 內(nèi)部交互。
2)圖中背景方塊 Consumer, Provider, Registry, Monitor 代表部署邏輯拓?fù)涔?jié)點(diǎn)。
3)圖中藍(lán)色虛線為初始化時(shí)調(diào)用,紅色虛線為運(yùn)行時(shí)異步調(diào)用,紅色實(shí)線為運(yùn)行時(shí)同步調(diào)用。
4)圖中只包含 RPC 的層,不包含 Remoting 的層,Remoting 整體都隱含在 Protocol 中。
2、核心角色說明
1)Provider 暴露服務(wù)的服務(wù)提供方
2)Consumer 調(diào)用遠(yuǎn)程服務(wù)的服務(wù)消費(fèi)方(負(fù)載均衡)
3)Registry 服務(wù)注冊與發(fā)現(xiàn)的注冊中心(監(jiān)控、心跳、踢出、重入)
4)Monitor 服務(wù)消費(fèi)者和提供者在內(nèi)存中累計(jì)調(diào)用次數(shù)和調(diào)用時(shí)間,主動(dòng)定時(shí)每分鐘發(fā)送一次統(tǒng)計(jì)數(shù)據(jù)到監(jiān)控中心。
5)Container 服務(wù)運(yùn)行容器:遠(yuǎn)程調(diào)用、序列化
二、與SpringBoot2.0整合
1、核心依賴
com.alibaba.boot dubbo-spring-boot-starter 0.2.0
2、項(xiàng)目結(jié)構(gòu)說明
結(jié)構(gòu)說明
dubbo-consume:服務(wù)消費(fèi)方 dubbo-provider:服務(wù)提供方 dubbo-common:公共代碼塊,Dubbo接口,實(shí)體類
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)消費(fèi)方配置
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ù)遠(yuǎn)程調(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í)體類參數(shù):{}",userEntity); return userEntity; } }
2)消費(fèi)方接口
注意這里注解
com.alibaba.dubbo.config.annotation.Referenceorg.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、接口超時(shí)配置
該配置可以在服務(wù)提供方配置,也可以在服務(wù)消費(fèi)方配置,這里演示在提供方的配置。注解:timeout 1)服務(wù)接口注解
@Service(timeout = 2000) @Component public class DubboServiceImpl implements DubboService { }
2)消費(fèi)方調(diào)用
@Override public String timeOut(Integer time) { return dubboService.timeOut(time); }
3)測試接口
服務(wù)超時(shí)拋出異常
com.alibaba.dubbo.remoting.TimeoutException
3、接口多版本配置
1)服務(wù)提供方
相同接口提供兩個(gè)版本實(shí)現(xiàn)。注解:version。
版本一:
@Service(version = "1.0.0") @Component public class VersionOneImpl implements VersionService { @Override public String getVersion() { return "{當(dāng)前版本:1.0.0}"; } }
版本二:
@Service(version = "2.0.0") @Component public class VersionTwoImpl implements VersionService { @Override public String getVersion() { return "{當(dāng)前版本:2.0.0}"; } }
2)消費(fèi)方調(diào)用
通過@Reference(version)注解,將指向不同版本的接口實(shí)現(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() ; } }
感謝各位的閱讀,以上就是“SpringBoot2.0如何實(shí)現(xiàn)RPC服務(wù)遠(yuǎn)程調(diào)用”的內(nèi)容了,經(jīng)過本文的學(xué)習(xí)后,相信大家對SpringBoot2.0如何實(shí)現(xiàn)RPC服務(wù)遠(yuǎn)程調(diào)用這一問題有了更深刻的體會(huì),具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián),小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章,歡迎關(guān)注!
分享文章:SpringBoot2.0如何實(shí)現(xiàn)RPC服務(wù)遠(yuǎn)程調(diào)用
網(wǎng)站鏈接:http://www.dlmjj.cn/article/psesdh.html