上面已经对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);
}
}
}
版权声明：本文为博主原创文章，未经博主允许不得转载。