Zookeeper典型应用场景介绍

╰+哭是因爲堅強的太久メ 2023-09-30 12:50 7阅读 0赞

**1.前言**

之前自己写了一些关于Zookeeper的基础知识，Zookeeper作为一种协调分布式应用高性能的调度服务，实际的应用场景也非常的广泛，这里主要通过几个例子来具体的说明Zookeeper在特定场景下的使用方式（下面的这些功能估计consul和etcd也能实现，以后学到了再说吧）。

**2.具体应用**

**2.1.一致性配置管理**

我们在开发的时候，有时候需要获取一些公共的配置，比如数据库连接信息等，并且偶然可能需要更新配置。如果我们的服务器有N多台的话，那修改起来会特别的麻烦，并且还需要重新启动。这里Zookeeper就可以很方便的实现类似的功能。

2.1.1.思路

将公共的配置存放在Zookeeper的节点中

应用程序可以连接到Zookeeper中并对Zookeeper中配置节点进行读取或者修改（对于写操作可以进行权限验证设置），下面是具体的流程图：

![15ebf5c538ef49d26176bd0a2495ac55.png][]

2.1.2.事例

数据库配置信息一致性的维护

配置类：

public class CommonConfig implements Serializable{
    // 数据库连接配置
    private String dbUrl;
    private String username;
    private String password;
    private String driverClass;
    
    public CommonConfig() {}
    
    public CommonConfig(String dbUrl, String username, String password, String driverClass) {
    super();
    this.dbUrl = dbUrl;
    this.username = username;
    this.password = password;
    this.driverClass = driverClass;
    }
    
    public String getDbUrl() {
    return dbUrl;
    }
    
    public void setDbUrl(String dbUrl) {
    this.dbUrl = dbUrl;
    }
    
    public String getUsername() {
    return username;
    }
    
    public void setUsername(String username) {
    this.username = username;
    }
    
    public String getPassword() {
    return password;
    }
    
    public void setPassword(String password) {
    this.password = password;
    }
    
    public String getDriverClass() {
    return driverClass;
    }
    
    public void setDriverClass(String driverClass) {
    this.driverClass = driverClass;
    }
    
    @Override
    public String toString() {
    return "CommonConfig:{dbUrl:" + this.dbUrl +
    ", username:" + this.username +
    ", password:" + this.password +
    ", driverClass:" + this.driverClass + "}";
    }
    }

配置管理中心

1.获取本地配置信息

2.修改配置，并同步

同步配置信息到Zookeeper服务器

public class ZkConfigMng {
    private String nodePath = "/commConfig";
    private CommonConfig commonConfig;
    private ZkClient zkClient;
    
    public CommonConfig initConfig(CommonConfig commonConfig) {
    if(commonConfig == null) {
    this.commonConfig = new CommonConfig("jdbc:mysql://127.0.0.1:3306/mydata?useUnicode=true&characterEncoding=utf-8",
    "root", "root", "com.mysql.jdbc.Driver");
    } else {
    this.commonConfig = commonConfig;
    }
    return this.commonConfig;
    }
    
    /**
    * 更新配置
    *
    * @param commonConfig
    * @return
    */
    public CommonConfig update(CommonConfig commonConfig) {
    if(commonConfig != null) {
    this.commonConfig = commonConfig;
    }
    syncConfigToZookeeper();
    return this.commonConfig;
    }
    
    public void syncConfigToZookeeper() {
    if(zkClient == null) {
    zkClient = new ZkClient("127.0.0.1:2181");
    }
    if(!zkClient.exists(nodePath)) {
    zkClient.createPersistent(nodePath);
    }
    zkClient.writeData(nodePath, commonConfig);
    }
    }

以上是提供者，下面我们需要一个客户端获取这些配置

public class ZkConfigClient implements Runnable {
    
    private String nodePath = "/commConfig";
    
    private CommonConfig commonConfig;
    
    @Override
    public void run() {
    ZkClient zkClient = new ZkClient(new ZkConnection("127.0.0.1:2181", 5000));
    while (!zkClient.exists(nodePath)) {
    System.out.println("配置节点不存在!");
    try {
    TimeUnit.SECONDS.sleep(1);
    } catch (InterruptedException e) {
    e.printStackTrace();
    }
    }
    // 获取节点
    commonConfig = (CommonConfig)zkClient.readData(nodePath);
    System.out.println(commonConfig.toString());
    zkClient.subscribeDataChanges(nodePath, new IZkDataListener() {
    
    @Override
    public void handleDataDeleted(String dataPath) throws Exception {
    if(dataPath.equals(nodePath)) {
    System.out.println("节点：" + dataPath + "被删除了！");
    }
    }
    
    @Override
    public void handleDataChange(String dataPath, Object data) throws Exception {
    if(dataPath.equals(nodePath)) {
    System.out.println("节点：" + dataPath + ", 数据：" + data + " - 更新");
    commonConfig = (CommonConfig) data;
    }
    }
    });
    }
    
    }

下面启动Main函数

[15ebf5c538ef49d26176bd0a2495ac55.png]: https://img-blog.csdnimg.cn/img_convert/15ebf5c538ef49d26176bd0a2495ac55.png