Spring Cloud 系列之注册中心 Zookeeper

水深无声 2022-11-22 00:11 134阅读 0赞

## 1.1 简介 ##

### 1.1.1 概述 ###

ZooKeeper 是一个分布式的，开放源码的分布式应用程序协调服务，是 Google 的 Chubby 一个开源的实现，是 Hadoop 和 Hbase 的重要组件。它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。ZooKeeper 的目标就是封装好复杂易出错的关键服务，将简单易用的接口和性能高效、功能稳定的系统提供给用户。ZooKeeper 包含一个简单的原语集，提供 Java 和 C 的接口。ZooKeeper 代码版本中，提供了分布式独享锁、选举、队列的接口。其中分布锁和队列有 Java 和 C 两个版本，选举只有 Java 版本。

![在这里插入图片描述][20201103142041592.jpg_pic_center]

### 1.1.2 安装 ###

♞ 先去 Apache 下载 [☞ Zookeeper][Zookeeper]  
  ♞ 将 Zookeeper 安装包上传到 Linux 服务器，需要事先安装 JDK  
  ♞ 使用 `tar -zxvf` 解压安装包，并进入解压目录  
  ♞ 使用 `mkdir data` 创建 data 目录  
  ♞ 进入 conf 目录 ，使用 `mv zoo_sample.cfg zoo.cfg` 把 zoo\_sample.cfg 改名为 zoo.cfg  
  ♞ 打开 zoo.cfg 将 dataDir 改为刚才新建的 data 目录  
  ♞ 进入 bin 目录，使用 `./zkServer.sh start` 启动， `./zkServer.sh stop` 停止，`./zkServer.sh status` 检查状态，`./zkCli.sh` 启动客户端

### 1.1.3 相关依赖 ###

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
    </dependency>

### 1.1.4 jar 包冲突 ###

在使用 Zookeeper 做注册中心时可能应为服务器上的 Zookeeper 版本与自己使用的版本不一致导致报错(一般体现为启动类错误)，此时我们就需要解决 jar 包冲突了。  
![在这里插入图片描述][20201103115035158.png]

<dependency>
    	<groupId>org.springframework.cloud</groupId>
    	<artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
    	<exclusions>
    		
    		<exclusion>
    			<groupId>org.apache.zookeeper</groupId>
    			<artifactId>zookeeper</artifactId>
    		</exclusion>
    	</exclusions>
    </dependency>
    
    <dependency>
    	<groupId>org.apache.zookeeper</groupId>
    	<artifactId>zookeeper</artifactId>
    	<version>x.x.x</version>
    </dependency>

## 1.2 Provider ##

### 1.2.1 配置文件 ###

server:
      port: 8093
    
    spring:
      application:
        name: ProviderServer
      cloud:
        zookeeper:
          # zookeeper 默认端口 2181
          connect-string: 106.52.175.xx:2181

### 1.2.2 启动类 ###

/** * Created with IntelliJ IDEA. * * @author Demo_Null * @date 2020/10/29 * @description 服务提供者启动类 */
    @SpringBootApplication
    @EnableDiscoveryClient // 一定要使用该注解
    public class ProviderZKApplication { 
        public static void main(String[] args) { 
            SpringApplication.run(ProviderZKApplication.class, args);
        }
    }

### 1.2.3 服务代码 ###

/** * Created with IntelliJ IDEA. * * @author Demo_Null * @date 2020/10/29 * @description */
    
    @RestController
    @RequestMapping("/provider")
    public class ProviderZKController { 
    
        @GetMapping("/get")
        public Object get() { 
            return "你已经消费了_zk";
        }
    }

### 1.2.4 查看服务 ###

启动 zookeeper 客户端，使用 `ls /` 可以看到有 services  
![在这里插入图片描述][20201103102214978.png]  
使用 `ls /services` 查看有哪些服务注册上来了  
![在这里插入图片描述][20201103102237666.png]  
继续使用 `ls /services/服务名` 获取该服务的流水号，流水号一致代表是一个服务。若服务在一定时间内未给 Zookeeper 服务响应，Zookeeper 会将其剔除，等到服务再次连上 Zookeeper 会认为是一个新的服务分配新的流水号。  
![在这里插入图片描述][20201103102302749.png]  
使用 `get /services/ProviderServer/6e0e0f01-8b5f-4c42-ac37-ad0595b428a0` 获取服务信息  
![在这里插入图片描述][2020110310211188.png]

## 1.3 Consumer ##

### 1.3.1 配置文件 ###

server:
      port: 80
    
    spring:
      application:
        name: ConsumerServer
      cloud:
        zookeeper:
          connect-string: 106.52.175.xx:2181

### 1.3.2 启动类 ###

/** * Created with IntelliJ IDEA. * * @author Demo_Null * @date 2020/10/29 * @description 消费者启动类 */
    @SpringBootApplication
    @EnableDiscoveryClient
    public class ConsumerApplication { 
        public static void main(String[] args) { 
            SpringApplication.run(ConsumerApplication.class, args);
        }
    }

### 1.3.3 服务代码 ###

/** * Created with IntelliJ IDEA. * * @author Demo_Null * @date 2020/10/29 * @description */
    @RestController
    @RequestMapping("/consumer")
    public class ConsumerController { 
    
        @Autowired
        private DiscoveryClient discoveryClient;
    
    
        @GetMapping("/go")
        public void go() { 
            List<ServiceInstance> providerServer = discoveryClient.getInstances("ProviderServer");
    
            if (0 == providerServer.size()) { 
                return;
            }
    
            ServiceInstance serviceInstance = providerServer.get(0);
            System.out.print(serviceInstance.getUri() + " --- ");
            String url = serviceInstance.getUri() + "/provider/get";
    
    
            RestTemplate restTemplate = new RestTemplate();
            String str = restTemplate.getForObject(url, String.class);
            System.out.println(str);
        }
    }

### 1.3.4 调用服务 ###

![在这里插入图片描述][20201103104157648.png]

## 1.4 集群 ##

### 1.4.1 Zookeeper 集群 ###

Zookeeper 集群中节点个数一般为奇数个(>=3)，若集群中 Master 挂掉，剩余节点个数在半数以上时，就可以推举新的主节点，继续对外提供服务。 由于在 Spring Cloud 中使用 Zookeeper 作为注册中心比较少，这里对于集群的搭建仅作简要描述。

#### ☞ zoo.cfg 中增加如下配置 ####

server.1=xxx.xxx.xxx.xxx:2888:3888
    server.2=xxx.xxx.xxx.xxx:2888:3888
    server.3=xxx.xxx.xxx.xxx:2888:3888

#### ☞ myid ####

在我们创建 data 目录中新建一个 myid 文件，在里面写 1/2/3 来表示自己是哪一个编号的机器。

#### ☞ 启动 ####

依次启动每个 Zookeeper 服务

### 1.4.2 Provider 集群 ###

#### ☞ 配置文件 ####

server:
      port: 8093
    
    spring:
      application:
        name: ProviderServer
      cloud:
        zookeeper:
          # zookeeper 默认端口 2181
          connect-string: 106.52.175.1:2181,106.52.175.2:2181,106.52.175.3:2181

### 1.4.2 Consumer 集群 ###

#### ☞ 配置文件 ####

server:
      port: 80
    
    spring:
      application:
        name: ConsumerServer
      cloud:
        zookeeper:
          # zookeeper 默认端口 2181
          connect-string: 106.52.175.1:2181,106.52.175.2:2181,106.52.175.3:2181

--------------------

[☞ 源码][Link 1]

[20201103142041592.jpg_pic_center]: /images/20221120/fe1714e609ef49e195ccef6c78c033d5.png
[Zookeeper]: https://www.apache.org/dyn/closer.lua/zookeeper/zookeeper-3.6.2/apache-zookeeper-3.6.2-bin.tar.gz
[20201103115035158.png]: /images/20221120/3193f388eba442288ca32c0367eea726.png
[20201103102214978.png]: /images/20221120/5df8a0efaa1b499ba7e6746467f48004.png
[20201103102237666.png]: /images/20221120/c56be878ae424cdd98b16775e6fd0ceb.png
[20201103102302749.png]: /images/20221120/fe9e374eb9b44833bdeb23329c4f4b57.png
[2020110310211188.png]: /images/20221120/97050ffbe99f413e8959fd241b3f07ca.png
[20201103104157648.png]: /images/20221120/25300e365abe4487abea196c75468337.png
[Link 1]: https://github.com/java-software/spring-cloud-zookeeper