SpringBoot系列教程之dubbo和Zookeeper集成方法

仉成益

2023-03-14

本文向大家介绍SpringBoot系列教程之dubbo和Zookeeper集成方法，包括了SpringBoot系列教程之dubbo和Zookeeper集成方法的使用技巧和注意事项，需要的朋友参考一下

今日学习新的内容：dubbo

dubbo是阿里巴巴公司开源的一个高性能优秀的服务框架，一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。

zookeeper

zooKeeper是一个分布式的，开放源码的分布式应用程序协调服务，它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。

SpringBoot整合dubbo和Zookeeper

1、了解Dubbo基本概念

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

他们的关系如下：
1、服务容器启动后，运行加载服务提供者provider；
2、服务提供者成功启动，往注册中心提供自己能提供的服务；
3、服务消费者consumer成功启动，往注册中心订阅自己要消费的服务；
4、注册中心Registry返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
5、服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
6、服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

2、在docker中安装zookeeper

安装：

（自动获取到最新的zookeeper版本）
docker pull zookeeper

启动：

docker run --name zk01 -p 2181:2181 --restart always -d 6ad6cb039dfa
6ad6cb039dfa（镜像id）

阿里云安全组规则和Linux系统防火墙都记得开放2181端口。

3、新建工程（1）新建工程，工程里新建两个模块，provider模块

（2）consumer模块

4、给两个模块导入相同的pom.xml文件

zkclient使用起来还是有点坑，注意清除一些包中依赖，也是看狂神视频学到的，这里在使用2.7.7版本时候用了新的注解出了点问题，还是改回来使用2.7.3，使用新版本还有点点区别，在代码中我也给出一些警示了。

<dependencies>
    <!--    dubbo 7.3倒是可以,7.7的就出错连接不上了-->
    <dependency>
      <groupId>org.apache.dubbo</groupId>
      <artifactId>dubbo-spring-boot-starter</artifactId>
      <version>2.7.3</version>
    </dependency>

    <!--    zookeeper client zkclient-->
    <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
    <dependency>
      <groupId>com.github.sgroschupf</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.1</version>
    </dependency>


    <!-- 引入zookeeper 避开连接的坑 -->
    <dependency>
      <groupId>org.apache.curator</groupId>
      <artifactId>curator-framework</artifactId>
      <version>2.12.0</version>
    </dependency>
    <dependency>
      <groupId>org.apache.curator</groupId>
      <artifactId>curator-recipes</artifactId>
      <version>2.12.0</version>
    </dependency>

    <dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.4.14</version>
      <!--排除这个slf4j-log4j12-->
      <exclusions>
        <exclusion>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
      </exclusions>
    </dependency>

5、添加service层售票接口、接口实现类（1）ITicketService

public interface ITicketService {
  String saleTicket(String name);
}

（2）TicketServiceImpl

注意使用的包名称一定要一致，不是spring带的Service

package top.weidaboy.provider.service.Impl;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;
import top.weidaboy.provider.service.ITicketService;
//zookeeper:服务注册与发现
@Service      //使用后被注入,项目已启动就自动注册到注册中心
@Component  //放到spring容器中去
//新版:import org.apache.dubbo.config.annotation.DubboService;
//@DubboService //将服务发布出去
public class TicketServiceImpl implements ITicketService {

  @Override
  public String saleTicket(String name) {
    return "确认买票： "+name;
  }
}

6、application.proterties文件配置dubbo详细信息

server.port=8081
#当前应用起名
dubbo.application.name=provider-server
#找到zookeeper注册中心地址
dubbo.registry.address=zookeeper://你的IP:2181
#扫描提供指定包下的服务
dubbo.scan.base-packages=top.weidaboy.provider.service

7、启动服务提供者代码

启动成功后，该程序会往对应的注册中心地址注册新的服务，供给需要消费的消费者使用

8、编写服务消费者代码

既然有了服务提供者，那么就在consumer模块中创建消费者来使用服务，分以下三步：

（1）创建消费者服务，以及实现接口

UserService：

public interface IUserService {
  //买票
  String buyTicket(String name);
}

UserServiceImpl：

@Service//注入到容器中, 这个import org.springframework.stereotype.Service;
public class UserServiceImpl implements IUserService {

  @Reference
   //远程引用指定的服务,
  //该注解会按照全类名来进行匹配,看是哪个给注册中心注册了这个全类名
  ITicketService ticketService; //相同的接口名

  @Override
  public String buyTicket(String name) {
    return ticketService.saleTicket(name);
  }
}

（2）在consumer模块中添加服务提供者的接口代码

要求：在consumer模块提供方的代码路径必须与provider模块的路径一样,只需导入接口类
ITicketService：

public interface ITicketService {
  String saleTicket(String name);
}

代码结构如图：丑了点嘿嘿，凑合看吧

（3）修改application.proterties文件

注意：这是在consumer模块下的文件，因为消费者只是需要消费服务，无须注册，就可以不用扫描对应的服务包名了

server.port=8082 #需要不同端口
#给当前应用起名:
dubbo.application.name=consumer-server
#注册中心
dubbo.registry.address=zookeeper://你的IP:2181

9、编写测试类

@SpringBootTest
class WeidaboyApplicationTests {
  @Autowired
  IUserService userService;
  @Test
  void contextLoads() {
    System.out.println(userService.buyTicket("唐人街探案三"));
  }
}

10、测试调用不同端口的服务

运行测试类，要求我们刚刚启动的服务提供者的程序不要关闭，并且两个端口不能相互占用，注册中心地址一样。

测试成功！

小结

本次学习内容实现：SpingBoot整合了dubbo和zookeeper实现分布式开发的应用，将提供服务和消费服务进行拆分，让不同系统去管理，整体是为了更方便，更有目的的开发项目，长路漫漫，继续前进吧！

到此这篇关于SpringBoot系列教程之dubbo和Zookeeper集成方法的文章就介绍到这了,更多相关SpringBoot dubbo和Zookeeper集成内容请搜索小牛知识库以前的文章或继续浏览下面的相关文章希望大家以后多多支持小牛知识库！

SpringBoot系列教程之dubbo和Zookeeper集成方法

相关阅读

相关文章

相关问答

相关工具

相关文档