JGroups

= JGroups :作者: Bela Ban :toc2: :toclevels: 3 :icons: :homepage: http://www.jgroups.org :source-highlighter: pygments == 总览 链接:$$http:///jgroups.org$[JGroups] 是一个聚集库,允许成员彼此交换消息。 它提供以下功能:

• 加入指定集群(成为成员)
• (加入后), 可以向其他成员发送消息
• 获取同一集群中的成员列表
• 注册在以下情况被调用的回调函数: ** 收到一条消息 ** 成员加入 ** 一名成员退出
• 离开集群 == 示例代码

下面的代码展示了如何向所有集群成员发送消息。打开两个或更多的 shell，并使用不同的参数（成员的名称）运行演示程序，例如 node1、node2 等。

protected MyReceiver(String name) { this.name=name; } public void receive(Message msg) { System.out.printf("-- [%s] 来自 %s 的消息: %s\n", name, msg.src(), msg.getObject()); } public void viewAccepted(View v) { System.out.printf("-- [%s] 新视图: %s\n", name, v); } } public static void main(String[] args) throws Exception { new Demo().start(args[0]); } }

JChannel 是用于与 JGroups 交互的句柄。在 start() 中，使用配置文件 udp.xml (请参阅 >) 创建了一个新的 JChannel，该文件需要在类路径中找到。也可以提供完全限定的路径名，例如 /Users/bela/tcp.xml。接收器设置为 MyReceiver 的实例，该实例实现了两个回调函数：viewAccepted()，在成员加入或离开时调用；以及 receive()，在接收消息时调用。最后，集群 "demo-cluster"

[source,java]