Akka简单群集示例

Question

我是Akka的新手。我正在尝试Akka Java Doc中的第一个集群示例。代码如下：

import akka.actor.ActorRef; 
import akka.actor.ActorSystem; 
import akka.actor.Props; 
import akka.actor.UntypedActor; 
import akka.cluster.Cluster; 
import akka.cluster.ClusterEvent.ClusterDomainEvent; 

public class SimpleClusterApp { 
    public static void main(String[] args) { 
    // Override the configuration of the port 
    // when specified as program argument 
    if (args.length > 0) 
     System.setProperty("akka.remote.netty.tcp.port", args[0]); 

    // Create an Akka system 
    ActorSystem system = ActorSystem.create("ClusterSystem"); 

    // Create an actor that handles cluster domain events 
    ActorRef clusterListener = system.actorOf(Props.create(SimpleClusterListener.class), "clusterListener"); 

    // Add subscription of cluster events 
    Cluster.get(system).subscribe(clusterListener, ClusterDomainEvent.class); 
} 
} 

但它不能工作。 Eclipse抱怨SimpleClusterListener.class无法解析。有谁能告诉我，我怎么能找到这个班？ 非常感谢您

Answer 1

从http://doc.akka.io/docs/akka/2.2.3/java/cluster-usage.html：

的阿卡集群是一个独立的jar文件。请确保你在你的项目中的以下[Maven的]依赖性：

<dependency> 
    <groupId>com.typesafe.akka</groupId> 
    <artifactId>akka-cluster_2.10</artifactId> 
    <version>2.2.3</version> 
</dependency> 

Answer 2

的全部源代码，不包含在文档中（即我所看到的，反正）。

但它是在Git仓库：https://github.com/akka/akka/tree/master/akka-samples/akka-sample-cluster-java/src/main/java/sample/cluster/simple

希望帮助:)