Dubbo+zookeeper搭建微服务

Dubbo+zookeeper搭建微服务

Dubbo环境搭建

Dubbo推荐我们用Zookeeper注册中心，即将我们的服务在注册中心注册，需要的可以在注册中心拿到服务，可异机服务

1、Zookeeper：

• 下载Zookeeper https://zookeeper.apache.org/
• 安装步骤：https://blog.csdn.net/xc_zhou/article/details/121593786
• 创建一个zoo.cfg配置文件，配置文件中的内容与zoo_sample.cfg内容一致 （复制粘贴一份就行）
• 运行zkServer.cmd(服务端)
• 出现ZooKeeper audit is disabled错误时：https://blog.csdn.net/qq_43472877/article/details/111177298
• zookeeper的默认端口号为：2181 即注册中心的端口号
• 使用zkCli.cmd测试：
  • **ls /：**列出zookeeper根下的所有节点
  • **create -e /qiumin 123：**创建一个qiumin节点，值为123456
  • **get qiumin：**获取qiumin的值

2、下载Dubbo-admin可视化：

• https://github.com/apache/dubbo
• 下载该版本 dubbo-admin-master-0.2.0 （这里使用的是该版本，你也可以使用最新版的）
• 在该文件夹中执行：mvn clean package -Dmaven.test.skip=ture 【打成一个jar包，也可以在idea里打成jar包】
• 运行该jar包 java -jar jar包名 【注意：该操作需先打开zookeeper的服务端】
• http://localhost:7001/ 访问，用户名密码默认为root root

23.3 结合项目使用

在一个空项目中创建两个项目，分别为提供者即服务端和消费者即客户端

provide-server

• 导入依赖

  org.apache.dubbo dubbo-spring-boot-starter 2.7.3 com.github.sgroschupf zkclient 0.1 org.apache.curator curator-framework 2.12.0 org.apache.curator curator-recipes 2.12.0 org.apache.zookeeper zookeeper 3.6.2 org.slf4j slf4j-log4j12

注意：导入的日志尽量是maven仓库中使用人数最多的版本，有些报错是由于版本问题，zookeeper最好使用3.6.2版本

• 配置文件

  server.port=8081
  #提供者名称
  dubbo.application.name=provide-server
  #注册中心地址
  dubbo.registry.address=zookeeper://127.0.0.1:2181
  #需要注册到注册中心的服务，扫描包
  dubbo.scan.base-packages=com.qiumin.service

• 接口Service

  package com.qiumin.service;

  public interface TicketService {
  public String getTicket();
  }

• 接口实现类ServiceImpl

  package com.qiumin.service;

  import org.apache.dubbo.config.annotation.Service;
  import org.springframework.stereotype.Component;

  @Component //本来这里可以用框架下的service，为了区分就是用该注解将其加入spring容器中
  @Service //该为dubbo下的service 最新版本的可以用DubboService
  public class TicketServiceImpl implements TicketService{
  //通过配置文件将其加入注册中心
  @Override
  public String getTicket() {
  return “《邱敏学Java》”;
  }
  }

注意导包的问题

• 将zookeeper的服务端启动后在启动该项目的服务，成功后就会在注册中心注册服务，可运行Dubbo-admin jar包来可视化查看

consumer-server

• 导入依赖（与上面相同的依赖）

  org.apache.dubbo dubbo-spring-boot-starter 2.7.3 com.github.sgroschupf zkclient 0.1 org.apache.curator curator-framework 2.12.0 org.apache.curator curator-recipes 2.12.0 org.apache.zookeeper zookeeper 3.6.2 org.slf4j slf4j-log4j12

• 配置文件

  server.port=8002
  #消费者名称
  dubbo.application.name=consumer-server
  #注册中心地址，可以为其他计算机上的地址
  dubbo.registry.address=zookeeper://127.0.0.1:2181

• 创建与服务端相同路径的且相同名字的接口【在不同的项目中】

  package com.qiumin.service;

  public interface TicketService {
  public String getTicket();
  }

• userService 服务

  package com.qiumin.service;

  import org.apache.dubbo.config.annotation.Reference;
  import org.springframework.stereotype.Service;

  @Service //框架下的Service，加入容器
  public class userService {

  @Reference  //引用注册中心的接口，路径接口名相同   去注册中心拿
  TicketService ticketService;
  
  public void buyTicket(){
      String ticket = ticketService.getTicket();
      System.out.println("从注册中心拿到的==>"+ticket);
  }
  1
  2
  3
  4
  5
  6
  7

  }

@Reference //引用注册中心的接口，路径接口名相同 去注册中心拿 【新版@DubboReference】

• 测试 实际是controller这里只是简单的测试

  package com.qiumin;

  import com.qiumin.service.userService;
  import org.junit.jupiter.api.Test;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.boot.test.context.SpringBootTest;

  @SpringBootTest
  class ConsumerServerApplicationTests {
  @Autowired
  userService service;

  @Test
  void contextLoads() {
      //注册中心拿Ticket
      service.buyTicket();
  }
  1
  2
  3
  4
  5

  }

• 启动该项目的服务，前提是zookeeper注册中心和前面写的provide-server即服务端启动了，该项目服务启动后就会用注册中心注册的服务

23.4 总结

步骤：

前提：zookeeper服务已开启

1、 提供者提供服务（服务端）

• 导入依赖
• 配置注册中心的地址，以及服务发现名，和要扫描的包
• 在想要被注册的服务上面 添加一个注解@Service Dobbo的service

2、消费者如何消费 （客户端）

• 导入依赖
• 配置注册中心的地址，配置自己的服务名
• 从远程注入服务@Reference

**3、调试 ** （注意我们创建项目时端口的问题）

开启注册中心服务zookeeper---->执行可视化的jar包---->idea中启动提供者服务，注册服务----->启动消费者服务，从注册中心取服务

4、Nacos

现名，和要扫描的包

• 在想要被注册的服务上面 添加一个注解@Service Dobbo的service

2、消费者如何消费 （客户端）

• 导入依赖
• 配置注册中心的地址，配置自己的服务名
• 从远程注入服务@Reference

**3、调试 ** （注意我们创建项目时端口的问题）

开启注册中心服务zookeeper---->执行可视化的jar包---->idea中启动提供者服务，注册服务----->启动消费者服务，从注册中心取服务

4、Nacos

qiumin