java - Akka EventBus for Java 示例

Question

我需要一些关于如何在 Java 中使用 Akka 提供的 EventBus(而不是 Scala!)的建议。我在 http://doc.akka.io/docs/akka/2.0.1/java/event-bus.html 中看过该文档

我尝试自己做，所以我在这里得到了这些代码:

public class Subscriber {

public static void main(String args[]){
    final ActorSystem actorSystem = ActorSystem.create("ServerEvents");
    final ActorRef actor = actorSystem.actorOf(new Props(ServerEventHandler.class));
    actorSystem.eventStream().subscribe(actor,ServerMessage.class);
    actorSystem.eventStream().publish(new ServerMessage());
}
  }


public class ServerEventHandler extends UntypedActor {
  @Override
  public void onReceive(final Object message) {
    System.out.println("Got event in thread: " + Thread.currentThread().getName());
    System.out.println("Event: " + message);
  }
}

问题是，我知道

actorSystem.eventStream().subscribe(actor,ServerMessage.class);
actorSystem.eventStream().publish(new ServerMessage());

ServerMessage()是sub/pub的 channel 和消息，但是ServerMessage类中的具体内容是什么？

如果你们能提供帮助，我们将不胜感激

谢谢!

Answer 1

ServerMessage 是示例事件类。基本上，只要您有一个订阅该类型事件的参与者，您就可以将任何类的任何实例放入其中(因此您自己的事件实现)。