SpringBoot2中如何利用Dubbo框架實現(xiàn)RPC服務(wù)遠程調(diào)用

這篇文章主要介紹了SpringBoot2中如何利用Dubbo框架實現(xiàn)RPC服務(wù)遠程調(diào)用的相關(guān)知識，內(nèi)容詳細易懂，操作簡單快捷，具有一定借鑒價值，相信大家閱讀完這篇SpringBoot2中如何利用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() ;
  }
  }

關(guān)于“SpringBoot2中如何利用Dubbo框架實現(xiàn)RPC服務(wù)遠程調(diào)用”這篇文章的內(nèi)容就介紹到這里，感謝各位的閱讀！相信大家對“SpringBoot2中如何利用Dubbo框架實現(xiàn)RPC服務(wù)遠程調(diào)用”知識都有一定的了解，大家如果還想學習更多知識，歡迎關(guān)注億速云行業(yè)資訊頻道。