脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → SpringBoot整合Dubbo框架

SpringBoot整合Dubbo框架,实现RPC服务远程调用

 更新时间：2021年06月01日 09:48:28   作者：知了一笑  
Dubbo是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。今天就来看下SpringBoot整合Dubbo框架的步骤

一、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.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、接口超时配置

该配置可以在服务提供方配置，也可以在服务消费方配置，这里演示在提供方的配置。
注解：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() ;
    }
}

以上案例都是参照Dubbo官网的流程编写的，Dubbo许多强大功能都可以参考官网一步步的配置。

四、源代码地址 

GitHub地址：知了一笑
https://github.com/cicadasmile/middle-ware-parent

以上就是SpringBoot整合Dubbo框架,实现RPC服务远程调用的详细内容，更多关于SpringBoot整合Dubbo框架的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

相关文章

  • 2023最新版IDEA创建javaweb项目的详细图文教程

    2023最新版IDEA创建javaweb项目的详细图文教程

    之前用的社区版IDEA无法部署JavaWeb项目,于是装了一个最新版的IDEA,下面这篇文章主要给大家介绍了关于2023最新版IDEA创建javaweb项目的详细图文教程,文中通过图文介绍的非常详细,需要的朋友可以参考下
    2023-06-06
  • Java 超详细讲解抽象类与接口的使用

    Java 超详细讲解抽象类与接口的使用

    对于面向对象编程来说,抽象是它的一大特征之一,在 Java 中可以通过两种形式来体现OOP的抽象:接口和抽象类,下面这篇文章主要给大家介绍了关于Java入门基础之抽象类与接口的相关资料,需要的朋友可以参考下
    2022-04-04
  • java生成json数据示例

    java生成json数据示例

    这篇文章主要介绍了java生成json数据示例,需要的朋友可以参考下
    2014-04-04
  • Intellij IDEA如何查看所有断点

    Intellij IDEA如何查看所有断点

    这篇文章主要介绍了Intellij IDEA如何查看所有断点问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2023-03-03
  • 深入讲解基于JDK的动态代理机制

    深入讲解基于JDK的动态代理机制

    众所周知相比于静态代理，动态代理避免了开发人员编写各个繁锁的静态代理类，下面这篇文章主要给大家介绍了关于基于JDK的动态代理机制的相关资料，文中通过图文以及示例代码介绍的非常详细，需要的朋友可以参考下
    2018-07-07
  • springboot+vue+elementsUI实现分角色注册登录界面功能

    springboot+vue+elementsUI实现分角色注册登录界面功能

    这篇文章主要给大家介绍了关于springboot+vue+elementsUI实现分角色注册登录界面功能的相关资料,Spring Boot和Vue.js是两个非常流行的开源框架,可以用来构建Web应用程序,需要的朋友可以参考下
    2023-07-07
  • SpringBoot整合Redis使用@Cacheable和RedisTemplate

    SpringBoot整合Redis使用@Cacheable和RedisTemplate

    本文主要介绍了SpringBoot整合Redis使用@Cacheable和RedisTemplate，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2022-07-07
  • Redis 订阅发布_Jedis实现方法

    Redis 订阅发布_Jedis实现方法

    下面小编就为大家带来一篇Redis 订阅发布_Jedis实现方法。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-06-06
  • Spring Cloud  Hystrix实现服务容错的方法

    Spring Cloud  Hystrix实现服务容错的方法

    Hystrix是SpringCloud中重要的熔断保护组件,由Netflix开源,主要提供延迟和容错管理,以保障分布式系统的高可用性和鲁棒性,通过封装依赖项实现服务间隔离,引入回退逻辑应对依赖服务故障,有效防止系统崩溃和服务级联故障
    2024-10-10
  • Spring注解@DependsOn解析

    Spring注解@DependsOn解析

    今天要分享得是Spring的@DependsOn注解，对于@DependsOn，我们从它的名称里面就能看出意思是“依赖于”，那么在Spring中，它的作用就是解决Bean的创建依赖，感兴趣的小伙伴快来阅读吧
    2023-04-04

最新评论