SpringBoot整合Dubbo框架,實(shí)現(xiàn)RPC服務(wù)遠(yuǎn)程調(diào)用
一、Dubbo框架簡(jiǎn)介
1、框架依賴
圖例說(shuō)明：
1)圖中小方塊 Protocol, Cluster, Proxy, Service, Container, Registry, Monitor 代表層或模塊，藍(lán)色的表示與業(yè)務(wù)有交互，綠色的表示只對(duì) 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、核心角色說(shuō)明
1）Provider 暴露服務(wù)的服務(wù)提供方
2）Consumer 調(diào)用遠(yuǎn)程服務(wù)的服務(wù)消費(fèi)方（負(fù)載均衡）
3）Registry 服務(wù)注冊(cè)與發(fā)現(xiàn)的注冊(cè)中心（監(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、核心依賴
<!-- 這里包含了Zookeeper依賴和Dubbo依賴 --> <dependency> <groupId>com.alibaba.boot</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>0.2.0</version> </dependency>
2、項(xiàng)目結(jié)構(gòu)說(shuō)明
結(jié)構(gòu)說(shuō)明
dubbo-consume：服務(wù)消費(fèi)方 dubbo-provider：服務(wù)提供方 dubbo-common：公共代碼塊，Dubbo接口，實(shí)體類(lèi)
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í)體類(lèi)參數(shù)：{}",userEntity);
return userEntity;
}
}
2）消費(fèi)方接口
- 注意這里注解
- 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、接口超時(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）測(cè)試接口
服務(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)用
通過(guò)@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() ;
}
}
以上案例都是參照Dubbo官網(wǎng)的流程編寫(xiě)的，Dubbo許多強(qiáng)大功能都可以參考官網(wǎng)一步步的配置。
四、源代碼地址
GitHub地址：知了一笑
https://github.com/cicadasmile/middle-ware-parent
以上就是SpringBoot整合Dubbo框架,實(shí)現(xiàn)RPC服務(wù)遠(yuǎn)程調(diào)用的詳細(xì)內(nèi)容，更多關(guān)于SpringBoot整合Dubbo框架的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
2023最新版IDEA創(chuàng)建javaweb項(xiàng)目的詳細(xì)圖文教程
之前用的社區(qū)版IDEA無(wú)法部署JavaWeb項(xiàng)目,于是裝了一個(gè)最新版的IDEA,下面這篇文章主要給大家介紹了關(guān)于2023最新版IDEA創(chuàng)建javaweb項(xiàng)目的詳細(xì)圖文教程,文中通過(guò)圖文介紹的非常詳細(xì),需要的朋友可以參考下2023-06-06
對(duì)于面向?qū)ο缶幊虂?lái)說(shuō),抽象是它的一大特征之一,在 Java 中可以通過(guò)兩種形式來(lái)體現(xiàn)OOP的抽象:接口和抽象類(lèi),下面這篇文章主要給大家介紹了關(guān)于Java入門(mén)基礎(chǔ)之抽象類(lèi)與接口的相關(guān)資料,需要的朋友可以參考下2022-04-04
這篇文章主要介紹了java生成json數(shù)據(jù)示例,需要的朋友可以參考下2014-04-04
這篇文章主要介紹了Intellij?IDEA如何查看所有斷點(diǎn)問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-03-03
深入講解基于JDK的動(dòng)態(tài)代理機(jī)制
眾所周知相比于靜態(tài)代理，動(dòng)態(tài)代理避免了開(kāi)發(fā)人員編寫(xiě)各個(gè)繁鎖的靜態(tài)代理類(lèi)，下面這篇文章主要給大家介紹了關(guān)于基于JDK的動(dòng)態(tài)代理機(jī)制的相關(guān)資料，文中通過(guò)圖文以及示例代碼介紹的非常詳細(xì)，需要的朋友可以參考下2018-07-07
springboot+vue+elementsUI實(shí)現(xiàn)分角色注冊(cè)登錄界面功能
這篇文章主要給大家介紹了關(guān)于springboot+vue+elementsUI實(shí)現(xiàn)分角色注冊(cè)登錄界面功能的相關(guān)資料,Spring?Boot和Vue.js是兩個(gè)非常流行的開(kāi)源框架,可以用來(lái)構(gòu)建Web應(yīng)用程序,需要的朋友可以參考下2023-07-07
SpringBoot整合Redis使用@Cacheable和RedisTemplate
本文主要介紹了SpringBoot整合Redis使用@Cacheable和RedisTemplate，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-07-07
Redis 訂閱發(fā)布_Jedis實(shí)現(xiàn)方法
下面小編就為大家?guī)?lái)一篇Redis 訂閱發(fā)布_Jedis實(shí)現(xiàn)方法。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-06-06
Spring Cloud Hystrix實(shí)現(xiàn)服務(wù)容錯(cuò)的方法
Hystrix是SpringCloud中重要的熔斷保護(hù)組件,由Netflix開(kāi)源,主要提供延遲和容錯(cuò)管理,以保障分布式系統(tǒng)的高可用性和魯棒性,通過(guò)封裝依賴項(xiàng)實(shí)現(xiàn)服務(wù)間隔離,引入回退邏輯應(yīng)對(duì)依賴服務(wù)故障,有效防止系統(tǒng)崩潰和服務(wù)級(jí)聯(lián)故障2024-10-10
今天要分享得是Spring的@DependsOn注解，對(duì)于@DependsOn，我們從它的名稱里面就能看出意思是“依賴于”，那么在Spring中，它的作用就是解決Bean的創(chuàng)建依賴，感興趣的小伙伴快來(lái)閱讀吧2023-04-04