`
liyonghui160com
  • 浏览: 774650 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

ZooKeeper示例 实时更新server列表

阅读更多

 

 

实现AppServer
AppServer的逻辑非常简单, 只须在启动时, 在zookeeper的"/sgroup"节点下新增一个子节点即可.

 

public class AppServer {   
    private String groupNode = "sgroup";   
    private String subNode = "sub";   
  
    /**  
     * 连接zookeeper  
     * @param address server的地址  
     */  
    public void connectZookeeper(String address) throws Exception {   
        ZooKeeper zk = new ZooKeeper("localhost:4180,localhost:4181,localhost:4182", 5000, new Watcher() {   
            public void process(WatchedEvent event) {   
                // 不做处理   
    }   
        });   
        // 在"/sgroup"下创建子节点   
        // 子节点的类型设置为EPHEMERAL_SEQUENTIAL, 表明这是一个临时节点, 且在子节点的名称后面加上一串数字后缀   
        // 将server的地址数据关联到新创建的子节点上   
        String createdPath = zk.create("/" + groupNode + "/" + subNode, address.getBytes("utf-8"),    
            Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);   
        System.out.println("create: " + createdPath);   
    }   
       
    /**  
     * server的工作逻辑写在这个方法中  
     * 此处不做任何处理, 只让server sleep  
     */  
    public void handle() throws InterruptedException {   
        Thread.sleep(Long.MAX_VALUE);   
    }   
       
    public static void main(String[] args) throws Exception {   
        // 在参数中指定server的地址   
        if (args.length == 0) {   
            System.err.println("The first argument must be server address");   
            System.exit(1);   
        }   
           
        AppServer as = new AppServer();   
        as.connectZookeeper(args[0]);   
           
        as.handle();   
    }   
}  

 


将其打成appserver.jar后待用, 生成jar时别忘了指定入口函数. 具体的教程请自行搜索.

 

实现AppClient
AppClient的逻辑比AppServer稍微复杂一些, 需要监听"/sgroup"下子节点的变化事件, 当事件发生时, 需要更新server列表.
注册监听"/sgroup"下子节点的变化事件, 可在getChildren方法中完成. 当zookeeper回调监听器的process方法时, 判断该事件是否是"/sgroup"下子节点的变化事件, 如果是, 则调用更新逻辑, 并再次注册该事件的监听.

 

 

public class AppClient {   
    private String groupNode = "sgroup";   
    private ZooKeeper zk;   
    private Stat stat = new Stat();   
    private volatile List<String> serverList;   
  
    /**  
     * 连接zookeeper  
     */  
    public void connectZookeeper() throws Exception {   
        zk = new ZooKeeper("localhost:4180,localhost:4181,localhost:4182", 5000, new Watcher() {   
            public void process(WatchedEvent event) {   
                // 如果发生了"/sgroup"节点下的子节点变化事件, 更新server列表, 并重新注册监听   
                if (event.getType() == EventType.NodeChildrenChanged    
                    && ("/" + groupNode).equals(event.getPath())) {   
                    try {   
                        updateServerList();   
                    } catch (Exception e) {   
                        e.printStackTrace();   
                    }   
               }   
            }   
        });   
  
        updateServerList();   
    }   
  
    /**  
     * 更新server列表  
     */  
    private void updateServerList() throws Exception {   
        List<String> newServerList = new ArrayList<String>();   
  
        // 获取并监听groupNode的子节点变化   
        // watch参数为true, 表示监听子节点变化事件.    
        // 每次都需要重新注册监听, 因为一次注册, 只能监听一次事件, 如果还想继续保持监听, 必须重新注册   
        List<String> subList = zk.getChildren("/" + groupNode, true);   
        for (String subNode : subList) {   
            // 获取每个子节点下关联的server地址   
            byte[] data = zk.getData("/" + groupNode + "/" + subNode, false, stat);   
            newServerList.add(new String(data, "utf-8"));   
        }   
  
        // 替换server列表   
        serverList = newServerList;   
  
        System.out.println("server list updated: " + serverList);   
    }   
  
    /**  
     * client的工作逻辑写在这个方法中  
     * 此处不做任何处理, 只让client sleep  
     */  
    public void handle() throws InterruptedException {   
        Thread.sleep(Long.MAX_VALUE);   
    }   
  
    public static void main(String[] args) throws Exception {   
        AppClient ac = new AppClient();   
        ac.connectZookeeper();   
  
        ac.handle();   
    }   
}  
 


将其打包成appclient.jar后待用, 别忘了指定入口函数.

 

运行
在运行jar包之前, 需要确认zookeeper中是否已经存在"/sgroup"节点了, 没有不存在, 则创建该节点. 如果存在, 最好先将其删除, 然后再重新创建. ZooKeeper的相关命令可参考我的另一篇博文.
运行appclient.jar: java -jar appclient.jar 开启多个命令行窗口, 每个窗口运行appserver.jar进程:java -jar appserver.jar server0000. "server0000"表示server的地址, 别忘了给每个server设定一个不同的地址. 观察appclient的输出.
依次结束appserver的进程, 观察appclient的输出.
appclient的输出类似于:


 

server list updated: []   
server list updated: [server0000]   
server list updated: [server0000, server0001]   
server list updated: [server0000, server0001, server0002]   
server list updated: [server0000, server0001, server0002, server0003]   
server list updated: [server0000, server0001, server0002]   
server list updated: [server0000, server0001]   
server list updated: [server0000]   
server list updated: []  

  

分享到:
评论

相关推荐

    ZooKeeper示例 实时更新server列表1

    《ZooKeeper示例:实时更新server列表》 在分布式系统中,ZooKeeper作为一个可靠的分布式协调服务,常被用于管理、配置、命名、提供分布式锁等任务。本示例将探讨如何利用ZooKeeper实现实时更新server列表,以确保...

    Dubbo、spring、zookeeper示例搭建

    - 初始化Zookeeper的数据目录,执行`bin/zkServer.sh start`启动服务。 ### 步骤2:创建Spring项目 - 使用Maven或Gradle初始化一个新的Spring项目。 - 添加Dubbo和Spring的依赖到`pom.xml`或`build.gradle`。 ###...

    zookeeper-server-client 简单例子

    通常,这样的示例会包括创建 Zookeeper 连接、创建节点、读取节点数据、设置节点数据、监听节点变化等基本操作。 例如,创建一个 Zookeeper 连接并创建一个节点的代码片段: ```java import org.apache.zookeeper....

    1、zookeeper3.7.1安装与验证

    此外,你需要至少有奇数台机器(本文中使用了3台,名为`server1`、`server2`和`server3`)来搭建Zookeeper集群。 2. **设置机器名称和用户**: 使用root用户设置每台机器的主机名,并创建用户`alanchan`和对应的...

    ZooKeeper3.4.9 windos和linux

    1.2 数据模型:ZooKeeper的数据结构类似于文件系统,由节点(ZNode)组成,支持读写操作,并且具备版本控制和ACL(访问控制列表)。 二、Windows上的ZooKeeper部署 2.1 安装:下载解压Zookeeper-3.4.9压缩包,将...

    第三课:zookeeper 典型使用场景实践1

    - **架构设计**:Zookeeper中的节点结构通常采用层次化的命名空间,如在例子中,根节点为`tuling-manager`,每个服务节点如`server00001`到`server0000n`表示实际的服务器实例,并携带JSON格式的服务状态信息,包括...

    2、zookeeper基本操作及应用示例(shell、java api、应用场景示例)

    3. 配置管理:将全局配置存储在Zookeeper,多个应用实例可以通过订阅配置节点的变化,实现实时更新配置。 4. 分布式计数器:通过原子操作递增或递减节点数据,实现分布式计数。 总结,Zookeeper作为分布式系统的...

    zookeeper-3.8.0安装包下载

    1. bin:包含了启动和停止 Zookeeper 服务的脚本,如 zkServer.sh 和 zkCli.sh。zkServer.sh 用于启动服务器,zkCli.sh 用于启动命令行客户端,方便用户与 Zookeeper 进行交互。 2. conf:存放配置文件,如 zoo.cfg...

    zookeeper-3.3.6

    2. **配置管理**:集中管理分布式系统的配置信息,动态更新,实时同步。 3. **命名服务**:提供分布式应用的全局唯一ID生成。 4. **集群管理**:监控集群中节点的状态,实现故障检测和自动故障切换。 **七、...

    zookeeper的开发使用技巧和常用命令

    在上面的示例中,我们配置了三个 ZooKeeper 节点,分别是 zookeeper-1、zookeeper-2 和 zookeeper-3。每个节点都有唯一的数据目录、日志目录和 myid 文件。 三、启动 ZooKeeper 服务 启动 ZooKeeper 服务之前,...

    zookeeper数据迁移从单例到集群linux命令过程

    - 更新每个节点上的 `zoo.cfg` 文件中的 `server.id=host:port:port` 行,指定集群中的其他节点。 - 例如,在 `zookeeper2` 的 `zoo.cfg` 中添加: ```properties server.1=192.168.102.228:2888:3888 server.2...

    Zookeeper-release-3.5.4 源码,部分有注释

    此外,`zookeeper-release-3.5.4`中还包括了测试用例,这为我们提供了很好的示例,了解如何与Zookeeper进行交互。例如,`org.apache.zookeeper.test`包下包含了各种测试场景,如客户端API的使用、会话管理、数据更新...

    Zookeeper单机及集群安装配置

    **Zookeeper集群逻辑图示例**: - 客户端可以连接到集群中的任何服务器。 - 每个跟随者都与领导者保持连接,以便接收数据更新指令。 - 服务器会记录事务日志和快照到持久化存储中。 - 只要有超过一半的服务器正常...

    Zookeeper 安装和配置

    `keeper demo` 可能是包含一个简单的 Zookeeper 使用示例,用于演示如何在 Dubbo 中集成 Zookeeper。 在 Dubbo 中配置 Zookeeper,需要在服务提供者和服务消费者的应用配置文件中指定注册中心类型(`zookeeper`)和...

    zookeeper-3.4.10 linux版本

    在实际使用中,ZooKeeper支持多种数据模型,如节点(Znode)、ACL(访问控制列表)和watcher(观察者)。Znodes是ZooKeeper中的基本数据单元,可以存储数据和元数据。ACL用于控制对Znodes的访问权限,而watcher则是...

    Zookeeper实战

    启动Zookeeper服务,通过`zkServer.sh`脚本完成: ```shell cd ~/zookeeper/bin sh zkServer.sh start ``` 检查Zookeeper的状态,以确认服务是否正常运行: ```shell sh zkServer.sh status ``` 当需要停止...

    zookeeper.tar.gz

    这个压缩包文件"zookeeper.tar.gz"提供了一个已经在生产环境中实际运行过的配置示例,对于理解和学习Zookeeper的配置与运行机制有着重要的参考价值。 一、Zookeeper的核心概念 1. 数据模型:Zookeeper的数据模型是...

    zookeeper安装文档.docx

    - 复制示例配置文件`zoo_sample.cfg`为`zoo.cfg`。 ```bash cp zoo_sample.cfg zoo.cfg ``` - 使用文本编辑器打开`zoo.cfg`文件进行编辑。 ```bash vim zoo.cfg ``` 修改配置项如下: ```properties ...

    zookeeper-3.4.6的服务包

    这个服务包可能包含了运行Zookeeper所需的所有组件,包括服务器端软件、客户端库以及相关的文档和配置示例。 描述中的“zookeeper的3.4版本我找了很久都没找到,还是通过朋友发过来的”暗示了Zookeeper的某些版本...

    zookeeper3.4.6 windows 版本

    对于搭建Dubbo示例,你需要创建一个提供者和服务消费者项目,配置ZooKeeper地址,并使用Dubbo的API声明服务接口和实现。在Windows上,你可以利用IDEA或Eclipse等Java开发工具进行快速开发和测试。 总的来说,...

Global site tag (gtag.js) - Google Analytics