• 三个类：

    ServiceAProvider

    ServiceBProvider

    ServiceConsumer

    其中

    ServiceAProvider提供的服务名service-A，指向IP为192.168.58.130

    ServiceBProvider提供的服务名service-A，指向IP为192.168.58.131

    当有消费者请求时，随机地选取service-A列表的服务器提供服务

    ServiceConsumer 为消费者类

    依赖：

     

    view source print ?
    01. <dependency>
    02. <groupId>org.apache.zookeeper</groupId>
    03. <artifactId>zookeeper</artifactId>
    04. <version>3.4.5-cdh5.1.0</version>
    05. </dependency>
    06. <dependency>
    07. <groupId>org.apache.helix</groupId>
    08. <artifactId>helix-core</artifactId>
    09. <version>0.6.4</version>
    10. </dependency>


     

    github源码下载地址：

    https://github.com/Bellonor/myhadoop2.x/tree/master/myhadoop2.x/src/main/java/com/jamesfen/zookeeper

    详见下面的代码：

    服务提供者ServiceAProvider类的源码为：

     

    view source print ?
    01. package com.jamesfen.zookeeper;
    02. import java.net.InetAddress;
    03. import org.I0Itec.zkclient.ZkClient;
    04. public class ServiceAProvider {
    05.  
    06. private String serviceName = "service-A";
    07.  
    08. //向zookeeper注册服务
    09. public void init() throws Exception{
    10. String serverList = "192.168.58.11:2181";
    11. String PATH ="/configcenter";//根节点路径
    12. ZkClient zkClient = new ZkClient(serverList);
    13. boolean rootExists = zkClient.exists(PATH);
    14. if(!rootExists){
    15. zkClient.createPersistent(PATH);
    16. }
    17. //判断是否存在，不存在则创建服务节点
    18. boolean serviceExists = zkClient.exists(PATH + "/" + serviceName);
    19. if(!serviceExists){
    20. zkClient.createPersistent(PATH + "/" + serviceName);
    21. }
    22.  
    23. //註冊當前服務
    24. InetAddress addr =InetAddress.getLocalHost();
    25. //String ip= addr.getHostAddress().toString();
    26. String ip = "192.168.58.130";
    27.  
    28. //創建當前服務器節點
    29. zkClient.createEphemeral(PATH + "/" + serviceName + "/" + ip);
    30.  
    31. System.out.println("提供的服务节点名称为："+PATH + "/" + serviceName + "/" + ip);
    32. }
    33. //提供服务
    34. public void provide(){
    35.  
    36. }
    37. public static void main(String[]args) throws Exception {
    38. ServiceAProvider service = new ServiceAProvider();
    39. service.init();
    40.  
    41. Thread.sleep(1000*60*60*24);
    42. }
    43.  
    44. }

    服务提供者ServiceBProvider类源码为

     

     

    view source print ?
    01. package com.jamesfen.zookeeper;
    02. import java.net.InetAddress;
    03. import org.I0Itec.zkclient.ZkClient;
    04. public class ServiceBProvider {
    05. //服务名仍然为 A,这样是为了，一个服务名有两个台机器在服务，才能做负载均衡.
    06. private String serviceName = "service-A";
    07.  
    08. //向zookeeper注册服务
    09. public void init() throws Exception{
    10. String serverList = "192.168.58.11:2181";
    11. String PATH ="/configcenter";//根节点路径
    12. ZkClient zkClient = new ZkClient(serverList);
    13. boolean rootExists = zkClient.exists(PATH);
    14. if(!rootExists){
    15. zkClient.createPersistent(PATH);
    16. }
    17.  
    18. boolean serviceExists = zkClient.exists(PATH + "/" + serviceName);
    19. if(!serviceExists){
    20. zkClient.createPersistent(PATH + "/" + serviceName);//創建服務節點
    21. }
    22.  
    23. //註冊當前服務
    24. InetAddress addr =InetAddress.getLocalHost();
    25. //String ip= addr.getHostAddress().toString();
    26. String ip = "192.168.58.131";
    27.  
    28. //創建當前服務器節點
    29. zkClient.createEphemeral(PATH + "/" + serviceName + "/" + ip);
    30.  
    31. System.out.println("提供的服务节点名称为："+PATH + "/" + serviceName + "/" + ip);
    32. }
    33. //提供服务
    34. public void provide(){
    35.  
    36. }
    37. public static void main(String[]args) throws Exception {
    38. ServiceBProvider service = new ServiceBProvider();
    39. service.init();
    40.  
    41. Thread.sleep(1000*60*60*24);
    42. }
    43.  
    44. }

    消费者类源码为：

     

     

    view source print ?
    01. package com.jamesfen.zookeeper;
    02. import java.util.ArrayList;
    03. import java.util.List;
    04. import java.util.Random;
    05. import org.I0Itec.zkclient.IZkChildListener;
    06. import org.I0Itec.zkclient.ZkClient;
    07. public class ServiceConsumer {
    08.  
    09. private List<String> serverList = new ArrayList<String>();
    10.  
    11. private String serviceName ="service-A";
    12.  
    13. //初始化服务地址信息
    14. public void init(){    
    15. String zkServerList ="192.168.58.11:2181";
    16. String SERVICE_PATH="/configcenter/"+serviceName;//服务节点路径
    17. ZkClient zkClient = new ZkClient(zkServerList);
    18.  
    19. boolean serviceExists =zkClient.exists(SERVICE_PATH);
    20. if(serviceExists){
    21. serverList =zkClient.getChildren(SERVICE_PATH);
    22. }else{
    23. throw new RuntimeException("service not exist!");
    24. }
    25.  
    26. //注册事件监听
    27. zkClient.subscribeChildChanges(SERVICE_PATH,new IZkChildListener(){
    28. //@Override
    29. public void handleChildChange(String parentPath, List<String> currentChilds)throws Exception{
    30. serverList = currentChilds;
    31. }     
    32. });
    33. }
    34.  
    35.  
    36. //消费服务
    37. public void consume(){
    38. //通过负责均衡算法，得到一台服务器进行调用
    39. int index = getRandomNum(0,1);     
    40. System.out.println("调用" + serverList.get(index)+"提供的服务：" + serviceName);
    41. }
    42.  
    43. public int getRandomNum(int min,int max){ 
    44. Random rdm = new Random(); 
    45. return rdm.nextInt(max-min+1)+min;
    46. } 
    47.  
    48. public static void main(String[] args)throws Exception {
    49. ServiceConsumer consumer = new ServiceConsumer();  
    50.  
    51. consumer.init();
    52. consumer.consume();
    53.  
    54. Thread.sleep(1000*60*60*24);
    55. }
    56.  
    57. }

     

Logo
向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

ELK实现containerd的容器日志采集展示【基于logging的全栈监测】

企业级ELK Stack构建介绍

avatar 云原生

深入理解 Mocha 测试框架：从零实现一个 Mocha

前言什么是自动化测试自动化测试在很多团队中都是Devops环节中很难执行起来的一个环节，主要原因在于测试代码的编写工作很难抽象，99%的场景都需要和业务强绑定，而且写测试代码的编写工作量往往比编写实际业务代码的工作量更多。在一些很多业务场景中投入产出比很低，适合写自动化测试的应该是那些中长期业务以及一些诸如组件一样的基础库。自动化测试是个比较大的概念，其中分类也比较多，比如单元测试，端对端测试，集

avatar 云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...

avatar 云原生