Dubbo环境搭建

上节课我们了解了RPC是什么以及它的作用，这节课我们开始实战，先搭建Dubbo的环境，Dubbo官方推荐我们使用Zookeeper作为注册中心，Zookeeper 是 Apache Hadoop 的子项目，是一个树型的目录服务，支持变更推送，适合作为 Dubbo 服务的注册中心，工业强度较高，可用于生产环境，并推荐使用 ，首先我们安Zookeeper:

下载地址：https://zookeeper.apache.org/releases.html
1.png
下载完成解压进入bin目录，右键zkServer.cmd 以管理员身份打开，可能会闪退，解决方案：

右键该cmd文件，用nodepad++（或者其他编辑工具）打开，在endlocal上面加入pause，再次运行，查看出错问题：
2.png
缺失zoo.cfg文件，我们进入conf目录，发现有一个zoo_sample.cfg的文件，复制一份，修改名字为zoo.cfg

我们打开查看一下，得到的信息有默认端口为2181
3.png
然后我们再次启动：
13.png
已经正常启动了：

然后启动客户端（类同于Redis，后期的客户端就是程序）:
4.png
然后我们输入几个命令简单测试一下：
5.png
搭建Dubbo：

下载地址：https://github.com/apache/dubbo-admin/tree/master

下载master分支，下载完成解压

然后在解压目录打包：

  1. mvn clean package -Dmaven.test.skip=true

6.png
打包成功！

然后使用java -jar命令执行该包
7.png
由输出语句得到信息，dubbo运行在7001端口
8.png
启动该jar包之前，先要启动Zookeeper：

然后我们登陆localhost:7001：
9.png

默认为root-root
10.png

上代码：

首先新建一个空项目，里面添加两个springboot的model，分别作为provider-server与consumer-server服务

首先编写provider-server的代码

导入依赖：

  1.         <!--导入dubbo与zookeeper的依赖-->
  2.         <dependency>
  3.             <groupId>org.apache.dubbo</groupId>
  4.             <artifactId>dubbo-spring-boot-starter</artifactId>
  5.             <version>2.7.8</version>
  6.         </dependency>
  7.         <!--zookeeper客户端-->
  8.         <dependency>
  9.             <groupId>com.github.sgroschupf</groupId>
  10.             <artifactId>zkclient</artifactId>
  11.             <version>0.1</version>
  12.         </dependency>
  13.         <dependency>
  14.             <groupId>org.apache.curator</groupId>
  15.             <artifactId>curator-framework</artifactId>
  16.             <version>5.1.0</version>
  17.         </dependency>
  18.         <dependency>
  19.             <groupId>org.apache.curator</groupId>
  20.             <artifactId>curator-recipes</artifactId>
  21.             <version>5.1.0</version>
  22.         </dependency>
  23.         <dependency>
  24.             <groupId>org.apache.zookeeper</groupId>
  25.             <artifactId>zookeeper</artifactId>
  26.             <version>3.6.1</version>
  27.             <exclusions>
  28.                 <exclusion>
  29.                     <groupId>org.slf4j</groupId>
  30.                     <artifactId>slf4j-log4j12</artifactId>
  31.                 </exclusion>
  32.             </exclusions>
  33.         </dependency>

去掉zookeeper中的log4j依赖，要不然会报jar包冲突

配置文件：

  1. server.port=8001
  3. #服务名称
  4. dubbo.application.name=provider-server
  5. #注册中心地址
  6. dubbo.registry.address=zookeeper://127.0.0.1:2181
  7. #哪些服务要被注册
  8. dubbo.scan.base-packages=com.zym.service

编写service：

  1. package com.zym.service;
  3. public interface TicketService {
  4.     public String getTicket();
  5. }

对应的实现类:

  1. package com.zym.service;
  3. import org.apache.dubbo.config.annotation.DubboService;
  4. import org.springframework.stereotype.Service;
  6. //zookeeper:服务注册与发现
  7. @DubboService
  8. @Service
  9. //使用的dubbo以后尽量不要使用service注解，因为dubbo也有service注解容易混淆
  10. //我这里用的是高版本的，新版本Dubbo提供了@DubboService这个注解，所以我们还是可以正常使用spring的@service注解
  12. public class TicketServiceImpl implements TicketService{
  14.     @Override
  15.     public String getTicket() {
  16.         return "得到了一张票";
  17.     }
  18. }

然后运行，查看dubbo的管理页面：
11.png
可以看到已经注册成功了

接下来编写客户端，去调用注册中心的服务

依赖还是和上面的一样，此处不贴，配置文件如下：

  1. server.port=8002
  3. #消费者从哪里拿服务需要暴露自己的名字
  4. dubbo.application.name=consumer-server
  5. #注册中心的地址
  6. dubbo.registry.address=zookeeper://127.0.0.1:2181

service：

  1. package com.zym.service;
  3. import org.apache.dubbo.config.annotation.DubboReference;
  4. import org.springframework.stereotype.Service;
  6. //dubbo旧版本应该为@Reference
  7. @Service
  8. public class UserService {
  9.     //拿到provider的票,要去注册中心拿
  10.     @DubboReference //引入pom坐标，还可以定义路径相同的接口名，此处用的是第二种
  11.     TicketService ticketService;
  13.     public void buyTicket(){
  14.         System.out.println("消费者购买了一张票："+ticketService.getTicket());
  15.     }
  16. }

测试类：

  1. package com.zym;
  3. import com.zym.service.UserService;
  4. import org.junit.jupiter.api.Test;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.boot.test.context.SpringBootTest;
  8. @SpringBootTest
  9. class ConsumerServerApplicationTests {
  10.     @Autowired
  11.     UserService userService;
  12.     @Test
  13.     void contextLoads() {
  14.         userService.buyTicket();
  15.     }
  17. }

运行，查看后台输出：
12.png