问题标签 [akka-remote-actor]

我遇到的问题是我可以在另一台从机上创建系统。但我不知道如何将零件分配到不同的机器上。IE master、slave1 和 slave2 最终都在同一台机器上，而不是分别位于 101,102 和 103 上。

我正在使用主服务器从本质上管理通过多个服务器的消息工作流。所以主服务器启动创建主服务器参与者，然后执行以下操作：

• 掌握：
1. 向从站 1 发送启动消息
2. 从从站 1 获取成功消息并将消息传递给从站 2
3. 从slave 2获取成功消息然后关闭系统
• Slave1：从服务器获取消息并成功回复主服务器
• Slave2：从服务器获取消息并成功回复主服务器

后来我想水平缩放这些中的每一个 - 但是在此之前遇到了一个问题。所有远程的东西只能在一台机器上运行。

我正在使用远程，因此部分配置如下所示：

创建actorSystem和主actor的代码

然后在主actor内部我使用slave1，当它收到一条消息时这样做：

所以我可以将系统全部托管在一台机器上。我也可以在一台机器上启动它并让它在另一台远程机器上运行。但是我不能让配置中的每个参与者都在不同的机器上运行。

我很愚蠢，但看不到以什么方式！;)

我注意到 Akka 2.3.2 没有 akka-remote-test-experiment。任何人都可以向我建议如何解决这个问题：

我正在使用 play framework 2.2.2，我想添加 Akka 远程库。哪些版本兼容？

我可以使用 Akka 远程 2.3.3 吗？

==== 更新

我正在添加 akka 远程依赖项：

我必须在播放框架中更改 akka 版本吗？

我有一个使用自定义参与者系统的 J2EE 应用程序，我需要外部化一些自定义配置。

有没有办法做到这一点？因为application.conf总是在类路径上，所以我可以加载一个外部custom.properties文件并像下面一样使用它

I am getting this error when trying to run my akka application:

[ERROR] [06/30/2014 15:58:14.591] [Thread-3] [RemoteActorRefProvider] Error while looking up address [akka://FooPar0@127.0.0.1:2552] akka.remote.RemoteTransportException: No transport is loaded for protocol: [akka], available protocols: [akka.tcp] at akka.remote.Remoting$.localAddressFo rRemote(Remoting.scala:88) ...

My sbt project has the following build.sbt:

name := "FooPar"

version := "0.1"

scalaVersion := "2.11.1"

resolvers += "Typesafe Repository" at "http://repo.typesafe.com/typesafe/releases/"

resolvers += "Sonatype Releases" at "http://oss.sonatype.org/content/repositories/releases"

libraryDependencies += "com.typesafe.akka" %% "akka-actor" % "2.3.4"

libraryDependencies += "com.typesafe.akka" %% "akka-remote" % "2.3.4"

libraryDependencies += "org.scalacheck" %% "scalacheck" % "1.11.4" % "test"

Finally, the generated configuration string for my application looks like this:

Can someone help me locate the problem? I am following this guide here http://doc.akka.io/docs/akka/2.3.4/scala/remoting.html, but it seems, my configuration file is just as it should be

As a response to Mario:

I am instantiating the ActorSystem from the config-string listed above and then via this code:

That is, I do not create Address objects explicitly.

我正在用 Scala 中的 Akka 演员构建一个库，以进行一些大规模的数据处理。

我正在使用 StarCluster 在 Amazon EC2 现货实例上运行我的代码。该程序不稳定，因为远程执行的演员有时会掉线：

在代码运行时，节点会在几分钟内一个接一个断开连接。节点说类似：

和

即使我可以在节点之间 ping 也很好。

我一直在努力解决这个问题；我认为这是一些配置设置。Akka 远程处理文档甚至说，

但是，在 Amazon EC2 等云环境中，该值可能会增加到 12，以解决此类平台上有时会出现的网络问题。

但是，我已经设置了这一点，但仍然没有解决问题的运气。这是我当前的远程配置：

我从主节点部署我的演员：

谁能指出我正在犯的错误/如何解决此问题并阻止节点断开连接？或者，如果演员断开连接，重新启动演员的一些解决方案也有效；我不太关心丢失的消息。事实上，我认为这应该是一种易于配置的行为，但我发现很难找到合适的位置来寻找它。

谢谢

最近我在我的项目中实现了远程演员模式。我想知道哪种方式同时运行演员。

方式1。

方式2。

顺便说一句，我打印出线程名如-akka.actor.default-dispatcher-4，但是dispatcher一直没有到100，为什么？

非常感谢

从下面的运行日志中，它说远程启动正常并监听 2552 端口：

但是telnet那个端口失败了。这是否意味着无法使用 telnet 验证远程，或者
远程处理有问题？正在尝试 127.0.0.1... telnet：无法连接到远程主机：连接被拒绝

我创建了这个演员：

现在，我想检索道具 1，但我不能。你能帮助我吗？？

我的应用程序需要与大量客户端（它们是安装在用户机器上的 java 代理）进行双向持续通信，此外它还包括一个 spring mvc webapp，它提供了一个标准的 jsp UI 来管理这些代理。我只看了 java akka 的基础知识（没有时间为这个项目学习 scala）。但处理大量客户代理似乎是一个不错的选择。我查看了 akka spring 集成模块和 akka-spring-java 示例，在 spring 端使用 akka 似乎非常简单。

我认为在客户端代理端使用akka远程处理也可能是一个好主意，可能嵌入在另一个应用程序中的代理基本上运行一个线程需要监视用户jvm中的各种进程并与服务器上的服务进行通信。使用位置透明度将在概念上简化架构，并且可能更有效。

本文表明这可能不是正确的方法

点对点与客户端-服务器

使用远程处理的替代方法是使用似乎与 akka spring 集成模块相关联的骆驼 websockets。

鉴于它的技术堆栈，在我的应用程序的上下文中采取的最佳方向是什么？