集群通信组件tribes之使用方法

最后更新于:2022-04-01 07:10:44

上面已经对tribes的内部实现机制及原理进行了深入的剖析,在理解它的设计原理后看看如何使用tribes,整个使用相当简单便捷,只需要四步: ① 定义一个消息对象,由于这个消息对象是要在网络之间传递的,网络传输涉及到序列化,所以需要实现Serializable接口。 ~~~ public class MyMessage implements Serializable { private String message; public String getMessage() { return message; } public void setMessage(String message) { this.message = message; } } ~~~ ② 定义一个ChannelListener监听器,对消息的处理逻辑放在messageReceived方法中。 ~~~ public class MyMessageListener implements ChannelListener{ public boolean accept(Serializable myMessage, Member member) { return true; } public void messageReceived(Serializable myMessage, Member member) { System.out.println(((MyMessage)myMessage).getMessage()+"  from  "+member.getName()); } } ~~~ ③ 定义一个MembershipListener监听器,对集群成员的加入及失效的逻辑处理,在memberAdded中对成员加入事件逻辑处理,在memberDisappeared中对成员失效事件逻辑处理。 ~~~ public class MyMemberListener implements MembershipListener { public void memberAdded(Member member) { System.out.println(member.getName()+" Added"); } public void memberDisappeared(Member member) { System.out.println(member.getName()+" Disappeared"); } } ~~~ ④ 主程序,分别实例化ChannelListener、MembershipListener并添加到channel中,然后启动channel,由于集群通信需要启动几个节点才可实现,为方便操作这里引入args参数,当参数值为”r”时表示只是启动一个节点并加入集群,而参数值为”s”时则表示启动节点加入集群后并且向集群所有成员发送Message,主程序使用循环睡眠是为了不让程序结束,一旦结束节点就不存在了。可以先带”r”参数运行两次,即意味着启动了两个节点,最后再带”s”参数运行,即第三个节点启动并向前两个成语节点发送消息,前两个节点分别输出了”hello  from  tcp://{169, 254, 75, 186}:4002”,而成员监听器则会在节点加入或失效时输出类似这样的消息”tcp://{169, 254, 75, 186}:4002 Added”、”tcp://{169, 254, 75, 186}:4000 Disappeared”。 ~~~ public class TribesTest { public static void main(String[] args) throws ChannelException,InterruptedException { Channel myChannel = new GroupChannel(); ChannelListener msgListener = new MyMessageListener(); MembershipListener mbrListener = new MyMemberListener(); myChannel.addMembershipListener(mbrListener); myChannel.addChannelListener(msgListener); myChannel.start(Channel.DEFAULT); switch (args[0]) { case ("r"): while (true) Thread.currentThread().sleep(1000); case ("s"): MyMessage myMsg = new MyMessage(); myMsg.setMessage("hello"); Member[] group = myChannel.getMembers(); myChannel.send(group, myMsg, Channel.SEND_OPTIONS_DEFAULT); while (true) Thread.currentThread().sleep(1000); } } } ~~~ 喜欢java的可以交个朋友: ![](https://docs.gechiui.com/gc-content/uploads/sites/kancloud/2016-01-15_5698bd8d22882.jpg)
';