php网站后台无法上传图片,网站高级?O置,wp网站建设模板,成都优化网站哪家公司好1. Zookeeper原生客户端库存在的缺点
复杂性高#xff1a;原生客户端库提供了底层的 API#xff0c;需要开发者手动处理很多细节#xff0c;如连接管理、会话管理、异常处理等。这增加了开发的复杂性#xff0c;容易出错。连接管理繁琐#xff1a;使用原生客户端库时原生客户端库提供了底层的 API需要开发者手动处理很多细节如连接管理、会话管理、异常处理等。这增加了开发的复杂性容易出错。连接管理繁琐使用原生客户端库时开发者需要手动管理与 ZooKeeper 的连接。这包括连接的建立、重连、会话超时处理等。异常处理复杂原生客户端库的 API 抛出多种异常如 KeeperException、InterruptedException 等。开发者需要手动处理这些异常增加了代码的复杂性。缺少高级功能原生客户端库缺少一些高级功能如连接池管理、自动重试、负载均衡等。这些功能在实际应用中非常有用但需要开发者自己实现或使用第三方库。缺少封装和抽象原生客户端库提供了底层的 API缺少更高层次的封装和抽象。开发者需要自己编写大量的代码来实现常见的功能如分布式锁、配置管理等。性能调优困难原生客户端库的性能调优需要开发者手动进行如调整连接超时时间、会话超时时间等。这需要对 ZooKeeper 的工作原理有深入的理解。缺少社区支持相比于一些更高级的客户端库如 Curator原生客户端库的社区支持相对较少。开发者在使用过程中遇到问题时可能难以找到解决方案。
2. Apache Curator介绍 2.1 基本概述
定义Apache Curator是专为Apache ZooKeeper设计的Java/JVM客户端库通过提供高级API框架及一系列实用工具大幅降低使用ZooKeeper的复杂度并提升应用的可靠性。开发背景Curator最初由Netflix公司开源目前是Apache的顶级项目。
2.2 核心功能
高可用性连接管理自动处理与ZooKeeper服务器的连接断开和重新连接确保连接的稳定性和可靠性。易于使用的API封装复杂的ZooKeeper原语提供更直观、简洁的使用方式降低开发难度。模式Recipes预置了一系列常见的分布式计算模式如leader选举、分布式锁、缓存机制等开发者可以快速实现这些分布式系统经典难题。服务发现与负载均衡支持动态的服务注册与发现便于构建云原生应用提高系统的可扩展性和灵活性。异步DSL针对Java 8及以上版本提供了异步编程的支持提高了响应速度和程序效率。
3. 使用指南
3.1 添加 Maven 依赖
dependencygroupIdorg.apache.curator/groupIdartifactIdcurator-framework/artifactIdversion2.12.0/version
/dependency
dependencygroupIdorg.apache.curator/groupIdartifactIdcurator-recipes/artifactIdversion2.12.0/version
/dependency3.2 创建 Curator 客户端
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;public class CuratorExample {public static void main(String[] args) throws Exception {String connectString 192.168.200.138:2181;String path /curator1;byte[] data myData.getBytes();ExponentialBackoffRetry retry new ExponentialBackoffRetry(5000, 10);// 创建 Curator 客户端CuratorFramework client CuratorFrameworkFactory.newClient(connectString, retry);// 启动客户端client.start();// 创建节点client.create().withMode(CreateMode.PERSISTENT).forPath(path, data);// 获取节点数据byte[] retrievedData client.getData().forPath(path);System.out.println(Retrieved data: new String(retrievedData));// 关闭客户端client.close();}
}3.3 增删改查操作及Watcher监听
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.api.CuratorEvent;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;public class CuratorExample {public static void main(String[] args) throws Exception {String connectString 192.168.200.138:2181;String path /curator1;byte[] data1 myData1.getBytes();byte[] data2 myData2.getBytes();ExponentialBackoffRetry retry new ExponentialBackoffRetry(5000, 10);// 创建 Curator 客户端CuratorFramework client CuratorFrameworkFactory.newClient(connectString, retry);// 启动客户端client.start();// 增加临时监听操作client.getCuratorListenable().addListener((CuratorFramework c, CuratorEvent event) - {switch (event.getType()) {case WATCHED:WatchedEvent watchedEvent event.getWatchedEvent();if (watchedEvent.getType() Watcher.Event.EventType.NodeDataChanged) {System.out.println(监听的数据变化为: new String(c.getData().forPath(path)));System.out.println(触发事件);}}});// 创建节点client.create().withMode(CreateMode.PERSISTENT).forPath(path, data1);// 获取节点数据byte[] retrievedData client.getData().watched().forPath(path);System.out.println(原始数据: new String(retrievedData));// 修改节点数据client.setData().forPath(path, data2);Thread.sleep(2000);// 删除节点client.delete().forPath(path);Thread.sleep(2000);}
}3.4 进行永久监听
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.cache.ChildData;
import org.apache.curator.framework.recipes.cache.NodeCache;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;public class PermanentWatcherExample {public static void main(String[] args) throws Exception {String connectString 192.168.200.138:2181;String path /curator1;byte[] data1 myData1.getBytes();byte[] data2 myData2.getBytes();byte[] data3 myData3.getBytes();ExponentialBackoffRetry retry new ExponentialBackoffRetry(5000, 10);// 创建 Curator 客户端CuratorFramework client CuratorFrameworkFactory.newClient(connectString, retry);// 启动客户端client.start();// 永久监听client.create().withMode(CreateMode.PERSISTENT).forPath(path, data1);NodeCache nodeCache new NodeCache(client, path);nodeCache.start();nodeCache.getListenable().addListener(() - {ChildData currentData nodeCache.getCurrentData();if (currentData ! null) {System.out.println(触发了永久监听的回调当前值为 new String(currentData.getData()));}});client.setData().forPath(path, data1);Thread.sleep(2000);client.setData().forPath(path, data2);Thread.sleep(2000);client.setData().forPath(path, data3);Thread.sleep(2000);client.delete().forPath(path);}
}3.5 使用分布式锁
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
import org.apache.curator.retry.ExponentialBackoffRetry;public class DistributedLockExample {public static void main(String[] args) throws Exception {String connectString 192.168.200.138:2181;String path /myLock;ExponentialBackoffRetry retry new ExponentialBackoffRetry(5000, 10);// 创建 Curator 客户端CuratorFramework client CuratorFrameworkFactory.newClient(connectString, retry);// 启动客户端client.start();// 创建分布式锁InterProcessMutex lock new InterProcessMutex(client, path);// 获取锁lock.acquire();try {// 执行临界区代码System.out.println(Lock acquired, executing critical section...);Thread.sleep(2000);} finally {// 释放锁lock.release();System.out.println(Lock released.);}// 关闭客户端client.close();}
}
