SpringBoot2.0如何實現RPC服務遠程調用

這篇文章主要講解了“SpringBoot2.0如何實現RPC服務遠程調用”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“SpringBoot2.0如何實現RPC服務遠程調用”吧！

一、Dubbo框架簡介

1、框架依賴

圖例說明：

1)圖中小方塊 Protocol, Cluster, Proxy, Service, Container, Registry, Monitor 代表層或模塊，藍色的表示與業務有交互，綠色的表示只對 Dubbo 內部交互。

2)圖中背景方塊 Consumer, Provider, Registry, Monitor 代表部署邏輯拓撲節點。

3)圖中藍色虛線為初始化時調用，紅色虛線為運行時異步調用，紅色實線為運行時同步調用。

4)圖中只包含 RPC 的層，不包含 Remoting 的層，Remoting 整體都隱含在 Protocol 中。

2、核心角色說明

1）Provider 暴露服務的服務提供方

2）Consumer 調用遠程服務的服務消費方（負載均衡）

3）Registry 服務注冊與發現的注冊中心（監控、心跳、踢出、重入）

4）Monitor 服務消費者和提供者在內存中累計調用次數和調用時間，主動定時每分鐘發送一次統計數據到監控中心。

5）Container 服務運行容器：遠程調用、序列化

二、與SpringBoot2.0整合

1、核心依賴

<!-- 這里包含了Zookeeper依賴和Dubbo依賴 -->
<dependency>
 <groupId>com.alibaba.boot</groupId>
 <artifactId>dubbo-spring-boot-starter</artifactId>
 <version>0.2.0</version>
</dependency>

2、項目結構說明

結構說明

dubbo-consume：服務消費方
dubbo-provider：服務提供方
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、服務遠程調用

1）提供方服務接口

注意這里的注解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("字符參數：{}",param);
    return "[Hello,Cicada]";
  }
  @Override
  public UserEntity getUserInfo(UserEntity userEntity) {
    LOGGER.info("實體類參數：{}",userEntity);
    return userEntity;
  }
}

2）消費方接口

• 注意這里注解

• 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、接口超時配置

該配置可以在服務提供方配置，也可以在服務消費方配置，這里演示在提供方的配置。注解：timeout 1）服務接口注解

@Service(timeout = 2000)
@Component
public class DubboServiceImpl implements DubboService {
}

2）消費方調用

 @Override
 public String timeOut(Integer time) {
   return dubboService.timeOut(time);
 }

3）測試接口

服務超時拋出異常

com.alibaba.dubbo.remoting.TimeoutException

3、接口多版本配置

1）服務提供方

相同接口提供兩個版本實現。注解：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）消費方調用

通過@Reference(version)注解，將指向不同版本的接口實現。

@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如何實現RPC服務遠程調用”的內容了，經過本文的學習后，相信大家對SpringBoot2.0如何實現RPC服務遠程調用這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！