3

Akka が提供する EventBus を Java (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 へのチャネルとメッセージですが、ServerMessage クラスの正確な内容は何ですか??

皆さんがお役に立てば幸いです

ありがとう！

4

1 に答える 1

0

ServerMessage はサンプル イベント クラスです。基本的に、そのタイプのイベントにサブスクライブしているアクターがある限り、そこに任意のクラスの任意のインスタンスを配置できます (つまり、独自のイベント実装)。

于 2012-08-10T12:18:14.140 に答える