下载安装Zookeeper

linux

　　使用docker部署

windows:参考（），下载的zookeeper目录中需要包含lib（内置jar包，否则需要自己导入）

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

　　2、创建data目录和log目录

　　3、修改zoo.cfg 文件中的

dataDir=D:\Zookeeper\datadatalogDir=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添加依赖

方法文档：

1、provider 发布服务

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

                 
      
       org.apache.dubbo
                  
      
       dubbo-spring-boot-starter
                  
      
       2.7.3
              
             
                 
      
       org.apache.curator
                  
      
       curator-framework
                  
      
       4.2.0
              
             
                 
      
       org.apache.curator
                  
      
       curator-recipes
                  
      
       4.2.0
              
             
     
                  
      
       org.apache.zookeeper
                  
      
       zookeeper
                  
      
       3.5.5
                  
                      
                           
        
         org.slf4j
                            
        
         slf4j-log4j12
                        
                       
                           
        
         log4j
                            
        
         log4j
                        
                   
              
     

1.2 application.properties

#当前服务的名字可以任意dubbo.application.name=provider#zookeeper的默认端口2181dubbo.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 {  //必须有一个接口    @Override    public String test() {        return "ok";    }}

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

 

2、consumer 引用服务

2.1 引入依赖

                 
      
       org.apache.dubbo
                  
      
       dubbo-spring-boot-starter
                  
      
       2.7.3
              
             
                 
      
       org.apache.curator
                  
      
       curator-framework
                  
      
       4.2.0
              
             
                 
      
       org.apache.curator
                  
      
       curator-recipes
                  
      
       4.2.0
              
             
     
             
                 
      
       org.apache.zookeeper
                  
      
       zookeeper
                  
      
       3.5.5
                  
                      
                           
        
         org.slf4j
                            
        
         slf4j-log4j12
                        
                       
                           
        
         log4j
                            
        
         log4j
                        
                   
              
     

2.2 application.properties

dubbo.application.name=consumerdubbo.registry.address=zookeeper://192.168.1.101:2181server.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;@Servicepublic 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)@SpringBootTestpublic class ConsumerApplicationTests {    @Autowired    private ConsumerService consumerService;    @Test    public void contextLoads() {        consumerService.test();    }}

　　

2.6 补充目录结构