问题标签 [akka-remote-actor]

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 投票
2 回答
534 浏览

scala - 如何给出找到远程演员的准确路径

我正在关注本教程

http://alvinalexander.com/scala/simple-akka-actors-remote-example

我照原样关注它,但我的程序没有运行它给我错误,我对这一行感到困惑:

我必须写什么来代替“用户”?例如,当我将完整路径写到末尾时:

并运行 hellolocal 和 helloremote 都给我关于查找该地址的演员的错误。

如果我按原样编写代码,它会给我错误 helloremote erros :

hellolocal 错误:

0 投票
1 回答
2382 浏览

scala - Akka Remote Actors-:无法在本地和远程 Actor 之间建立连接

嗨,我正在关注这个教程,我照原样复制粘贴了代码,除了我将端口从 5150 更改为 2552 并且我遇到了这些错误 HelloLocal 项目错误

HelloRemote 项目错误是:

我是akka的新手,出于学习目的,我正在关注本教程,现在有错误请帮助我解决它们

在遵循 akka-remitng 2.3.6 之后进行编辑现在我遇到了不同的错误 aplication.conf (helloLocal)

HelloLoca.scala 导入 akka.actor._

和 HelloRemote application.conf 是

这些是现在的错误 HelloLocal

HelloRemote 错误是

0 投票
1 回答
816 浏览

android - 无法启动活动:找不到密钥“akka.version”的配置设置

在我的项目中,我想使用远程参与者,并成功地尝试和测试了它们作为 Scala-SBT 项目。

但是,当我尝试在 Android 中做同样的事情时。出现以下错误

这是加载配置并用于 Scala-SBT 项目的代码

对我来说似乎很明显的问题是 akka.remote 的 reference.conf 没有被使用。

PS:我确实尝试将 akka.remote 的 reference.conf 的内容复制到 ConfigFactory.parseString() 但它没有用

请帮助解决这个问题。

0 投票
1 回答
2976 浏览

java - Akka 远程路由主机名配置问题

我正在为我正在制作的工具体验 akka 远程功能。实际上,我能够使核心系统和远程系统在具有不同端口的同一主机上工作。请注意,我的远程服务器通过路由器运行,如 akka 文档中所述。

现在我正在尝试使用几个 azure 虚拟机来进行更好的实验,但我遇到了一些问题。

核心应用程序具有以下配置(出于安全原因,我更改了一些名称):

而远程主机具有以下配置:

使用此配置,服务器和远程主机显然能够通信,但远程主机开始记录一些错误:

过了一会儿,服务器和远程主机开始记录错误并冻结。

服务器错误:

远程错误(多次类似的行):

我发现问题可能出在主机名配置中,并尝试将主机名放入服务器和远程主机。但是,在这种情况下,系统甚至不会加载:

我不知道我做错了什么。我试图查找有关该问题的信息,但我发现的任何内容都与我的问题有关。我也打开了 Azure 配置的端口。

如何使我的服务器主机能够与我的远程主机正确通信?

0 投票
0 回答
656 浏览

scala - Akka Remoting:无法序列化演员

设置

使用 Akka ( 2.3.9 ) 远程处理。

我有一个 io.Tcp akka 系统,它与另一个远程后端 akka 系统通信。

问题是远程发回的消息永远不会到达 tcp 系统。

Front ( Tcp ) 系统在收到连接时注册一个“follower”类。

Follower 识别(成功)远程后端系统,然后转发接收到的数据

来自追随者的片段:

远程系统侦听 Received 案例,然后将回复写入发件人。

问题

一切正常,远程 akka 系统正确读取接收到的数据,对其进行处理,但在写回结果时会自行处理。

任何想法出了什么问题?

更新:

我现在从遥控器传回一个确认(在后端系统中)

现在我被告知远程 Actor(此日志中的 MyHandler )不可序列化:

MyHandler 不应该是自动序列化的,因为它是一个演员吗?

更新 2

我现在只是等待向遥控器“询问”的结果:

0 投票
1 回答
463 浏览

scala - Akka-cluster 发现本地网络中的其他机器

我正在尝试在连接到本地网络的几台机器上运行http://typesafe.com/activator/template/akka-distributed-workers 。

我希望主机配置尽可能透明,所以我在我的项目配置中设置linux.local(作为 netty.tcp.hostname 和种子节点),并且在每台机器上都有一个解析linux.local到适当 IP 地址的 avahi 守护进程。

akka-cluster/akka-remote 是否应该使用 gossip 协议或以上配置自动发现其他机器将不起作用,我需要在每台机器上显式设置 IP 地址,例如通过参数传递它?

0 投票
1 回答
107 浏览

akka - Is DistributedPubSub mediator stashing the messages for unreachable members of the cluster

In a clustered environment, we are sending the message through DistributedPubSub mediator. So, we've some machines which are unreachable in the cluster, when the message was sent. And these machines comes reachable again before the "autodowning" has expired, then these machines do get the messages.

Does this mean that DistributedPubSub mediator stashes the messages for the unreachable members of the cluster and delivers them when they become reachable again?

0 投票
0 回答
206 浏览

scala - 如何访问 akka.routing.Router?

我正在使用application.conf中的路由器配置创建路由器。

在某种情况下,我需要手动删除路由并将路由添加到我的路由器。我在 akka-scala 文档(链接)中看到,使用removeRouteeandRoutee我们将能够实现它。

但由于我使用配置创建路由器,我可以使用以下代码选择路由器。

在未来 onComplete Success 调用它返回akka.routing.RoutedActorRef。如何访问创建的akka.routing.Router?或者无论如何我可以将它转换为路由器对象?

非常感谢您提前。

0 投票
1 回答
290 浏览

akka - Akka 集群成员查询

使用akka集群,是否可以查询集群中当前有哪些成员?如果种子节点出现故障,最终又恢复了,它能否找出其他成员正在使用它作为种子节点吗?

0 投票
0 回答
72 浏览

akka - GridEngine 或 Akka

我正在构建一个依赖于第三方产品 (TPP) 执行的某些处理的应用程序。此 TPP 的分销商建议将其部署在 GridEngine 上(用于并行化等...)

这个 TPP 的接口将是一个基于 Scala 和 Akka 的 REST API。

假设处理类似于将处理移交给数据库或类似的 TPP,我是否能够完全使用 Akka 及其负载平衡、路由、集群和远程 Actor 功能而不是 GridEngine 来实现这种并行化?

我对 GridEngine 的理解是它提供了集群管理工具。它管理从站之间的负载,你交给它一个工作来完成,它分配给一个可用的从站。仅使用 Akka 就可以实现这一切吗?是否有任何特定的理由选择 GridEngine?

谢谢