zookeeper(2) 服务器动态上下线监听和分布式锁案例

案例一：服务器动态上下线监听

某分布式系统中，主节点可以有多台，可以动态上下线，任意一台客户端都能实时感知 到主节点服务器的上下线。

1.服务端代码

package com.atguigu.case1;import org.apache.zookeeper.*;import java.io.IOException;
import java.nio.charset.StandardCharsets;public class DistributeServer {String connectString = "hadoop100:2181,hadoop101:2181,hadoop102:2181";int sessionTimeout = 20000;private ZooKeeper zooKeeper;public static void main(String[] args) throws IOException, InterruptedException, KeeperException {DistributeServer server = new DistributeServer();server.getConnect();server.regist(args[0]);server.business();}private void business() throws InterruptedException {Thread.sleep(Long.MAX_VALUE);}private void regist(String hostname) throws InterruptedException, KeeperException {String s = zooKeeper.create("/servers/", hostname.getBytes(StandardCharsets.UTF_8), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);System.out.println(hostname + "isonline");}private void getConnect() throws IOException {zooKeeper = new ZooKeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent watchedEvent) {}});}
}

2.客户端代码

package com.atguigu.case1;import org.apache.zookeeper.*;import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;public class DistributeClient {String connectString = "hadoop100:2181,hadoop101:2181,hadoop102:2181";int sessionTimeout = 20000000;private ZooKeeper zooKeeper;public static void main(String[] args) throws IOException, InterruptedException, KeeperException {DistributeClient client = new DistributeClient();client.getConnect();client.getServerList();client.business();}private void getServerList() throws InterruptedException, KeeperException {List<String> children = zooKeeper.getChildren("/servers", true);ArrayList<String> servers = new ArrayList<>();for (int i = 0; i < children.size(); i++) {byte[] data = zooKeeper.getData("/servers/" + children.get(i), false, null);servers.add(new String(data));}System.out.println(servers);}private void business() throws InterruptedException {Thread.sleep(Long.MAX_VALUE);}private void regist(String hostname) throws InterruptedException, KeeperException {String s = zooKeeper.create("/servers/"+hostname, hostname.getBytes(StandardCharsets.UTF_8), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);System.out.println(hostname + "isonline");}private void getConnect() throws IOException {zooKeeper = new ZooKeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent watchedEvent) {try {getServerList();} catch (InterruptedException e) {e.printStackTrace();} catch (KeeperException e) {e.printStackTrace();}}});}
}

案例二：分布式锁案例原生方法

package com.atguigu.case2;import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;import java.io.IOException;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.CountDownLatch;public class DistributedLock {String connectString = "hadoop100:2181,hadoop101:2181,hadoop102:2181";int sessionTimeout = 2000;private final ZooKeeper zooKeeper;private CountDownLatch connectLatch  = new CountDownLatch(1);private CountDownLatch waitLatch  = new CountDownLatch(1);private String waitPath;private String currentMode;public DistributedLock() throws IOException, InterruptedException, KeeperException {//获取连接zooKeeper = new ZooKeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent watchedEvent) {//监听到前一个节点已经下线//connectLatch 如果连上需要释放if(watchedEvent.getState() == Event.KeeperState.SyncConnected) {connectLatch.countDown();}//waitLatch 需要释放if(watchedEvent.getType() == Event.EventType.NodeDeleted&&watchedEvent.getPath().equals(waitPath)){waitLatch.countDown();}}});//等待zk正常连接后，才往下走connectLatch.await();//判断根节点/locks是否存在Stat stat = zooKeeper.exists("/locks", false);if(stat == null) {//创建根节点zooKeeper.create("/locks","locks".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);}}//加锁public void zklock(){//创建对应的临时的带序号的节点try {currentMode = zooKeeper.create("/locks/" + "seq-", null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);//判断创建的节点是否是最小的节点，如果是获取到锁；不是，监听前一个序号最小的节点List<String> children = zooKeeper.getChildren("/locks", false);//如果children只有一个值，那就直接获取锁；如果有多个节点，需要判断谁最小if(children.size() == 1) {return;} else {//排序Collections.sort(children);//获取当前节点名称String thisNode = currentMode.substring("/locks/".length());//通过thisNode获取在children集合中的位置int index = children.indexOf(thisNode);if(index == -1) {System.out.println("数据异常");}else if(index == 0) {//就一个节点数据，就可以获取锁了return;}else {//需要监听 前一个节点变化waitPath = "/locks/"+children.get(index-1);zooKeeper.getData(waitPath,true,null);//等待监听waitLatch.await();//接收到之后return;}}} catch (KeeperException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}}public void unZklock(){//删除节点try {zooKeeper.delete(currentMode,-1);} catch (InterruptedException e) {e.printStackTrace();} catch (KeeperException e) {e.printStackTrace();}}
}

测试

package com.atguigu.case2;import org.apache.zookeeper.KeeperException;import java.io.IOException;public class DistributedLockTest {public static void main(String[] args) throws IOException, InterruptedException, KeeperException {DistributedLock lock1 = new DistributedLock();DistributedLock lock2 = new DistributedLock();new Thread(new Runnable(){@Overridepublic void run() {try {lock1.zklock();;System.out.println("线程1启动获取到锁");Thread.sleep(5000);lock1.unZklock();System.out.println("线程1释放锁");} catch (InterruptedException e) {e.printStackTrace();}}}).start();new Thread(new Runnable(){@Overridepublic void run() {try {lock2.zklock();System.out.println("线程2启动获取到锁");Thread.sleep(5000);lock2.unZklock();System.out.println("线程2释放锁");} catch (InterruptedException e) {e.printStackTrace();}}}).start();}
}

 案例三：分布式锁案例框架方法

引入包

        <dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>4.3.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>4.3.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-client</artifactId><version>4.3.0</version></dependency>
package com.atguigu.case3;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 CuratorLockTest {public static void main(String[] args) {//创建分布式锁1InterProcessMutex lock1 = new InterProcessMutex(getCuratorFramework(), "/locks");//创建分布式锁2InterProcessMutex lock2 = new InterProcessMutex(getCuratorFramework(), "/locks");new Thread(new Runnable(){@Overridepublic void run() {try {lock1.acquire();System.out.println("线程1获取到锁");lock1.acquire();System.out.println("线程1再次获取到锁");lock1.release();System.out.println("线程1释放锁");lock1.release();System.out.println("线程1再次释放锁");} catch (Exception e) {e.printStackTrace();}}}).start();new Thread(new Runnable(){@Overridepublic void run() {try {lock2.acquire();System.out.println("线程2获取到锁");lock2.acquire();System.out.println("线程2再次获取到锁");lock2.release();System.out.println("线程2释放锁");lock2.release();System.out.println("线程2再次释放锁");} catch (Exception e) {e.printStackTrace();}}}).start();}private static CuratorFramework getCuratorFramework() {ExponentialBackoffRetry policy = new ExponentialBackoffRetry(3000, 3);CuratorFramework client = CuratorFrameworkFactory.builder().connectString("hadoop100:2181,hadoop101:2181,hadoop102:2181").connectionTimeoutMs(2000).sessionTimeoutMs(2000).retryPolicy(policy).build();client.start();System.out.println("zookeeper启动成功");return client;}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/660043.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

C++ //练习 3.28 下列数组中元素的值是什么？

C++ //练习 3.28 下列数组中元素的值是什么？

C Primer&#xff08;第5版&#xff09; 练习 3.28 练习 3.28 下列数组中元素的值是什么&#xff1f; string sa[10]; int ia[10]; int main(){string sa2[10];int ia2[10]; }环境&#xff1a;Linux Ubuntu&#xff08;云服务器&#xff09; 工具&#xff1a;vim 解释 sa中…
阅读更多...
微信小程序在线客服源码系统：聊天记录云端实时保存 带完整的搭建教程

微信小程序在线客服源码系统：聊天记录云端实时保存 带完整的搭建教程

微信小程序已经成为企业开展线上业务的重要渠道。然而&#xff0c;在小程序中提供客户服务需要解决聊天记录的存储与查询问题。传统的客服系统往往只能在本地保存聊天记录&#xff0c;一旦客户端出现问题&#xff0c;聊天记录可能会丢失&#xff0c;给企业带来巨大的损失。为了…
阅读更多...
双屏联动系统在展厅设计中的互动类型与效果

双屏联动系统在展厅设计中的互动类型与效果

随着各项多媒体技术的快速发展&#xff0c;让展厅中的各类展项得到技术升级&#xff0c;其中作为电子设备中最基础的显示技术&#xff0c;不仅优化了内容的展示质量&#xff0c;还实现了更具互动性的创新技术&#xff0c;如双屏联动系统就是当前展厅设计中最常见的技术类型之一…
阅读更多...
单据报表增加保存按钮（将单据报表的数据保存到后台表）

单据报表增加保存按钮（将单据报表的数据保存到后台表）

单据报表增加保存按钮 &#x1f4e3;1. 需求 新建一张要存储保存数据的后台把&#xff0c;查出当月数据以后&#xff0c;可以点击保存按钮将当前月份的数据保存到后台表中。如果后台表中没有当前月份的数据&#xff0c;则直接保存到后台表中&#xff1b;如果后台表中有当前月份…
阅读更多...
【C++】类和对象（1）

【C++】类和对象（1）

上节我们学习了C入门的一些语法知识&#xff0c;这篇博客来学习类和this指针。 目录 面向过程和面向对象的初步认识 类的引入 类的定义 类的访问限定符及封装 访问限定符 封装 类的作用域 类的实例化 类对象大小 this指针 this指针特性 面向过程和面向对象的初步认识…
阅读更多...
UG949 适用于 FPGA 和 SoC 的UltraFast 设计方法指南

UG949 适用于 FPGA 和 SoC 的UltraFast 设计方法指南

使用RTL创建设计 定义RTL设计层级 模块边界输出进行寄存 即寄存器输出&#xff0c;打一拍 IP的使用 AMBA AXI
阅读更多...
c# Newtonsoft.Json 序列化和反序列化

c# Newtonsoft.Json 序列化和反序列化

1.安装 Newtonsoft.Json Nuget包 在C#中&#xff0c;你可以使用Newtonsoft.Json库来进行对象的序列化和反序列化&#xff0c;下面是一个简单的示例&#xff1a; using Newtonsoft.Json; using System;// 定义一个示例类 public class Person {public string Name { get; set; …
阅读更多...
AI 原生时代的云计算

AI 原生时代的云计算

本文整理自2023年 12 月 20 日举办的「2023 百度云智大会智算大会」主论坛&#xff0c;百度副总裁谢广军的主题演讲《AI 原生时代的云计算》。 &#xff08;视频回放链接&#xff1a;https://cloud.baidu.com/summit/aicomputing_2023/index.html&#xff09; 大模型的到来&…
阅读更多...
安卓之代码检查工具优劣分析以及应用场景

安卓之代码检查工具优劣分析以及应用场景

一、引言 代码检查工具在Android应用开发中是不可或缺的一部分&#xff0c;它们旨在提高代码质量、强化编程规范、消除潜在bug、提升应用性能和安全性。诸如Checkstyle、FindBugs、Infer、PMD和Android Lint等一系列工具各具特色&#xff0c;应用于不同的开发环节&#xff0c;有…
阅读更多...
Leetcode—807. 保持城市天际线【中等】

Leetcode—807. 保持城市天际线【中等】

2024每日刷题&#xff08;一零四&#xff09; Leetcode—807. 保持城市天际线 实现代码 class Solution { public:int maxIncreaseKeepingSkyline(vector<vector<int>>& grid) {int n grid.size();vector<int> row(n);vector<int> col(n);int a…
阅读更多...
代理模式详解（重点解析JDK动态代理）

代理模式详解（重点解析JDK动态代理）

- 定义 在解析动态代理模式之前&#xff0c;先简单看下整个代理模式。代理模式分为普通代理、强制模式、动态代理模式。其中动态代理模式主要实现方式为Java JDK提供的JDK动态代理&#xff0c;第三方类库提供的&#xff0c;例如CGLIB动态代理。 代理模式就是为其他对象提供一种…
阅读更多...
ArcGIS学习（二）属性表的基本操作

ArcGIS学习（二）属性表的基本操作

ArcGIS学习（二）属性表的基本操作 1.查看属性表 ArcGIS是处理空间数据的平台。对于空间数据，大家可以理解成它是由两个部分构成：1.一个是空间形体，也就是点、线、面三种。线又可以分为直线、曲线，面又分为圆形、正方形、不规则形体等；2.另外一个部分是空间形体所附带的…
阅读更多...
nginx升级openssl3.1.3

nginx升级openssl3.1.3

nginx版本 1.24.0 openssl版本3.1.3 进入nginx源码目录执行./configure --prefix/usr/local/nginx --without-http_rewrite_module --with-http_stub_status_module --with-http_ssl_module --with-openssl/usr/local/src/openssl-3.1.3make这一步可能会报错, 我的是报后缀名为…
阅读更多...
分布式锁（Distributed Lock）介绍（基于数据库（mysql）；基于缓存（redis）；基于ZooKeeper等分布式协调服务）

分布式锁（Distributed Lock）介绍（基于数据库（mysql）；基于缓存（redis）；基于ZooKeeper等分布式协调服务）

文章目录 分布式锁介绍1. 分布式锁的工作原理1.1 锁的基本概念1.2 工作机制 2. 分布式锁的实现方式2.1 基于数据库的分布式锁2.2 基于Redis的分布式锁2.3 基于ZooKeeper的分布式锁 3. 分布式锁的挑战3.1 死锁问题3.2 锁粒度问题粗粒度锁细粒度锁锁粒度的选择 3.3 锁的公平性问题…
阅读更多...
关于Spring框架的 @Configuration 与@Service 加载顺序哪个先后（某些环境加载是随机的）

关于Spring框架的 @Configuration 与@Service 加载顺序哪个先后（某些环境加载是随机的）

很多资料都说Configuration 优先加载&#xff0c;Service后加载&#xff0c;如下图&#xff1a; 本来也是以为 Configuration 优先加载于 Service &#xff0c;那参数处理放在Configuration注入完后&#xff0c;service构建时就可以拿来用的&#xff0c;在我在IDEA的调试时下断…
阅读更多...
喜讯 | 经纬恒润整车电子电气测试实验室通过一汽研发总院外部实验室资质认证！

喜讯 | 经纬恒润整车电子电气测试实验室通过一汽研发总院外部实验室资质认证！

近日&#xff0c;经纬恒润整车电子电气测试实验室成功通过中国一汽研发总院的资质评定&#xff0c;获得外部实验室认可证书。这是继经纬恒润测试实验室获得一汽智能网联开发院车载以太网测试资质认证之后的又一次认可&#xff0c;它将拓宽经纬恒润与红旗新能源及相关零部件供应…
阅读更多...
实现可编辑excel

实现可编辑excel

需要花钱买的插件有这个 SpreadJS 要在Vue项目中创建可编辑的Excel页面&#xff0c;你可以使用一些Vue插件和库帮助你实现此功能。以下是一个简单的步骤指导&#xff1a; 安装所需的依赖项&#xff1a; 在你的Vue项目目录下&#xff0c;使用以下命令安装xlsx和vue-xlsx库&…
阅读更多...
sqlite 存放json数据

sqlite 存放json数据

在SQLite中存放和查询JSON数据&#xff0c;你可以使用SQLite内置的JSON支持&#xff08;从SQLite版本3.9.0开始引入的JSON1扩展&#xff0c;以及在后续版本中增强的功能如JSON函数和操作符&#xff09;。下面是如何在SQLite中存放和查询JSON数据的步骤&#xff1a; 创建表格并…
阅读更多...
【SparkML实践5】特征转换FeatureTransformers实战scala版

【SparkML实践5】特征转换FeatureTransformers实战scala版

本节介绍了用于处理特征的算法&#xff0c;大致可以分为以下几组&#xff1a; 提取&#xff08;Extraction&#xff09;&#xff1a;从“原始”数据中提取特征。转换&#xff08;Transformation&#xff09;&#xff1a;缩放、转换或修改特征。选择&#xff08;Selection&…
阅读更多...
分组密码工作模式

分组密码工作模式

在密码学中&#xff0c;分组密码工作模式可以提供诸如机密性或真实性的信息服务。 基于分组的对称加密算法&#xff08;DES 、AES等&#xff09;只是描述如何根据加密密钥对一段固 定长度&#xff08;块&#xff09;的数据进行加密&#xff0c;对于比较长的数据&#xff0c;分组…
阅读更多...
最新文章

Copyright @ 2022~2023