SpringCloud H版系列3--Zookeeper服务注册与发现

古城微笑少年丶 2022-08-28 13:46 130阅读 0赞

书接上文（链接: [SpringCloud H版系列2–Eureka服务注册与发现以及Eureka集群搭建][SpringCloud H_2_Eureka_Eureka]）  
利用Zookeeper作为注册中心替代Eureka。创建cloud

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

*  一、Eureka VS Zookeeper
 *   *  1.1. Eureka保证AP
     *  1.2. Zookeeper保证CP
     *  1.3. 为什么用Eureka
 *  二、cloud-provider-payment8004服务提供者
 *  三、cloud-consumerzk-order80服务消费者
 *  四、测试验证
 *   *  4.1 启动Zookeeper服务
     *  4.2 访问8004和80接口

# 一、Eureka VS Zookeeper #

## 1.1. Eureka保证AP ##

Eureka服务器节点之间是对等的，只要有一个节点在，就可以正常提供服务。

Eureka客户端的所有操作可能需要一段时间才能在Eureka服务器中反映出来，随后在其他Eureka客户端中反映出来。也就是说，客户端获取到的注册信息可能不是最新的，它并不保证强一致性

## 1.2. Zookeeper保证CP ##

Zookeeper集群中有一个Leader，多个Follower。Leader负责写，Follower负责读，ZK客户端连接到任何一个节点都是一样的，写操作完成以后要同步给所有Follower以后才会返回。如果Leader挂了，那么重新选出新的Leader，在此期间服务不可用。

## 1.3. 为什么用Eureka ##

分布式系统大都可以归结为两个问题：数据一致性和防止单点故障。而作为注册中心的话，即使在一段时间内不一致，也不会有太大影响，所以在A和C之间选择A是比较适合该场景的。

# 二、cloud-provider-payment8004服务提供者 #

![在这里插入图片描述][08a47d5ef22749a8b63ca5edc8a28b6a.png]  
pom.xml

<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.6</version>
            </dependency>

application.yml

server:
      port: 8004
    
    # 服务别名---zookeeper注册中心名称
    spring:
      application:
        name: cloud-provider-payment
      cloud:
        zookeeper:
          connect-string: 192.168.153.101:2181
          max-retries: 10
      datasource:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: org.gjt.mm.mysql.Driver
        url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=false
        username: root
        password: 1234

PaymentMain8004

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 { 
        //共同点：都能让注册中心发现，扫描到该服务。
        /*不同点：@EnableEurekaClient只适用于Eureka作为注册中心， 场景单一； @EnableDiscoveryClient 可以是其它注册中心 */
        public static void main(String[] args) { 
            SpringApplication.run(PaymentMain8004.class,args);
        }
    }

PaymentController

package com.atguigu.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;
    
    @RestController
    @Slf4j
    public class PaymentController { 
        @Value("${server.port}")
        private String serverPort;
    
        @RequestMapping(value = "/payment/zk")
        public String paymentzk(){ 
            return "springcloud with zookeeper: " + serverPort + "\t" + UUID.randomUUID().toString();
        }
    }

# 三、cloud-consumerzk-order80服务消费者 #

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

application.yml

server:
      port: 80
    
    # 服务别名---zookeeper注册中心名称
    spring:
      application:
        name: cloud-consumer-order
      cloud:
        zookeeper:
          connect-string: 192.168.153.101:2181
          max-retries: 10
      datasource:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: org.gjt.mm.mysql.Driver
        url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=false
        username: root
        password: 1234

OrderZKMain80

OrderZKController

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 INVOKE_URL = "http://cloud-provider-payment";
        @Resource
        private RestTemplate restTemplate;
    
        @GetMapping("/consumer/payment/zk")
        public String paymentInfo(){ 
            String result = restTemplate.getForObject(INVOKE_URL+"/payment/zk",String.class);
            return result;
        }
    }

ApplicationContextConfig

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 restTemplate(){ 
            return new RestTemplate();
        }
    
    }

# 四、测试验证 #

## 4.1 启动Zookeeper服务 ##

本机Zookeeper安装在虚拟机CentOS上，先关闭防火墙

service iptables stop

进入/root/zookeeper-3.4.6/bin，执行如下命令才会启动zookeeper

./zkServer.sh start

![在这里插入图片描述][498d554973fd46278cddd6a57d3fdf6b.png]  
执行启动客户端

./zkCli.sh -server localhost:2181

![在这里插入图片描述][ce3cdcdba7994436942ece3b7047be6f.png]  
启动8004微服务，进入ls /根目录，进入ls /services可以看到有新增的微服务名cloud-provider-payment，默认创建的是临时节点  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oeS6Jmr6Jmrfg_size_20_color_FFFFFF_t_70_g_se_x_16]

## 4.2 访问8004和80接口 ##

访问8004接口http://localhost:8004/payment/zk  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oeS6Jmr6Jmrfg_size_20_color_FFFFFF_t_70_g_se_x_16 1]  
访问80接口http://localhost:80/consumer/payment/zk  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oeS6Jmr6Jmrfg_size_20_color_FFFFFF_t_70_g_se_x_16 2]

[SpringCloud H_2_Eureka_Eureka]: https://blog.csdn.net/jike11231/article/details/119977764
[08a47d5ef22749a8b63ca5edc8a28b6a.png]: /images/20220828/3e4593567d844d7b83bdb6ebe250a08c.png
[716905fa96184494bf991dfd8636f4f3.png]: /images/20220828/09319ca9950c43b8a1dbe247d86c855d.png
[498d554973fd46278cddd6a57d3fdf6b.png]: /images/20220828/716a4bf86f8248c6ba00ddeae507b289.png
[ce3cdcdba7994436942ece3b7047be6f.png]: /images/20220828/00773f814ea7470ea59109cb164d97f5.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oeS6Jmr6Jmrfg_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/7c6dc1bee7ac4cffa0dd9284a8f7fd20.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oeS6Jmr6Jmrfg_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/ef2cbc478c0842e6ae15520b51f15301.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5oeS6Jmr6Jmrfg_size_20_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/c777f927dbfc42f99f6121e4aa065fca.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5oeS6Jmr6Jmrfg==,size_20,color_FFFFFF,t_70,g_se,x_16