ZooKeeper命令及JavaAPI操作代码分析

本文小编为大家详细介绍“ZooKeeper命令及JavaAPI操作代码分免费云主机域名析”，内容详细，步骤清晰，细节处理妥当，希望这篇“ZooKeeper命令及JavaAPI操作代码分析”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。ZooKeeper是一个树形目录服务，其数据模型和Uiix的文件目录树很类似，拥有一个层次化结构。这里面的每一个节点都被称为：ZNode，每个节点上都会保存自己的数据和节点信息。节点可以拥有子节点，同时也允许少量（1MB）数据存储在该节点之下。节点可以分为四大类：
PEFSISTENT持久化节点EPHEMERAL临时节点：-ePERSISTENT_SEQUENTIAL持久化顺序节点：-sEPHEMERAL_SEQUENTIAL临时顺序节点：-es启动ZooKeeper服务：./zkServer.sh start查看ZooKeeper服务：./zkServer.sh status停止ZooKeeper服务：./zkServer.sh stop重启ZooKeeper服务：./zkServer.sh restart./zkCli.sh -server localhost:2181连接服务端，如果是单机后面的可以省略不写。ls [/] ：查看指定节点下子节点create [/app] [hrbu]：创建一个名为/app1的子节点，并存放数据。get [/app] ：获取节点下的数据。set [/app] [hrbu]：给指定节点设置数据delete [/app] ：删除指定节点 ps：此命令无法删除存在子节点的节点，如果要删除带有子节点的节点可以是使用deleteall [/app] 命令。quit 断开连接help 查看命令帮助create -e [/app] 创建临时节点，会话关闭就会删除create -s [/app] 创建顺序节点create -es [/app] 创建临时顺序节点ls -s [/app] 查看节点的详细信息参数解读connectString – list of servers to connect to （ZooKeeper的地址）sessionTimeoutMs – session timeout （会话超时时间）
connectionTimeoutMs – connection timeout （连接超时时间）
retryPolicy – retry policy to use （重试策略）会话超时时间和连接超时时间有默认值。第二种链式编程的方式可以指定一个工作空间，在此客户端下的所有操作都会将此工作空间作为根目录。注意如果使用的是云服务器需要将指定端口打开firewall-cmd --zone=public --add-port=2181/tcp --permanent 开放端口firewall-cmd --zone=public --list-ports 查看已经开放的端口systemctl restart firewalld 重启防火墙生效最后别忘了在服务器的安全组里面添加端口，将2181端口打开添加节点查询节点修改节点删除节点Zookeeper允许用户在指定节点上注册一些Watcher，并且在一些特定事件触发的时候，ZooKeeper服务端会将事件通知到感兴趣的客户端上去，该机制是ZooKeeper实现分布式协调服务的重要特性。ZooKeeper中引入了Watcher机制来实现了发布/订阅功能，能够让多个订阅者同时监听某一个对象，当一个对象自身状态变化时，会通知所有订阅者。ZooKeeper原生支持通过注册Watcher来进行事件监听，但是使用并不是特别方便，需要开发人员自己反复注册Watcher，比较繁琐。Curator引入了Cache来时限对Zookeeper服务端事件的监听。ZooKeeper提供了三种Watcher：NodeCache：只是监听某一个特定的节点。PathChildrenCache：监控一个Node的子节点。TreeCache：可以监控整个树上的所有节点，类似于PathChildrenCache和NodeCache的组合。NodeCachePathChildrenCacheTreeCache我们在进行单机应用开发，涉及并发同步的时候，，我们往往采用synchronized或者lock的方式来解决多线程间的代码同步问题，这时候多线程的运行都是在同一个JVM之下，没有任何问题。但当我们的应用时分布式集群工作的情况下，属于多JVM下的工作环境，跨JVM之间已经无法通过多线程的锁解决同步问题。那么就需要一种更加高级的锁机制，来处理跨机器进程之间的数据同步问题，这就是分布式锁。核心思想：当客户端要获取锁，则创建节点，使用完锁，则删除该节点。1.客户端获取锁时，在lock节点下创建临时顺序节点。2.然后获取lock下面的所有子节点，客户端获取到所有的子节之后，如果发现自己创建的子节点序号最小，那么就认为该客户端获取到了锁。使用完锁后，将该节点删除。3.如果发现自己创建的节点并非lock所有子节点中最小的，说明自己还没有获取到锁，此时客户端需要找到比自己小的那个节点，同时对其注册事件监听器，监听删除事件。4.如果发现比自己小的那个节点被删除，则客户端的Watcher会收到相应通知，此时再次判断自己创建的节点是否时lock子节点中序号最小的，如果是则获取到了锁，如果不是则重复以上步骤继续获取比自己小的一个节点并注册监听。在Curator中有五种锁方案：InterProcessSemaphoreMutex：分布式排它锁（非可重入锁）InterProcessMutex：分布式可重入排它锁InterProcessReadWriteLock：分布式读写锁InterProcessMultiLock：将多个锁作为单个实体管理的容器InterProcessSemaphoreV2：共享信号量读到这里，这篇“ZooKeeper命令及JavaAPI操作代码分析”文章已经介绍完毕，想要掌握这篇文章的知识点还需要大家自己动手实践使用过才能领会，如果想了解更多相关内容的文章，欢迎关注百云主机行业资讯频道。

相关推荐: docker容器的四种端口映射怎么实现

本文小编为大家详细介绍“docker容器的四种端口映射怎么实现”，内容详细，步骤清晰，细节处理妥当，希望这篇“docker容器的四种端口映射怎么实现”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。把容器的端口映射为宿主机的一个随机或者…