jgroups_JGroups：无需额外基础架构的领导人选举

jgroups

嗨，您好，

在本文中，我将展示如何在不使用任何其他基础架构（例如Apache Zookeeper或Consul）的情况下解决领导人选举的问题。

领导者选举是解决以下问题的一种常见方法：在分布式系统中，只有一个实例必须完成特定工作。

例如，这可能是

触发计划的工作
当系统充当外部系统的客户端时，协调建立连接
运行清理任务
…

通常，这可以通过使用提到的或类似的基础结构来解决。但是，如果您不想将它们引入系统环境，则还有另一种方法： JGroups 。

JGroups是一个

用于可靠消息传递的工具包。它可用于创建其节点可以相互发送消息的集群。
[http://jgroups.org/]

使用JGroups设置领导者，可以通过使用JGroups的View概念非常容易地进行选举。

视图是关于群集状态的实际视图，请猜测是什么。由于每个集群都恰好有一个协调器，它是视图中成员列表的第一个成员，因此可以将其解释为集群的领导者。

如果领导者死亡/重新启动/出现故障，列表中的下一个成员将成为新的领导者。这是一种非常方便且确定的方法。

例

让我们看一些简单的代码，演示一下：

public class JGroupsLeaderElectionExample {private static final int MAX_ROUNDS = 1_000;private static final int SLEEP_TIME_IN_MILLIS = 1000;public static void main(String[] args) throws Exception {JChannel channel = new JChannel();channel.connect("The Test Cluster");for (int round = 0; round < MAX_ROUNDS; round++) {checkLeaderStatus(channel);sleep();}channel.close();}private static void sleep() {try {Thread.sleep(SLEEP_TIME_IN_MILLIS);} catch (InterruptedException e) {// Ignored}}private static void checkLeaderStatus(JChannel channel) {View view = channel.getView();Address address = view.getMembers().get(0);if (address.equals(channel.getAddress())) {System.out.println("I'm (" + channel.getAddress() + ") the leader");} else {System.out.println("I'm (" + channel.getAddress() + ") not the leader");}}
}

上面的代码使用默认的堆栈设置创建一个新的JChannel。也可以使用XML文件或编程方法来配置堆栈。
然后将通道连接到“测试群集” 。 JGroups通过在连接上广播发现集群。如果当前实例是第一个，它将创建集群。

在循环中，代码现在仅从通道获取实际视图，并检查实际实例是否也是第一个成员。您记得第一位成员可以被视为领导者。

如果现在启动多个实例并停止第一个实例，则第二个将接管。像这个例子：

-------------------------------------------------------------------
GMS: address=Ygdrassil-21922, cluster=The Test Cluster, physical address=2003:4e:a904:2d67:55c:2653:7e28:8634:59721
-------------------------------------------------------------------
I'm (Ygdrassil-21922) the leader
I'm (Ygdrassil-21922) the leader
I'm (Ygdrassil-21922) the leader
I'm (Ygdrassil-21922) the leader

-------------------------------------------------------------------
GMS: address=Ygdrassil-57947, cluster=The Test Cluster, physical address=2003:4e:a904:2d67:55c:2653:7e28:8634:59724
-------------------------------------------------------------------
I'm (Ygdrassil-57947) not the leader
I'm (Ygdrassil-57947) not the leader
I'm (Ygdrassil-57947) not the leader
I'm (Ygdrassil-57947) not the leader
I'm (Ygdrassil-57947) not the leader
I'm (Ygdrassil-57947) the leader
I'm (Ygdrassil-57947) the leader

像往常一样，可以在我的GitHub帐户上找到该代码。