老王讲自制RPC框架.(三.ZOOKEEPER）
2024-10-19 16:41:11
(#)定义
Zookeeper 分布式服务框架是 Apache Hadoop 的一个子项目，它主要是用来解决分布式应用中经常遇到的一些数据管理问题，如：统一命名服务、状态同步服务、集群
管理、分布式应用配置项的管理
(#)使用
配置zk客户端我就不多说了，这个网上一找一堆，我主要说一下就是，自己玩玩的话，没必要搭建一个集群，用一台基本问题不大，在此假设集群已经搭建完成了
需要引入zk client的jar包
(#)code
private Logger logger = LoggerFactory.getLogger(ServiceRepository.class);
@Value("${session.timeout}")
private int SESSION_TIMEOUT;
@Value("${registry.address}")
private String CONNECT_STRING;
@Value("${repository.path}")
private String RPC_PATH;
private ZooKeeper zooKeeper = null;
private CountDownLatch latch = new CountDownLatch(1); private void createConnect() {
releaseConnection();
try {
zooKeeper = new ZooKeeper(CONNECT_STRING, SESSION_TIMEOUT,
new Watcher() {
public void process(WatchedEvent event) {
logger.info("receive message :{}" + event.getState());
latch.countDown();
}
});
latch.await();
} catch (IOException e) {
logger.error("create异常信息:{}", e);
} catch (InterruptedException e) {
logger.error("create异常信息:{}", e);
}
;
} private void releaseConnection() {
if (zooKeeper != null) {
try {
zooKeeper.close();
} catch (InterruptedException e) {
logger.error("release异常信息:{}", e);
}
}
} private boolean createPath(String path, String data) {
try {
zooKeeper.create(path, data.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
} catch (KeeperException e) {
logger.error("create异常信息:{}", e);
} catch (InterruptedException e) {
logger.error("create异常信息:{}", e);
}
return true;
} public String readData(String path) {
try {
return new String(zooKeeper.getData(path, false, null));
} catch (KeeperException e) {
logger.error("read异常信息:{}", e);
return "";
} catch (InterruptedException e) {
logger.error("read异常信息:{}", e);
return "";
}
} public boolean writeData(String path, String data) {
try {
zooKeeper.setData(path, data.getBytes(), -1);
} catch (KeeperException e) {
logger.error("write异常信息:{}", e);
} catch (InterruptedException e) {
logger.error("write异常信息:{}", e);
}
return false;
} public void deleteNode(String path) {
try {
zooKeeper.delete(path, -1);
} catch (KeeperException e) {
logger.error("delete异常信息:{}", e);
} catch (InterruptedException e) {
logger.error("delete异常信息:{}", e);
}
}
}
最新文章
- iOS--NSBundle理解
- ANE 从入门到精通 --- 简单的Whatever
- html随记
- nodejs中的Crypto模块
- ofbiz进击 个人遇到的奇葩问题汇总。
- MFC中消息响应机制
- 暑假集训(2)第八弹 ----- Hero（hdu4310)
- find_cmd函数分析
- Java语言程序设计(基础篇) 第八章 多维数组
- 使用函数指针和多态代替冗长的if-else或者switch-case
- LeetCodeOJ. Maximum Depth of Binary Tree
- Oracle中忘记sys和System密码的办法
- visio UML用例里面找不到include关系
- OGG强制停止进程
- shell vim--处理二进制文本
- 【贪心】【堆】Gym -100956D - Greedy Game
- seo从业者发展方向
- Redishelp
- DNS污染
- SqlDataAdapter 对datagridview进行增删改(A)