如果我没有明确调用它们，那么如何在 jgroups 中调用 ReceiverAdapter

Question

我编写了以下类来创建 JGroup 集群：public class TestClient extends ReceiverAdapter {JChannel channel;private void start() throws Exception {    channel=new JChannel().setReceiver(this);    channel.connect("ChatCluster");    eventLoop();    channel.close();}private void eventLoop() {    while(true) {    }}public void viewAccepted(View new_view) {    System.out.println("** view: " + new_view);    System.out.println("Get Coord"+new_view.getCoord());    System.out.println(new_view.getMembers());}public void receive(Message msg) {    System.out.println(msg.getSrc() + ": " + msg.getObject());}public void getState(OutputStream output) throws Exception {}public void setState(InputStream input) throws Exception {}}ReceiverAdapter 是一个 Jgroups 定义的类：public class ReceiverAdapter implements Receiver {public ReceiverAdapter() {}public void receive(Message msg) {}public void receive(MessageBatch batch) {    Iterator var2 = batch.iterator();    while(var2.hasNext()) {        Message msg = (Message)var2.next();        try {            this.receive(msg);        } catch (Throwable var5) {            ;        }    }}public void getState(OutputStream output) throws Exception {}public void setState(InputStream input) throws Exception {}public void viewAccepted(View view) {}public void suspect(Address mbr) {}public void block() {}public void unblock() {}}我的问题是如何在视图更改或发送/接收消息时调用 ReceiverAdapter 类中的这些方法，因为我不需要显式调用这些方法。JGroups 是否实现了某种事件侦听器？

Answer 1

如果我正确理解了您的问题，我认为您已经解决了您的问题。您需要将您的 Receiver 实现显式传递给您想要使用它的 JChannel：

Receiver receiver = new MyReceiverImplementation();
JChannel jChannel = new JChannel().connect("clusterName").receiver(receiver);

JGroups 不会自动寻找要注入的接收器。