Spring Boot Dubbo 构建分布式服务的方法

更新时间：2019年05月31日 09:05:28 作者：JavaStorm

这篇文章主要介绍了Spring Boot Dubbo 构建分布式服务的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧

概述：

节点角色说明

节点	角色说明
Provider	暴露服务的服务提供方
Consumer	调用远程服务的服务消费方
Registry	服务注册与发现的注册中心
Monitor	统计服务的调用次数和调用时间的监控中心
Container	服务运行的容器

调用关系说明

服务容器 Container 负责启动，加载，运行服务提供者。
服务提供者 Provider 启动的时候，向注册中心 Registry 注册自己提供的服务。
服务消费者 Consumer 在启动的时候，向注册中心 Registry 订阅自己所需要的服务。注册中心 Registry 返回服务提供者的地址列表给消费者，如果有变更注册中心将基于长连接推送变更数据给消费者。
服务消费者从提供者地址列表中，基于软负载均衡算法，选择一台提供者进行进行调用，如果调用失败再选择另外一台。
服务消费者与提供者在内存中统计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心 Monitor 。

项目构建

开发环境主要涉及以下方面：

Spring Boot
JDK 8
Dubbo 2.7.1
Zookeeper

具体代码可以查看 github 的 dubbo 模块： https://github.com/UniqueDong/springboot-study

Dubbo API

定义服务接口，打成 jar 包让消费者依赖，服务者实现接口。该工程只有接口定义以及 model 对象。@Data 属于lombok 开源库提供的特性，方便开发。

model 对象定义：

@Data
public class User implements Serializable {
  private Long id;
  private String username;
}

provider 接口定义：

public interface UserProvider {
  List<User> listUser();
}

Provider 服务提供者

pom依赖：

引入spring-boot-starter，dubbo-api 接口就是我们上面提到的接口定义 jar ，dubbo-spring-boot-starter ，dubbo-dependencies-zookeeper。

<dependencies>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter</artifactId>
      <exclusions>
        <exclusion>
          <artifactId>spring-boot-starter-logging</artifactId>
          <groupId>org.springframework.boot</groupId>
        </exclusion>
      </exclusions>
    </dependency>
    <dependency>
      <groupId>zero.springboot.study</groupId>
      <artifactId>dubbo-api</artifactId>
      <version>1.0.0-SNAPSHOT</version>
    </dependency>
    <!--dubbo start-->
    <dependency>
      <groupId>org.apache.dubbo</groupId>
      <artifactId>dubbo-spring-boot-starter</artifactId>
      <version>2.7.1</version>
    </dependency>

    <dependency>
      <groupId>org.apache.dubbo</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.7.1</version>
    </dependency>

    <!-- Zookeeper dependencies -->
    <dependency>
      <groupId>org.apache.dubbo</groupId>
      <artifactId>dubbo-dependencies-zookeeper</artifactId>
      <version>2.7.1</version>
      <type>pom</type>
      <exclusions>
        <exclusion>
          <artifactId>log4j</artifactId>
          <groupId>log4j</groupId>
        </exclusion>
        <exclusion>
          <artifactId>slf4j-log4j12</artifactId>
          <groupId>org.slf4j</groupId>
        </exclusion>
      </exclusions>
    </dependency>

    <!--dubbo end-->
    
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>fastjson</artifactId>
      <version>1.2.57</version>
    </dependency>
  </dependencies>

配置文件 yaml 定义：

spring:
 application:
  name: dubbo-provider
#自定义配置
embedded:
 zookeeper:
  # zookeeper 服务连接端口
  port: 2181

# dubbo 配置
dubbo:
 # 注册中心配置 
 registry:
  id: dubbo-provider
  address: zookeeper://127.0.0.1:${embedded.zookeeper.port}
  group: local
 application:
  name: dubbo-provider
  id: dubbo-provider
  logger: slf4j
  qosEnable: true
  qosPort: 22224
  qosAcceptForeignIp: false
 # dubbo 协议配置
 protocol:
  # -1 表示使用随机未被占用的端口
  port: -1
  name: dubbo
 scan:
  # dubbo 服务提供者实现类所在包
  base-packages: com.zero.provider.impl

实现 api 定义的接口

注意 @Service 是 Dubbo 的，不要导入了 Spring 的。

import com.google.common.collect.Lists;
import com.zero.api.model.User;
import com.zero.api.provider.UserProvider;
import org.apache.dubbo.config.annotation.Service;

import java.util.List;

@Service(interfaceClass = UserProvider.class)
public class UserProviderImpl implements UserProvider {
  @Override
  public List<User> listUser() {
    User user = new User();
    user.setId(1L);
    user.setUsername("青龙");
    return Lists.newArrayList(user);
  }
}

Consumer

Pom 定义：

我们要依赖 spring-boot-starter-web 提供http rest接口给前端调用。同时内部通过 Dubbo 实现 RPC调用服务提供者。

<dependencies>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
      <exclusions>
        <exclusion>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-logging</artifactId>
        </exclusion>
      </exclusions>
    </dependency>
    <dependency>
      <groupId>zero.springboot.study</groupId>
      <artifactId>dubbo-api</artifactId>
      <version>1.0.0-SNAPSHOT</version>
    </dependency>
    <!--dubbo start-->
    <dependency>
      <groupId>org.apache.dubbo</groupId>
      <artifactId>dubbo-spring-boot-starter</artifactId>
      <version>2.7.1</version>
    </dependency>

    <dependency>
      <groupId>org.apache.dubbo</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.7.1</version>
    </dependency>

    <!-- Zookeeper dependencies -->
    <dependency>
      <groupId>org.apache.dubbo</groupId>
      <artifactId>dubbo-dependencies-zookeeper</artifactId>
      <version>2.7.1</version>
      <type>pom</type>
      <exclusions>
        <exclusion>
          <artifactId>log4j</artifactId>
          <groupId>log4j</groupId>
        </exclusion>
        <exclusion>
          <artifactId>slf4j-log4j12</artifactId>
          <groupId>org.slf4j</groupId>
        </exclusion>
      </exclusions>
    </dependency>

    <!--dubbo end-->

    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <optional>true</optional>
    </dependency>

  </dependencies>

yaml 定义：

server:
 # web 日更年期端口
 port: 9005
spring:
 application:
  name: dubbo-comsumer
#自定义配置
embedded:
 zookeeper:
  port: 2181
# dubbo 配置
dubbo:
 registry:
  id: dubbo-comsumer
  address: zookeeper://127.0.0.1:${embedded.zookeeper.port}
  group: local
 application:
  name: dubbo-comsumer
  id: dubbo-comsumer
  logger: slf4j
  qosEnable: false
  qosPort: 22223
  qosAcceptForeignIp: false
 protocol:
  port: -1
  name: dubbo
 # 是否检查服务提供者有效 
 consumer:
  check: false

服务消费者调用服务生产者

import com.zero.api.model.User;
import com.zero.api.provider.UserProvider;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class UserService {

  @Reference
  private UserProvider userProvider;

  public List<User> listUser() {
    return userProvider.listUser();
  }
}

我们通过一个RESTfull接口，提供给前端调用。

@RestController
@RequestMapping("/users")
public class UserController {
  @Autowired
  private UserService userService;

  @GetMapping
  public Object listUser() {
    List<User> list = userService.listUser();
    return list;
  }
}

总结

各种具体协议、注册中心、多注册中心、超时等配置可以查看官方文档 http://dubbo.apache.org/zh-cn/docs/user/quick-start.html

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

Java二维码登录流程实现代码(包含短地址生成，含部分代码)
近年来，二维码的使用越来越风生水起，本篇文章主要介绍了Java二维码登录流程实现代码，其中包含短地址生成，有兴趣的可以了解一下。
2016-12-12
SpringBoot启动失败的解决方法：A component required a&nb
这篇文章主要介绍了解决SpringBoot启动失败：A component required a bean of type ‘xxxxxxx‘ that could not be found.,目前解决方法有两种，一种是不注入bean的方式，另一种是使用@Component的方式，本文给大家详细讲解，需要的朋友可以参考下
2023-02-02
Java中的ArrayList、LinkedList、HashSet等容器详解
这篇文章主要介绍了Java中的ArrayList、LinkedList、HashSet等容器详解,集合表示一组对象，称为其元素,有些集合允许重复元素，而另一些则不允许,有些是有序的，有些是无序的,需要的朋友可以参考下
2023-08-08
idea http request无法识别环境变量的解决步骤
AlibabaCloudToolkit插件安装后在 Editor->File Types增加 AlibabaCloudROStemplates(JSON)项且会配置为解析*.json 文件，导致http client无法正确解析http-client.env.json文件而无法读取环境变量，本文介绍idea http request无法识别环境变量问题,需要的朋友可以参考下
2023-08-08
java实现微信扫码支付功能
这篇文章主要为大家详细介绍了java实现微信扫码支付功能，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2018-07-07
JAVA字符串反转的三种方法
这篇文章主要介绍了JAVA字符串反转的三种方法，帮助大家更好的理解和学习Java，感兴趣的朋友可以了解下
2020-09-09
SpringBoot使用前缀树过滤敏感词的方法实例
Trie也叫做字典树、前缀树（Prefix Tree）、单词查找树,特点：查找效率高，消耗内存大,这篇文章主要给大家介绍了关于SpringBoot使用前缀树过滤敏感词的相关资料,需要的朋友可以参考下
2022-01-01
Elasticsearch索引结构与算法解析
作为搜索引擎的一部分，ES自然具有速度快、结果准确、结果丰富等特点，那么ES是如何达到“搜索引擎”级别的查询效率呢？首先是索引，其次是压缩算法，接下来我们就一起了解下ES的索引结构和压缩算法
2023-04-04
java文件读写操作实例详解
java的io流读取数据使用io流读取文件和向文件中写数据,这篇文章主要给大家介绍了关于java文件读写操作的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2022-02-02
springboot结合maven实现多模块打包
本文主要介绍了springboot借助maven完成多模块打包，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2023-04-04