Akka使用Java进行远程连接

我是Akka的新手，对Scala根本不熟悉。我正尝试使用Akka + Java在多台机器上运行项目。我能够在本地成功运行Akka Java示例，但是当我尝试在两台机器上运行它们中的任何一个时，代码停止工作。我也查看了Akka-Sample-Remote源代码。它也适用于单台机器，但在多台机器上使用时会中断。我认为问题在于我设置配置的方式。我已经将这个问题归纳为一个简单的HelloWorld问题，如下所示。Akka使用Java进行远程连接

将代码分成两个项目，并带有两个单独的配置文件：Hello Actor项目和World Actor项目。 World Actor等待接收来自Hello Actor的Hello消息，然后打印出“Hello World”。下面您可以看到这两个项目的代码和配置。正如你所看到的，世界演员是在1719端口启动的，而你好演员在1720端口启动，并尝试使用“akka.tcp：//[email protected]：1719/user/WorldActor”连接到世界演员。想知道他的代码/配置有什么问题吗？

JWorld.java：

public class JWorld { 

    public static void main(String[] args) { 
    JWorldApplication app = new JWorldApplication(); 
    System.out.println("Started World Application - waiting for Hello message"); 
    } 

}

JWorldApplication.java：

import akka.actor.ActorRef; 

import akka.actor.ActorSystem; 
import akka.actor.Props; 
import com.typesafe.config.ConfigFactory; 

public class JWorldApplication { 
    private ActorSystem system; 

    public JWorldApplication() { 
    system = ActorSystem.create("WorldApplication", ConfigFactory.load() 
     .getConfig("WorldConfig")); 
    ActorRef actor = system.actorOf(new Props(JWorldActor.class), 
     "WorldActor"); 
    } 
}

JWolrdActor.java：

import akka.actor.UntypedActor; 


public class JWorldActor extends UntypedActor { 
    @Override 
    public void onReceive(Object message) { 

     if (message instanceof HelloMessage) { 
      HelloMessage recMsg = (HelloMessage) message; 
      System.out.println("Received Message: " + recMsg.getText()); 
      System.out.println("***** Hello World! ******"); 
     } else { 
      System.out.println("UnHandled Message Received"); 
      unhandled(message); 
     } 
    } 

}

HelloMessage.java：

import akka.actor.ActorRef; 

public class HelloMessage{ 
    private ActorRef receiver; 
    private String text; 
    HelloMessage() {} 
    HelloMessage(ActorRef receiver){ this.receiver = receiver;} 
    public ActorRef getReceiver(){ return receiver;} 
    public void setText(String text) { this.text = text;} 
    public String getText() {return text;} 
}

Application.conf：

WorldConfig { 
    actor { 
    provider = "akka.remote.RemoteActorRefProvider" 
    } 

    remote { 
    netty.tcp { 
     hostname="192.27.336.187" 
     port=1719 
    } 
    } 
}

JHello.java：

public class JHello { 

public static void main(String[] args) { 
    JHelloApplication testApp = new JHelloApplication(); 
    System.out.println("Started Hello Application - Sending Hello Message"); 
    testApp.sayHello(); 


} 
}

JHelloApplication.java：

import akka.actor.ActorRef; 
import akka.actor.ActorSystem; 
import akka.actor.Props; 

import com.typesafe.config.ConfigFactory; 

public class JHelloApplication { 
    private ActorSystem system; 
    private ActorRef remoteActor, myActor; 

    public JHelloApplication() { 
     system = ActorSystem.create("HelloApplication", ConfigFactory.load() 
       .getConfig("HelloConfig")); 
     myActor = system.actorOf(new Props(JHelloActor.class),"HelloActor"); 
     remoteActor = system 
       .actorFor("akka.tcp://[email protected]:1719/user/WorldActor"); 
    } 

    public void sayHello() { 
     myActor.tell(new HelloMessage(remoteActor)); 
    } 

}

JHelloActor.java：

import akka.actor.ActorRef; 
import akka.actor.UntypedActor; 

public class JHelloActor extends UntypedActor { 

    @Override 
    public void onReceive(Object message) { 
     if (message instanceof HelloMessage) { 
      HelloMessage msg = (HelloMessage) message; 
      if (msg.getReceiver() !=null){ 
       msg.setText("Hello"); 
       msg.getReceiver().tell(msg, getSelf()); 
      } 
     } else { 
      System.out.println("UnHandled Message Received"); 
      unhandled(message); 
     } 
    } 

}

APPLI cation.conf：

HelloConfig { 
    actor { 
    provider = "akka.remote.RemoteActorRefProvider" 
    } 

    remote { 
    netty.tcp { 
     hostname="192.27.336.187" 
     port=1720 
    } 
    } 
}

来源

2013-03-19 reza

这已在akka邮件列表中得到解答：https：//groups.google.com/d/msg/akka-user/1tLBTZdo8tA/bhCqkilFlxcJ – 2013-03-20 09:29:27

正如Patrcik所提到的，问题最终由Patrik在Akka组中回答。问题在于两个配置文件都缺少Akka {}标记。添加此标签可解决问题。

来源

2013-03-22 20:35:13 reza

Akka使用Java进行远程连接

回答

相关问题