问题标签 [akka-remoting]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
743 浏览

sbt - AKKA 集群:在 2 个远程节点之间发送和接收参与者消息

我有 2 个项目(sbt),比如说projectA and projectB。项目A 依赖于项目B。我如何配置 akka 集群,以便两个项目都使用参与者传递消息?projectA 和 projectB 都形成了一个带有种子节点的集群。

0 投票
0 回答
38 浏览

akka - Akka 远程处理无法启动

我是 Akka 的新手,我正在阅读 Jason Goodwin 写得很好的书 Learning Akka。他的例子虽然使用了激活器,但由于激活器已经消失,我从第 2 章重新创建了他的例子,没有激活器。问题是我的代码(没有激活器)没有开始远程处理。

我也下载了他的代码,它在做sbt clean publishLocaland之后就可以工作了sbt run。但是,如果我只是将他的 src/ 目录和他的 build.sbt 复制到另一个项目,我会遇到同样的问题。远程处理未启动。

我的客户也无法连接到正在运行的数据库(他的代码带有激活器)。

此代码全部基于 Akka 2.3。

我错过了什么?

0 投票
1 回答
96 浏览

scala - 无法与 Akka 建立远程通信

我最近才开始使用 Akka 和 Scala,我正在尝试制作一个实现基本 Akka 远程处理的简单项目。

当我在没有远程处理的情况下尝试以下代码时,一切正常,但是当我将数据库参与者放在远程参与者系统上但仍在同一台机器内时,出现错误“遇到死信”

这是在 hashmap 中存储数据的数据库 actor 的代码:

这是客户端的代码

0 投票
1 回答
55 浏览

akka - 为什么 Akka 不返回地址/主机信息?

Akka 2.5 在这里。我需要确定某个特定ActorRef对象是否与我的应用程序位于同一 JVM 上。我最好的尝试:

...正在true为我返回(它是空的;没有可用的地址/主机信息)。同样,我要做的只是确定someActor(这是一个ActorRef)是否是:(a)在应用程序 JVM 中运行,或者(b)它是否是一个远程参与者,住在另一个 JVM 中并通过 akka-aremote 与我的应用程序通信.

有一个更好的方法吗?我需要在里面配置一些东西application.conf才能让它工作吗?

0 投票
1 回答
112 浏览

akka-http - Akka-http 与 Akka-Remoting

我是 Akka 世界的新手,想了解 Akka-Remoting 和 Akka-HTTP 之间的区别。在安全性或维护方面,一个比另一个更好吗?实施其中一项时应考虑哪些事项?

0 投票
1 回答
199 浏览

c# - 为什么消息中的多个构造函数会导致 Akka.NET 无法传递?

我有一个使用 Akka.NET 远程处理的非常简单的实现。

具体来说,我有两个演员:

在大多数情况下,这些参与者似乎工作正常,问题出在我发送的消息中。

我的消息类大致如下所示:

但是,当我尝试使用此类发送消息时,出现错误

'与远程系统akka.tcp://client@localhost:2552的关联失败;地址现在门控 5000 ms。原因是:[Akka.Remote.EndpointDisassociatedException: Disassociated'

当我删除多个构造函数时,消息发送成功。

我在参考这个问题的文档中找不到任何东西,有人可以向我解释这个限制吗?

任何人都可以提供任何建议的解决方法吗?

0 投票
1 回答
99 浏览

scala - 如何通过akka中的ConsistentHashingPool向所有actor广播相同的字符串消息

我是 Akka 的新手,并且遇到了这个问题。

我有 4 个演员,但不知何故,广播消息总是发给一个演员

这是一个示例代码

请帮忙

0 投票
1 回答
443 浏览

f# - Akka.NET:给远程 Actor 的死信

我正在学习如何从另一台机器调用远程演员。为了模拟两台不同的机器,我有一台主机,另一台是虚拟机 (VM)。网络适​​配器设置为,NAT因为通过此设置,我能够从 VM ping 主机(我读到它应该设置为 Bridge,但 ping 命令超时)。

除此之外,这是RemoteActor.fsx主机上的代码

我首先执行了这个脚本,这是输出 在此处输入图像描述

这是LocalActor.fsx虚拟机上的代码

这是这个的输出 本地远程

现在RemoteActor.fsx抛出这个错误 错误

我在 Stack Overflow 上发现了一些有同样错误但无法解决的帖子。显然错误是因为在发送消息RemoteActor之前死亡。Local Actor同样在运行RemoteActor.fsx脚本后,如果我echoServer <! "Hello"RemoteActor终端中键入它,我也会收到同样的错误。

知道如何解决这个问题吗?任何帮助将不胜感激!谢谢!

0 投票
1 回答
56 浏览

akka - Akka 远程性能问题

我在 Akka 远程处理中面临性能问题。我有 2 个演员Actor1Actor2. Actor 之间发送的消息是来自to的同步请求请求和来自Actor1toActor2的响应。下面是我的 Actor 的示例代码片段和配置:Actor2Actor1

Actor1.java:

Actor2.java:

应用程序.conf:

输出:

我在这里做错了什么吗?有什么观察或建议可以提高性能吗?

0 投票
2 回答
38 浏览

akka - 我们可以在做询问时避免创建内部演员吗

Akka 文档在这里说: ask 操作涉及创建一个内部参与者来处理这个回复,它需要有一个超时时间,之后它会被销毁,以免泄漏资源

有什么办法可以阻止这种内部演员的创作?