zookeeper选举问题

旧城等待， 2021-06-24 14:36 455阅读 0赞

两种选举制度

1.持久-直到节点挂掉

2.轮留选举

这里我使用的是持久的方式

public class ZKConnectionUtil \{

private  static CuratorFramework client ;

private static Object lock = new Object();

private static LeaderLatch leaderLatch;

private static Logger logger = LoggerFactory.getLogger(ZKConnectionUtil.class);

/\*\*

\* @描述：是否是leader

\* @return

\* @return boolean

\* @exception

\* @createTime：2016年11月22日

\* @author: songqinghu

\*/

public static boolean isLeader(CuratorFramework client)\{

return leaderLatch.hasLeadership();

\}

//            solr.zk.check.namespace=contentcheck

//            solr.zk.check.flag.path=/flag

/\*\*

\*

\* @描述：获取单例的zookeeper连接

\* @return void

\* @exception

\* @createTime：2016年8月24日

\* @author: songqinghu

\*/

public static CuratorFramework getZKConnection()\{

if(client ==null)\{

synchronized (lock) \{

if(client ==null)\{

int connectionTimeoutMs=5000;

String connectString=PropertiesUtil.getProProperties("solr.zk.url","");

String namespace=PropertiesUtil.getProProperties("solr.zk.porsche.namespace","");

//String connectString="10.125.2.48:3181";

//String namespace="contentcheck";

//byte\[\] defaultData=IpUtil.getInNetworkIp().getBytes();

RetryPolicy retryPolicy= new RetryNTimes(Integer.MAX\_VALUE, 1000);

client = CuratorFrameworkFactory.

builder().

//        aclProvider(aclProvider).

//        authorization(scheme, auth).

connectionTimeoutMs(connectionTimeoutMs).

connectString(connectString).

//  defaultData(defaultData).

namespace(namespace).

retryPolicy(retryPolicy).

build();

client.start();

//选举

String leaderPath = PropertiesUtil.getProProperties("solr.zk.porsche.leader", "");

leaderLatch = new LeaderLatch(client, leaderPath);

try \{

leaderLatch.start();

\} catch (Exception e) \{

logger.error("get leaderlatch occor error and error is : " + e);

\}

\}

\}

\}

return client;

\}

\}

原理解析:  
在指定节点下每台机器会创建临时节点,机器挂掉,节点会被删除,就会重新选举

发表评论取消回复

表情：

评论列表（有 0 条评论，455人围观）

还没有评论，来说两句吧...

相关阅读

相关 Zookeeper选举算法

集群选举Leader的两种情况集群中已经存在Leader。集群中不存在Leader。集群中已经存在Leader的情况此种情况一般都是某台机器启

今天药忘吃喽~/ 2022年11月30日 04:23/ 0 赞/ 152 阅读

相关【ZooKeeper】Leader 选举

1 Leader 选举概述 Leader 选举是 ZooKeeper 中最重要的技术之一，也是保证分布式数据一致性的关键所在。在本节中，我们将先从整体上来对 ZooKe

今天药忘吃喽~/ 2022年10月21日 14:55/ 0 赞/ 219 阅读

相关 Zookeeper选举机制

SID：服务器ID。用来唯一标识一台ZooKeeper集群中的机器，每台机器不能重复，和myid一致。 ZXID：事务ID。ZXID是一个事务ID，用来标识一次服务器状态的变

港控/mmm°/ 2022年09月05日 14:54/ 0 赞/ 254 阅读

相关 zookeeper选举机制

什么是zookeeper？ zookeeper是一个分布式应用程序协调服务、开源的组件，有分布式服务的基本都可以用zookeeper。

我就是我/ 2022年06月06日 12:28/ 0 赞/ 280 阅读

相关 Zookeeper-Zookeeper leader选举

在上一篇文章中我们大致浏览了zookeeper的启动过程，并且提到在Zookeeper的启动过程中leader选举是非常重要而且最复杂的一个环节。那么什么是leader选举呢？

向右看齐/ 2022年05月28日 09:49/ 0 赞/ 258 阅读

相关 Zookeeper master选举

Master/slave 主从，单点故障处理有一个向外提供的服务，服务必须7\24小时提供服务，不能有单点故障。所以采用集群的方式，采用master、slave的结构。一台

ゝ一纸荒年。/ 2022年05月24日 01:40/ 0 赞/ 255 阅读

相关 Zookeeper选举机制

选择机制中的概念服务器ID 比如有三台服务器，编号分别是1,2,3。 > 编号越大在选择算法中的权重越大。数据ID 服务器中存放的最大数据ID. > 值越大

深藏阁楼爱情的钟/ 2022年04月25日 10:22/ 0 赞/ 310 阅读

相关 zookeeper选举机制

两个账号写串了，在复制一份过来简单例子，说明zookeeper选举机制；假设有5台服务器组成的zookeeper集群，他们的id为1-5，同时，他们都是最新启动的，也就

拼搏现实的明天。/ 2022年04月10日 03:46/ 0 赞/ 337 阅读

相关 Zookeeper选举机制

1、全新集群选举机制 ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4u

r囧r小猫/ 2021年10月15日 12:13/ 0 赞/ 457 阅读

相关 zookeeper选举问题

两种选举制度 1.持久-直到节点挂掉 2.轮留选举这里我使用的是持久的方式 public class ZKConnectionUtil \{

旧城等待，/ 2021年06月24日 14:36/ 0 赞/ 456 阅读