zookeeper实战之服务注册与发现

CoreDump 发布于2019-08-16 18:28 / 3293人阅读

摘要：应用场景回顾下应用场景数据发布与订阅服务注册与发现分布式锁分布式队列选举配置中心命名服务负载均衡实现服务注册与发现服务注册与发现再来看看在服务注册与发现中的应用代码实现逻辑服务注册创建的临时的有序节点临时的话断开连接了可以监听到有序节点创

zookeeper应用场景

回顾下zk应用场景：

数据发布与订阅

服务注册与发现

分布式锁

分布式队列

master选举

配置中心

命名服务

负载均衡

zookeeper实现服务注册与发现

服务注册与发现

再来看看zk在服务注册与发现中的应用：

代码实现逻辑：

服务注册：

public class ServiceRegister {

    private  static final String BASE_SERVICES = "/services";
    private static final String  SERVICE_NAME="/products";

    public static  void register(String address,int port) {
        try {
            ZooKeeper zooKeeper = new ZooKeeper("localhost:2181",5000,(watchedEvent)->{});
            Stat exists = zooKeeper.exists(BASE_SERVICES + SERVICE_NAME, false);
            if(exists==null) {
                zooKeeper.create(BASE_SERVICES + SERVICE_NAME,"".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
            }
            String server_path = address+":"+port;
            //创建的临时的有序节点
            //临时的话断开连接了可以监听到,有序节点创建代表每一个节点否则相同节点名称无法创建
            zooKeeper.create(BASE_SERVICES + SERVICE_NAME+"/child",server_path.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.EPHEMERAL_SEQUENTIAL);
            System.out.println("产品服务注册成功");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

发现服务：

    public class InitListener implements ServletContextListener {

    private  static final String BASE_SERVICES = "/services";
    private static final String  SERVICE_NAME="/products";

    private ZooKeeper zooKeeper;

    @Override
    public void contextInitialized(ServletContextEvent sce) {
        try {
             zooKeeper = new ZooKeeper("localhost:2181",5000,(watchedEvent)->{
                if(watchedEvent.getType() == Watcher.Event.EventType.NodeChildrenChanged  && watchedEvent.getPath().equals(BASE_SERVICES+SERVICE_NAME)) {
                    updateServiceList();
                }
            });

            updateServiceList();
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    private void updateServiceList() {
       try{
           List children = zooKeeper.getChildren(BASE_SERVICES  + SERVICE_NAME, true);
           List newServerList = new ArrayList();
           for(String subNode:children) {
               byte[] data = zooKeeper.getData(BASE_SERVICES  + SERVICE_NAME + "/" + subNode, false, null);
               String host = new String(data, "utf-8");
               System.out.println("host:"+host);
               newServerList.add(host);
           }
           //保存注册服务的ip端口信息，以供远程rpc调用
           LoadBalance.SERVICE_LIST = newServerList;
       }catch (Exception e) {
           e.printStackTrace();
       }
    } 
}

public abstract class LoadBalance {
    public volatile static List SERVICE_LIST;

    public abstract String choseServiceHost();

}

/**
 * 随机负载均衡算法
 */
public class RamdomLoadBalance extends LoadBalance {
    @Override
    public String choseServiceHost() {
        String result = "";
        if(!CollectionUtils.isEmpty(SERVICE_LIST)) {
            int index = new Random().nextInt(SERVICE_LIST.size());
            result = SERVICE_LIST.get(index);
        }
        return result ;
    }
}

再讲讲几个关键点
1.注册服务的时候需要创建临时节点,断开连接的时候也就是服务端挂了后节点删除可监听到
2.注册服务的时候创建的是有序节点,一般来说相同服务都是有几台机器的,创建顺序节点可区分多台机器的服务
3.发现服务的一端监听服务节点的子节点，有子节点被删除了或者有新子节点创建即重新发现服务可用的机器

dubbo中基于zk的服务注册与发现也是这个原理

GPU云服务器云服务器服务治理与发现 webrtc入门与实战 tensorflow入门与实战数据分析与实战

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/75152.html

超详细，新手都能看懂！使用SpringBoot+Dubbo 搭建一个简单的分布式服务

Github 地址：https://github.com/Snailclimb/springboot-integration-examples ，欢迎各位 Star。目录：使用 SpringBoot+Dubbo 搭建一个简单分布式服务实战之前，先来看几个重要的概念什么是分布式? 什么是 Duboo？ Dubbo 架构什么是 RPC？为什么要用 Dubbo？开始实战 1 ...

chengtao1633 2019-08-16 13:52 评论0 收藏0
2021 年最新基于 Spring Cloud 的微服务架构分析

摘要：是一个相对比较新的微服务框架，年才推出的版本虽然时间最短但是相比等框架提供的全套的分布式系统解决方案。提供线程池不同的服务走不同的线程池，实现了不同服务调用的隔离，避免了服务器雪崩的问题。通过互相注册的方式来进行消息同步和保证高可用。 Spring Cloud 是一个相对比较新的微服务框架，...

cikenerd 2021-11-19 09:40 评论0 收藏0
Dubbo 一篇文章就够了：从入门到实战

摘要：启动容器，加载，运行服务提供者。服务提供者在启动时，在注册中心发布注册自己提供的服务。注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。一为什么需要 dubbo 很多时候，其实我们使用这个技术的时候，可能都是因为项目需要，所以，我们就用了，但是，至于为什么我们需要用到这个技术，可能自身并不是很了解的，但是，其实了解技术的来由及背景知识，对...

tomener 2019-08-19 10:12 评论0 收藏0
微服务之eureka

摘要：服务器用作服务注册服务器。此时，这个节点对于新的服务还能提供注册服务，对于死亡的仍然保留，以防还有客户端向其发起请求。的构架保证了它能够成为发现服务。本帖最后由 yqw_gz_java 于 2019-8-15 14:26 编辑与ZooKeeper 一样eureka 都可以注册服务发现服务CAP定理在分布式系统领域有个著名的CAP定理（C-数据一致性；A-服务可用性；P-服务对网络分...

Dean 2019-08-19 10:32 评论0 收藏0