分布式系统中经常涉及到配置资源的管理，比如，一个应用系统需要部署在多台服务器上，但是他们拥有某些的配置项是相同的，如果配置变更，需要修改这些配置，那么需要同时修改每台服务器，这样做比较麻烦而且容易出错。类似于这样的资源配置管理完全可以交给zookeeper进行管理，将需要配置的资源保存在zookeeper，当配置数据变化时，zookeeper会将变化信息发布到所有侦听zookeeper的服务器，服务器上的应用就可以从zookeeper中获取最新的配置信息。本文主要介绍如何通过Curator架构，使用zookeeper构建一个简单的配置资源管理系统。

系统架构

本文示例如下图所示，系统由三个部分组成，server端，zookeeper端和controller端，server端包含三个运行相同配置app的server，监听zookeeper中的conf节点。controller端用于操作zookeeper中的数据节点，当用户通过controller更新conf节点，三个server都会收到NodeDataChange消息。

Code

为演示简单起见，Serevr1, Srever2, Server3运行的代码一致，代码主要包含以下几个部分：

1.zookeeper需要存储的数据bean，这里我们使用json对bean 对象进行序列化。

package com.zte.zoo.keeper.configuration;

/**

 * Created by majun on 15/10/29.

 */

public class ConfigBean {

    private String url;

    private String port;

    private String name;

    private String pwd;

    public String getUrl() {

        return url;

    }

    public ConfigBean setUrl(String url) {

        this.url = url;

        return this;

    }

    public String getPort() {

        return port;

    }

    public ConfigBean setPort(String port) {

        this.port = port;

        return this;

    }

    public String getPwd() {

        return pwd;

    }

    public ConfigBean setPwd(String pwd) {

        this.pwd = pwd;

        return this;

    }

    public String getName() {

        return name;

    }

    public ConfigBean setName(String name) {

        this.name = name;

        return this;

    }

    @Override

    public String toString() {

        return GsonUtils.toJson(this);

    }

}

2.Server端运行的app code如下所示，主函数使用curatorwatch监听zookeeper的conf节点，当收到数据变化事件通知，打印

public class Server{

    public static void main(String[] args) {

        private final String serverName="app2";

        final CuratorFramework client = CuratorFrameworkFactory.newClient("127.0.0.1:2181", new ExponentialBackoffRetry(1000, 3));

        client.start();

        try {

            client.getData().usingWatcher(new CuratorWatcher() {

                public void process(WatchedEvent watchedEvent) throws Exception {

                    if (Watcher.Event.EventType.NodeDataChanged == watchedEvent.getType()) {

                        String data = new String(client.getData().forPath(watchedEvent.getPath()));

                        System.out.println(serverName + " recv data:" + GsonUtils.fromJson(data, ConfigBean.class));

                    }

                }

            }).forPath("/conf");

        } catch (Exception e) {

            e.printStackTrace();

        }

        while (true) ;

    }

}

3.Controller端运行的控制代码，更新zookeeper中具有PERSISTENT属性的conf节点

public class Controller {

    public static void main(String[] args) throws Exception {

        CuratorFramework newClient = CuratorFrameworkFactory.newClient("127.0.0.1:2181", new ExponentialBackoffRetry(1000, 3));

        newClient.start();

        ConfigBean configBean = new ConfigBean()

                .setUrl("192.168.1.1")

                .setPort("8000")

                .setName("majun")

                .setPwd("123");

//        createNode(newClient, "/conf", CreateMode.PERSISTENT, configBean.toString());

        updateNodeDate(newClient,"/conf",configBean.setName("xiaoya--").toString());

    }

    public static void createNode(CuratorFramework newClient, String path, CreateMode createMode, String data) {

        try {

            newClient.create().withMode(createMode).forPath(path, data.getBytes());

        } catch (Exception e) {

            System.out.println("创建节点失败, elog=" + e.getMessage());

        }

    }

    public static void updateNodeDate(CuratorFramework newClient, String path, String data) {

        try {

            newClient.setData().forPath(path, data.getBytes());

        } catch (Exception e) {

            System.out.println("更新节点数据失败, elog=" + e.getMessage());

        }

    }

}

4.json序列化工具类

public class GsonUtils {

    private static Gson gson = new Gson();

    public static String toJson(Object obj) {

        return gson.toJson(obj);

    }

    public static Object fromJson(String json, Class cla) {

        return gson.fromJson(json, cla);

    }

}

Test

启动zookeeper, 使用controller中的创建节点函数创建conf节点，然后分别启动三个server，使用controller中的更新函数更新节点，会在三个server打印的更新数据信息。

Conclusion

本文和大家分享了如何基于curator框架使用zookeeper构建统一资源管理系统，希望能够对大家有所帮助。

巴特西

基于zookeeper实现统一资源管理

系统架构

Code

Test

Conclusion

最新文章

热门文章