Zookeeper 服务注册与发现

分手后的思念是犯贱 2022-12-29 04:41 215阅读 0赞

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

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

*  1-Zookeeper 概述
 *  2-Zookeeper 服务注册
 *   *  2.1-提供者服务 cloud-provider-payment8004
     *  2.2-消费者服务 cloud-consumerzk-order80

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

# 1-Zookeeper 概述 #

Eureka 停止更新了怎么办：[https://github.com/Netflix/eureka/wiki][https_github.com_Netflix_eureka_wiki]

SpringCloud 整合 Zookeeper 代替 Eureka。Zookeeper 是一个分布式协调工具，可以实现注册中心功能。

Zookeeper 服务器取代 Eureka 服务器，Zookeeper 作为服务注册中心。

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

# 2-Zookeeper 服务注册 #

关闭 Linux 服务器防火墙后启动 Zookeeper 服务器（[Zookeeper 单机模式 安装][Zookeeper _]）。  
![在这里插入图片描述][20210114112731779.png]

## 2.1-提供者服务 cloud-provider-payment8004 ##

**a、右击父工程 mscloud，新建子模块 cloud-provider-payment8004**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3loajE5OTIwNDE3_size_16_color_FFFFFF_t_70]  
**b、修改子模块 cloud-provider-payment8004 中 pom.xml**

<?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">
        <modelVersion>4.0.0</modelVersion>
    
        <parent>
            <artifactId>cloud2020</artifactId>
            <groupId>com.atguigu.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
    
        <artifactId>cloud-provider-payment8004</artifactId>
    
        <dependencies>
            <dependency>
                <groupId>com.atguigu.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-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-zookeeper-discovery</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>

**c、修改子模块 cloud-provider-payment8004，目录 /src/main/resources 中新建 application.yml**

server:
      port: 8004
    
    spring:
      application:
        name: cloud-provider-payment
      cloud:
        zookeeper:
          connect-string: 192.168.49.129:2181

**d、修改子模块 cloud-provider-payment8004，目录 /src/main/java 中新建包 com.atguigu.springcloud**

**e、修改子模块 cloud-provider-payment8004，包 com.atguigu.springcloud 中新建启动类 PaymentMain8004.java**

package com.atguigu.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    public class PaymentMain8004 {
        public static void main(String[] args) {
            SpringApplication.run(PaymentMain8004.class, args);
        }
    }

**f、修改子模块 cloud-provider-payment8004，目录 /src/main/java 中新建包 com.atguigu.springcloud.controller**

**g、修改子模块 cloud-provider-payment8004，包 com.atguigu.springcloud.controller 中新建 PaymentController.java**

package com.atguigu.springcloud.controller;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.UUID;
    
    @RestController
    @Slf4j
    public class PaymentController {
        @Value("${server.port}")
        private String serverPort;
    
        @GetMapping(value = "/payment/zk")
        public String paymentzk() {
            return "springcloud with zookeeper:" + serverPort + "\t" + UUID.randomUUID().toString();
        }
    }

**h、测试子模块 cloud-provider-payment8004**

*  启动子模块 cloud-provider-payment8004
    
    若 Zookeeper 版本 jar 有冲突：
    
        <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>
        </dependency>
 *  [http://localhost:8004/payment/zk][http_localhost_8004_payment_zk]  
    ![在这里插入图片描述][20210114113826446.png]
 *  `./bin/zkCli.sh`  
    ![在这里插入图片描述][20210114114052695.png]  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3loajE5OTIwNDE3_size_16_color_FFFFFF_t_70 1]
 *  `get /services/cloud-provider-payment/9c6037a4-61d6-49d2-a390-a5ee91aa17f3`  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3loajE5OTIwNDE3_size_16_color_FFFFFF_t_70 2]  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3loajE5OTIwNDE3_size_16_color_FFFFFF_t_70 3]

**Zookeeper 服务节点是临时节点还是持久节点？**

**是临时节点**

## 2.2-消费者服务 cloud-consumerzk-order80 ##

**a、右击父工程 mscloud，新建子模块 cloud-consumerzk-order80**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3loajE5OTIwNDE3_size_16_color_FFFFFF_t_70 4]  
**b、修改子模块cloud-consumerzk-order80 中 pom.xml**

<?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">
        <modelVersion>4.0.0</modelVersion>
        
        <parent>
            <artifactId>cloud2020</artifactId>
            <groupId>com.atguigu.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
    
        <artifactId>cloud-consumerzk-order80</artifactId>
    
        <dependencies>
            <dependency>
                <groupId>com.atguigu.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-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-zookeeper-discovery</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>

**c、修改子模块 cloud-consumerzk-order80，目录 /src/main/resources 中新建 application.yml**

server:
      port: 80
    
    spring:
      application:
        name: cloud-consumer-order
      cloud:
        zookeeper:
          connect-string: 192.168.49.129:2181

**d、修改子模块 cloud-consumerzk-order80，目录 /src/main/java 中新建包 com.atguigu.springcloud**

**e、修改子模块 cloud-consumerzk-order80，包 com.atguigu.springcloud 中新建启动类 OrderZKMain80.java**

package com.atguigu.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    public class OrderZKMain80 {
        public static void main(String[] args) {
            SpringApplication.run(OrderZKMain80.class,args);
        }
    }

**f、修改子模块 cloud-consumer-order80，目录 /src/main/java 中新建包 com.atguigu.springcloud.config**

**g、修改子模块 cloud-consumer-order80，包 com.atguigu.springcloud.config 中新建 ApplicationContextConfig.java**

package com.atguigu.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;
    
    @Configuration
    public class ApplicationContextConfig {
        @Bean
        @LoadBalanced
        public RestTemplate getRestTemplate() {
            return new RestTemplate();
        }
    }

**h、修改子模块 cloud-consumerzk-order80，目录 /src/main/java 中新建包 com.atguigu.springcloud.controller**

**i、修改子模块 cloud-consumerzk-order80，包 com.atguigu.springcloud.controller 中新建 OrderZKController.java**

package com.atguigu.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;
    
    @RestController
    @Slf4j
    public class OrderZKController {
        public static final String INVOME_URL = "http://cloud-provider-payment";
    
        @Resource
        private RestTemplate restTemplate;
    
        @GetMapping("/consumer/payment/zk")
        public String payment() {
            String result = restTemplate.getForObject(INVOME_URL + "/payment/zk", String.class);
            return result;
        }
    }

**j、测试子模块 cloud-consumerzk-order80**

*  启动子模块 cloud-provider-payment8004
    
    若 Zookeeper 版本 jar 有冲突：
    
        <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>
        </dependency>
 *  [http://localhost:8004/payment/zk][http_localhost_8004_payment_zk]  
    ![在这里插入图片描述][20210115094622938.png]
 *  启动子模块 cloud-consumerzk-order80
 *  [http://localhost/consumer/payment/zk][http_localhost_consumer_payment_zk]  
    ![在这里插入图片描述][20210115094653551.png]
 *  `./bin/zkCli.sh`  
    ![在这里插入图片描述][20210114114052695.png]  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3loajE5OTIwNDE3_size_16_color_FFFFFF_t_70 5]

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

[https_github.com_Netflix_eureka_wiki]: https://github.com/Netflix/eureka/wiki
[Zookeeper _]: https://hjyang.blog.csdn.net/article/details/68926984
[20210114112731779.png]: /images/20221120/b97061a3c41a4fe78704c6616c0c5f22.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3loajE5OTIwNDE3_size_16_color_FFFFFF_t_70]: /images/20221120/c69688bc6929422e8c8184b3a8233e5f.png
[http_localhost_8004_payment_zk]: http://localhost:8004/payment/zk
[20210114113826446.png]: /images/20221120/8c54ee7880074e0c99571c25c370cbcb.png
[20210114114052695.png]: /images/20221120/332264012bd743fb918cf6a355de89cd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3loajE5OTIwNDE3_size_16_color_FFFFFF_t_70 1]: /images/20221120/34b68f25694b4c138a8aa9175cb04668.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3loajE5OTIwNDE3_size_16_color_FFFFFF_t_70 2]: /images/20221120/d8c9a73b511d47ca947573f8b71e71eb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3loajE5OTIwNDE3_size_16_color_FFFFFF_t_70 3]: /images/20221120/8ad53b76848d4c49b9dee10527d5019b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3loajE5OTIwNDE3_size_16_color_FFFFFF_t_70 4]: /images/20221120/66bcb3f8598d4354b1ecc8eeb27590b7.png
[20210115094622938.png]: /images/20221120/19f5bfcbafe84bfa957b8e5b3e0f9fba.png
[http_localhost_consumer_payment_zk]: http://localhost/consumer/payment/zk
[20210115094653551.png]: /images/20221120/ea76391e48a54aca8bafb32bf4e9f28f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3loajE5OTIwNDE3_size_16_color_FFFFFF_t_70 5]: /images/20221120/fa33aaf3f31946d2b80dd625e8dd6630.png