问题标签 [akka-remote-actor]

我有以下情况：

• Akka 远程系统 A
• Akka 远程系统 B

B 是一个分析引擎，它向 A 发送早午餐并忘记消息。系统 B 在分析后停止。

但是如果B在分析之后调用system.shutdown，并不是所有的消息都会传递给A。B的actor系统是否在缓冲消息？

我如何能够确保所有 B 邮件现在都在 A 的收件箱中？我可以确定 B 何时可以安全断开连接吗？如何正确断开 B 与 A 的连接？

感谢您的任何建议！

我们正在考虑使用 Akka 进行客户端服务器通信，并尝试对数据传输进行基准测试。目前我们正在尝试发送一百万条消息，其中每条消息都是一个包含 8 个字符串字段的案例类。

在这一点上，我们正在努力获得可接受的性能。我们在客户端和服务器上看到大约 600KB/s 的传输速率和空闲 CPU，所以出现了问题。也许这是我们的网络配置。

这是我们的 akka 配置

更新：

最后，尽管讨论了序列化（见下文），但我们只是将有效负载转换为使用字节数组，这样序列化不会影响测试。我们发现在核心 i7 上使用 jeroMQ（即 zeroMQ 在 java 中重新实现 - 所以仍然不是最快的），在原始 akka 上我们始终看到大约 200k msgs/sec 或大约 20 MB/sec（即没有 zeroMQ 插件）我们看到大约 10k 消息/秒或略低于 1MB/秒。尝试使用 akka + zeroMQ 会使性能变差。

在使用 Spark 完成我的第一步时，我遇到了从应用程序代码提交作业到集群的问题。挖掘日志，我注意到主日志上有一些周期性的 WARN 消息：

问题是我们的网络上不存在 IP 地址，也没有在任何地方配置。当它尝试执行任务时，工作日志上会显示相同的错误 ip（错误的 ip 传递给 --driver-url）：

知道我做错了什么，如何解决？

Java 版本是 1.8.0_20，我使用的是预构建的 Spark 二进制文件。

谢谢！

嗨，我想包装 AskTimeOutException 并发送正确的消息....

请建议我正确的处理方法..

当 spark 使用 sbt 运行测试时。我得到这个例外：

首先我认为这是我的一个子库导入的错误版本的netty。

查看我的依赖图后，我发现了 4 个不同版本的 netty。 3.6.6 3.8.0 3.9.3 4.0.23

论文版本大多是spark自己导入的 :o4.0.23是spark直接导入的，s3.8.0是其子依赖的Akka-remote

我试图从我的所有子依赖项中排除 netty 依赖项，excludeAll( ExclusionRule(organization = "io.netty"))并逐个添加每个 netty 版本。但这并没有解决问题。我还尝试排除所有com.typesafe.akka使用的部门Akka-remote 2.4.0，我遇到了同样的问题。

所需的 netty 版本Akka-remote是3.8.0. 甚至强迫这个也行不通。我还强迫我的项目使用Akka-remote:3.8.0-spark不会改变任何东西的空间火花 Akka 版本。

有关我的 build.sbt 的信息

如您所见，我尝试排除最大的尝试

和子项目棚包含

我正在尝试为我的远程演员增加安全性。我设置了不受信任的模式： http ://doc.akka.io/docs/akka/snapshot/scala/remoting.html

是否可以添加 IP 过滤，只允许来自特定服务器的连接？例如，我有一个主设备和 10 个从设备，我只想让我的主设备（特定 IP）连接我的从设备。

在开源中，每个人都可以创建我的主人的新实例，并连接到我真正的奴隶。如何使其安全？

我的项目包含 2 个部分 - 一个是 akka server，另一个是 play framework。两者有时都可以重新启动。为了从 akka 服务器接收日志记录，我正在使用 Websocket 处理程序

与订阅某个远程演员的更改的演员。

远程记录器参与者对 subscribe() unsubscribe() 事件做出反应，并将记录消息发送到订阅的客户端。它工作正常，直到远程服务器没有挂起或刚刚重新启动。检测远程 akka 服务器断开连接的最便宜的方法是什么（之后我可以再次订阅新启动的记录器）。我可以构建一些 pinger 演员，如果我收到超时而不是再次尝试重新订阅，但简单的 ping 不能保证它们之间已经发生了重新启动，并且它们会使系统更加复杂。可能存在其他解决方案。

我想在同一台主机上设置几个演员系统。将来，一些演员系统可能会转移到另一台主机上。Actor 系统中的 Actor 相互通信。

我的想法是所有参与者系统（在同一主机上）共享一个配置文件，该配置文件可以定义为系统属性 config.resource，因此我不会混淆不同的配置文件。

但我不确定配置文件应该如何看起来最好。我可以定义演员路径（如“akka.tcp://actorSystemName@10.0.0.1:2552/user/actorName”），但这对创建演员没有帮助。它仅对作为远程参与者访问有用。我可以定义另一个变量 actorName 来创建。但后来我有一个actorName 的两个变量。

最好的方法是我认为为每个系统定义actorSystemName、主机和端口，为每个actor定义actorNames，然后从所有这些变量创建路径。但是通过这种方法，我认为不可能访问子角色。

你如何配置你的演员系统？你使用一个或几个配置？

通过在网上搜索，我可以进行单向对话，但是当接收方在其控制台中键入任何内容时，它会给出如下错误，并且还想知道分布式 akka 系统如何在 java 上工作，我从 [ https获得了一些帮助://github.com/petabridge/akkadotnet-code-samples] 但它在 .net 中。

请帮助我创建一个基于 java 的 distrebute akka 系统。

我已经制作了 2 个 Akka.NET 解决方案，希望在一个简单的 hello world 示例上测试 Remoting，但是，当进行通信尝试时，我不断收到 Disassociated 异常。我有理由相信这是因为共享类 Greet 应该是两个系统都应该理解的消息。不幸的是，他们没有。我怎样才能解决这个问题？

这是“服务器”应用程序的代码：

这是客户端的代码：

编辑：将客户端和服务器放在相同的解决方案但不同的项目中，并且在共享项目中的 GreetingActor 和 Greet 解决了这些问题。但是，我希望有完全独立的解决方案。