Zookeeper典型应用场景高可用的服务注册与消费（四）

小鱼儿 2024-04-17 05:52 29阅读 0赞

## 1、项目结构 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70]  
pom文件：

<parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.4.RELEASE</version>
            <relativePath/> 
        </parent>
    
        <dependencies>
            
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.10</version>
            </dependency>
            
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.4.5</version>
            </dependency>
            <dependency>
                <groupId>org.apache.commons</groupId>
                <artifactId>commons-lang3</artifactId>
                <version>3.8</version>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <version>1.18.8</version>
            </dependency>
        </dependencies>

## 2、生产者 ##

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

生产者把当前ip和端口注册到zk上

2.1、pom文件

<dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
        </dependencies>

2.2、application.yml

server:
      port: 9000
    zookeeper:
      ip: 192.168.92.39
      timeout: 10000

2.3、ZookeeperProviderConfig

@Configuration
    public class ZookeeperProviderConfig implements InitializingBean {
    
        /***
         *功能描述  本地服务端口
         */
        @Value("${server.port}")
        private Integer port;
    
        /***
         *功能描述 zk ip
         */
        @Value("${zookeeper.ip}")
        private String zkAddress;
    
        /***
         *功能描述 超时时间
         */
        @Value("${zookeeper.timeout}")
        private Integer zkTimeout;
    
        /***
         *功能描述  zk注册的服务节点
         */
        private static final String BASE_SERVICE = "/services";
        private static final String PRODUCER_SERVICE = "/producer";
    
        @Override
        public void afterPropertiesSet() throws Exception {
            //1、获取本地地址
            String hostAddress = InetAddress.getLocalHost().getHostAddress();
            //2、创建Zookeeper
            ZkClient zkClient = new ZkClient(zkAddress, zkTimeout);
            //3、判断父亲节点是否存在，如果不存在创建
            if (!zkClient.exists(BASE_SERVICE)) {
                zkClient.createPersistent(BASE_SERVICE);
            }
            //4、把当前服务注册到zk中
            System.out.println(serverUrl);
            zkClient.createEphemeralSequential(BASE_SERVICE + PRODUCER_SERVICE, serverUrl);
    
        }
    }

2.4、controller

@RestController
    @RequestMapping("/zk")
    public class ProviderController {
    
        /***
         *功能描述  本地服务端口
         */
        @Value("${server.port}")
        private Integer port;
    
        @GetMapping("/hello")
        public String hello() {
    
            return "provider " + port + " say hello";
        }
    
    }

2.5、启动生产者，并且在idea复制一份，把端口改成9001启动  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 2]  
1）访问9000,9001端口  
![在这里插入图片描述][20190824151129521.png]  
![在这里插入图片描述][20190824151134957.png]  
2）打开zk：  
![在这里插入图片描述][20190824151215347.png]

## 3、消费者 ##

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

消费者用于监听生产者提供服务的根节点，如果根节点发生了变化，及时更新服务列表

3.1、pom

3.2、yml

server:
      port: 8000
    zookeeper:
      ip: 192.168.92.39
      timeout: 10000

3.3、LoadBalance

public abstract class LoadBalance {
    
        /***
        *功能描述  服务列表
         */
        public volatile static List<String> SERVICE_LIST;
         
        /***
        *功能描述 获取一个服务
        */
        public abstract String choseServiceHost();
    }

3.4.、轮询

@Configuration
    public class LunXunBalance extends LoadBalance {
    
        private static Integer index = 0;
    
        /***
         *功能描述  如果服务列表不为空，就从服务列表获取一个url返回
         */
        @Override
        public String choseServiceHost() {
            if (!CollectionUtils.isEmpty(SERVICE_LIST)) {
                index++;
                if (index >= SERVICE_LIST.size()) {
                    index = 0;
                }
                return SERVICE_LIST.get(index);
            }
            return null;
        }
    }

3.5、ZookeeperCustomerConfig

@Configuration
    public class ZookeeperCustomerConfig {
    
        /***
         *功能描述 zk地址
         */
        @Value("${zookeeper.ip}")
        private String zkAddress;
    
        /***
         *功能描述 超时时间
         */
        @Value("${zookeeper.timeout}")
        private Integer zkTimeout;
    
        /***
         *功能描述  zk注册的服务节点
         */
        private static final String BASE_SERVICE = "/services";
    
    
        @Bean
        public ZkClient zkClient() {
            ZkClient zkClient = new ZkClient(zkAddress, zkTimeout);
            updateServerList(zkClient);
            zkClient.subscribeChildChanges(BASE_SERVICE, new ServerWatcher(zkClient));
            return zkClient;
        }
    
    
        /**
         * 功能描述 更新服务列表
         */
        private void updateServerList(ZkClient zkClient) {
            List<String> serverList = new ArrayList<>();
            try {
                //获取节点
                List<String> childrens = zkClient.getChildren(BASE_SERVICE);
                //获取节点的值
                for (String child : childrens) {
                    Object host = zkClient.readData(BASE_SERVICE + "/" + child);
                    serverList.add((String) host);
                }
                //把值赋给LoadBalance
                LoadBalance.SERVICE_LIST = serverList;
                System.out.println("服务列表已经更新:" + serverList);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 功能描述  监听子节点的变换
         *
         * @author Zrs
         * @date 2019/8/24
         * @return: ......
         */
        private class ServerWatcher implements IZkChildListener {
    
            private ZkClient zkClient;
    
            public ServerWatcher(ZkClient zkClient) {
                this.zkClient = zkClient;
            }
    
            @Override
            public void handleChildChange(String parentPath, List<String> currentChilds) throws Exception {
                updateServerList(zkClient);
            }
        }
    
    
    }

.3.6、RestConfig

@Configuration
    public class RestConfig {
    
        @Bean
        public RestTemplate restTemplate() {
    
            return new RestTemplate();
        }
    }

3.7、 CustomerController

@RestController
    @RequestMapping("/customer")
    public class CustomerController {
    
        @Resource
        private RestTemplate restTemplate;
    
        @Autowired
        private LoadBalance loadBalance;
    
        @RequestMapping("/hello")
        public String customer() {
            String url = loadBalance.choseServiceHost();
            String hello = restTemplate.getForObject("http://" + url + "/zk/hello/", String.class);
            return hello;
        }
    }

3.8、启动消费者者  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 4]

1）第一次访问controller

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

2）第二次访问controller  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 6]  
3）停掉9001端口的客户端  
![在这里插入图片描述][20190824152233208.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 7]  
4）再次访问url  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 8]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/0a7a3f6b2c2e4f6b893f2ef14a3e8a54.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/83906b5981f841aaba0662b4581bbcb9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/2c723ec35cc44dbfac866acd8ccc1ff2.png
[20190824151129521.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/fde63a37b8544f40be3ec316b6475d6a.png
[20190824151134957.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/35807cf2915942a2a5401bd8f1498471.png
[20190824151215347.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/bf9a503d5ce448deac7284369f9242a8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/b0ac7f4e4edd424dac91515511e64c56.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 4]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/ca86d4d7159d496dbc048afa11380961.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 5]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/05479882ac5643479ffb5f4333f60f12.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 6]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/aec2ec2ea7384b2f8e4561b776867084.png
[20190824152233208.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/2f230a7cd2564298914b700214e1a1a2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 7]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/8a899de912984f569dfec392daefcb84.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTI1OTk5_size_16_color_FFFFFF_t_70 8]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/11/d0cc08ed2b3c4e72a120dae5c57cd00a.png