Spring Cloud（四）：Zookeeper服务注册与发现

布满荆棘的人生 2022-10-23 08:28 51阅读 0赞

## 1. Zookeeper服务注册与发现 ##

### 1.1 使用docker安装zookeeper ###

docker安装教程请查看这篇博客：[docker安装教程][docker]

*  下载镜像

docker pull zookeeper:3.4.9

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70]

*  启动容器并添加映射：

docker run --privileged=true -d --name zookeeper --publish 2181:2181  -d zookeeper:3.4.9

*  查看是否启动  
    ![在这里插入图片描述][20210309212848328.png]

### 1.2 SpringCloud整合Zookeeper代替Eureka ###

zookeeper是一个分布式协调工具，可以实现注册中心功能  
关闭Linux服务器防火墙后启动zookeeper服务器  
zookeeper服务器取代Eureka服务器，zk作为服务注册中心

**服务提供者**

*  新建 cloud-provider-payment8004 模块
 *  改pom

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>spring-cloud-demo</artifactId>
            <groupId>com.lele.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>cloud-provider-payment8004</artifactId>
    
        <dependencies>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.lele.springcloud</groupId>
                <artifactId>cloud-api-commons</artifactId>
                <version>${project.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
    
    
    
    
    
    
    
    
    
    
    
    
    
    
    
    
    
    
    
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
    
        </dependencies>
    
    </project>

*  建 yml

#8004表示注册到zookeeper服务器的支付服务提供者端口号
    server:
      port: 8004
    
    #服务别名----注册zookeeper到注册中心名称
    spring:
      application:
        name: cloud-provider-payment
      cloud:
        zookeeper:
          connect-string: localhost:2181  #zookeeper所在的主机ip地址

*  主启动类

package com.lele.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    /**
     * @author: lele
     * @date: 2021/3/9 22:24
     * @description:
     */
    @SpringBootApplication
    @EnableDiscoveryClient
    public class PaymentMain8004 {
        
        public static void main(String[] args) {
        
            SpringApplication.run(PaymentMain8004.class, args);
        }
    }

*  Controller

package com.lele.springcloud.controller;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.UUID;
    
    /**
     * @author: lele
     * @date: 2021/3/10 7:00
     * @description:
     */
    @RestController
    @Slf4j
    public class PaymentController {
        
    
        @Value("${server.port")
        private String serverPort;
    
        @RequestMapping(value = "/payment/zk")
        public String paymentzk() {
        
            return "spring cloud with zookeeper: " +serverPort+"\t"+ UUID.randomUUID().toString();
        }
    }

*  启动8004注册进zookeeper  
    ![在这里插入图片描述][20210310071127162.png]
 *  解决zookeeper版本jar包冲突问题  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 1]
 *  修改pom

<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>3.4.9</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.slf4j</groupId>
                        <artifactId>slf4j-log4j12</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 2]

*  访问：http://localhost:8003/payment/zk  
    ![在这里插入图片描述][20210310213215492.png]
 *  验证测试：

docker exec -it 容器id /bin/bash
    cd bin/
    zkCli.sh
    
    ls /
    ls /services

![在这里插入图片描述][20210310213715292.png]  
![在这里插入图片描述][20210310213738155.png]  
这里node的名字就是yml配置的springapplication的名字

*  验证测试2：

ls /services/cloud-provider-payment

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

get /services/cloud-provider-payment/a855f6d9-cb61-478e-919d-660d62e9f951

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 3]  
思考：  
服务节点是临时节点还是持久节点:

是临时节点。

**服务消费者**

*  新建 cloud-consumerzk-order80 模块
 *  改pom

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>spring-cloud-demo</artifactId>
            <groupId>com.lele.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>cloud-consumerzk-order80</artifactId>
    
        <dependencies>
            
            <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>3.4.9</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.slf4j</groupId>
                        <artifactId>slf4j-log4j12</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
    
            
            <dependency>
                <groupId>com.lele.springcloud</groupId>
                <artifactId>cloud-api-commons</artifactId>
                <version>${project.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
    </project>

*  yml

server:
      port: 80
    
    spring:
      application:
        name: cloud-consumer-order
      cloud:
      #注册到zookeeper地址
        zookeeper:
          connect-string: localhost:2181  #zookeeper所在的主机ip地址

*  主启动类

package com.lele.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    /**
     * @author: lele
     * @date: 2021/3/10 22:16
     * @description:
     */
    @SpringBootApplication
    @EnableDiscoveryClient
    public class OrderZKMain80 {
        
        public static void main(String[] args) {
        
            SpringApplication.run(OrderZKMain80.class, args);
        }
    }

*  配置RestTemplate：

package com.lele.springcloud.config;
    
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
    
    /**
     * @author: lele
     * @date: 2021/3/10 22:21
     * @description:
     */
    @Configuration
    public class ApplicationContextConfig {
        
        @Bean
        @LoadBalanced
        public RestTemplate getRestTemplate() {
        
            return new RestTemplate();
        }
    }

*  controller

package com.lele.springcloud.controller;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    import javax.annotation.Resource;
    
    /**
     * @author: lele
     * @date: 2021/3/10 22:26
     * @description:
     */
    @RestController
    @Slf4j
    public class OrderZKController {
        
    
        public static final String INVOKE_URL = "http://cloud-provider-payment";
    
        @Resource
        private RestTemplate restTemplate;
    
        @GetMapping(value = "/consumer/payment/zk")
        public String paymentInfo() {
        
            String result = restTemplate.getForObject(INVOKE_URL+"/payment/zk", String.class);
            return result;
        }
    }

启动80注册进zookeeper  
![在这里插入图片描述][20210310223525783.png]

*  访问：  
    http://localhost/consumer/payment/zk  
    ![在这里插入图片描述][20210310223628948.png]

[docker]: https://blog.csdn.net/houwanle/article/details/111462117
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70]: /images/20221023/5bf5a721b4e44b42a29e25e67483b174.png
[20210309212848328.png]: /images/20221023/b390baf0f58c4c158ec6ce9e7a22b8f2.png
[20210310071127162.png]: /images/20221023/2280ba84ec20458fac4f27312552729c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 1]: /images/20221023/ba1e20ce219046c6abd788102331ceaf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 2]: /images/20221023/f2a691ad25f641e3b0196989a635f51c.png
[20210310213215492.png]: /images/20221023/bf68ee82c3e9488ca4b43b7201dbef33.png
[20210310213715292.png]: /images/20221023/6f0f743ae8dd4d5db3de5717633b96c6.png
[20210310213738155.png]: /images/20221023/a39215f5ab274cf2b61f8b3efa6485c3.png
[20210310214150445.png]: /images/20221023/c9f86f81ccf64ceba1347cafd6bf4ae4.png
[20210310214255344.png]: /images/20221023/b8d3edaf855f4af4a0311c36b65e16bf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 3]: /images/20221023/5ff4240624954d9f85d676fe6ef33429.png
[20210310223525783.png]: /images/20221023/0f4f1e839a974d62861dd00542d9e453.png
[20210310223628948.png]: /images/20221023/3a03359b62394132b3eb4be4ab4bf004.png