Spring Boot----SpringBoot整合 Dubbo 和 Zookeeper

下载安装Zookeeper

linux

　　使用docker部署

windows:参考（https://blog.csdn.net/ring300/article/details/80446918），下载的zookeeper目录中需要包含lib（内置jar包，否则需要自己导入）

　　1、将conf目录下的zoo_sample.cfg文件，复制粘贴一份，重命名为zoo.cfg

　　3、修改zoo.cfg 文件中的

dataDir=D:\Zookeeper\data
datalogDir=D:\Zookeeper\log

　　4、启动双击 zkServer.cmd

对zoo.cfg文件配置说明

　　tickTime：这个时间是作为 Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每个 tickTime 时间就会发送一个心跳。

　　initLimit：这个配置项是用来配置 Zookeeper 接受客户端（这里所说的客户端不是用户连接 Zookeeper 服务器的客户端，而是 Zookeeper 服务器集群中连接到 Leader 的 Follower 服务器）初始化连接

时最长能忍受多少个心跳时间间隔数。当已经超过 10 个心跳的时间（也就是 tickTime）长度后 Zookeeper 服务器还没有收到客户端的返回信息，那么表明这个客户端连接失败。总的时间长度就是

10*2000=20 秒

　　syncLimit：这个配置项标识 Leader 与 Follower 之间发送消息，请求和应答时间长度，最长不能超过多少个 tickTime 的时间长度，总的时间长度就是 5*2000=10 秒

　　dataDir：顾名思义就是 Zookeeper 保存数据的目录，默认情况下，Zookeeper 将写数据的日志文件也保存在这个目录里。

　　clientPort：这个端口就是客户端连接 Zookeeper 服务器的端口，Zookeeper 会监听这个端口，接受客户端的访问请求。

SpringBoot整合Dubbo（RPC）

整合dubbo添加依赖

方法文档：https://github.com/apache/dubbo-spring-boot-project

1、provider 发布服务

1.1 在provider中的pom添加dubbo依赖和zookeeper相关依赖

        <dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.3</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>4.2.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>4.2.0</version></dependency><dependency><!--zookeeper应该不需要在依赖了--><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.5.5</version><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion><exclusion><groupId>log4j</groupId><artifactId>log4j</artifactId></exclusion></exclusions></dependency>

1.2 application.properties

#当前服务的名字可以任意
dubbo.application.name=provider
#zookeeper的默认端口2181
dubbo.registry.address=zookeeper://localhost:2181
#将service包下的服务发布出去
dubbo.scan.base-packages=com.zy.provider.service

1.3 Service（非常重要，需要有一份一样的service接口到consumer中，全限定类型(包名和类名都要一样)）

package com.zy.provider.service;public interface TestService {public String test();
}

1.4 serviceimpl

@Component
@Service  //注解到实现类上【org.apache.dubbo.config.annotation.Service;】
public class TestServiceImpl implements TestService {  //必须有一个接口@Overridepublic String test() {return "ok";}
}

1.5 启动：表示注册成功(否则，测试consumer的时候会报错)

2、consumer 引用服务

2.1 引入依赖

        <dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.3</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>4.2.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>4.2.0</version></dependency><!--排除zookeeper内部的日志jia包,防止和自生项目引入日志jar包产生冲突--><!--zookeeper应该是不需要在依赖了--><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.5.5</version><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion><exclusion><groupId>log4j</groupId><artifactId>log4j</artifactId></exclusion></exclusions></dependency>

2.2 application.properties

dubbo.application.name=consumer
dubbo.registry.address=zookeeper://192.168.1.101:2181
server.port=8082

2.3 创建service接口（这个service和provider中的 service需要一样，全限定类名一样(包名+接口名字)）

package com.zy.provider.service;  //注意包名public interface TestService {public String test();
}

2.4 创建自己项目中的service

package com.zy.consumer.service;
import com.zy.provider.service.TestService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;@Service
public class ConsumerService {@Reference //注意包是dubbo下的org.apache.dubbo.config.annotation.Reference;TestService testService;public void test(){System.out.println(testService.test());}
}

2.5 测试，控制台打印ok

@RunWith(SpringRunner.class)
@SpringBootTest
public class ConsumerApplicationTests {@Autowiredprivate ConsumerService consumerService;@Testpublic void contextLoads() {consumerService.test();}
}