问题标签 [akka-cluster]

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 回答
398 浏览

akka - 解析集群 Actor 系统中的路径

我有 3 个演员的层次结构: SM -> R -> W SM - 服务经理 R - 路由器 W - 工人

SM 创建了 R 角色,而后者又创建了部署在远程节点上的角色 W。

创建 Actor W 需要一些时间,因为它从外部服务收集信息,因此延迟几秒钟是正常的。因此,preStart()我想从 W 向 SM 发送一条消息,说明 init 已完成并且可以完全运行。

我试图通过这种方式从 W 联系到 SM 演员:

所有这些消息都会进入 deadLetter 收件箱。如果我错了,请纠正我,但本地化不应该是透明的吗?联系SM演员的正确方式是什么?

如果它有任何帮助,这里是死信日志

0 投票
1 回答
790 浏览

scala - 使用手动加入时 Akka 集群不启动

我有一个应用程序,我无法提前知道种子节点以放入应用程序配置中。因此,应用程序在一个节点上启动,当它在其他节点上启动时,它们使用 Cluster.join 在第一个节点上加入集群。问题是连接永远不会完成,集群永远不会启动。问题是什么?

0 投票
1 回答
1156 浏览

akka - 在集群中的任何未指定/随机节点上创建参与者

如果您指定了确切的节点,则可以通过编程方式在远程节点上创建参与者

但是,我想简单地要求演员系统在随机的,或者可能是使用最少的节点上创建一个演员。

是否可以在给定可选节点角色的任何远程节点上创建参与者?

0 投票
2 回答
1952 浏览

cluster-computing - Akka cluster: Get status information on nodes

Given an Akka ActorSystem object, how can you find out what other nodes are active in the cluster, and what their status is?

Thank you, - Daniel

0 投票
0 回答
157 浏览

akka - Akka Clustering 的一致性 SLA 是什么?

假设在我们开始测量的点之外没有进一步的成员变化,我如何确定整个 Akka 集群中集群成员状态不一致的最大时间长度?

我意识到这取决于几个因素,所以我正在寻找一种在给定所有必需变量的情况下计算最坏情况的方法。

0 投票
1 回答
1389 浏览

scala - 无法让 akka 在 2 台不同的机器上运行 - 无法分配请求的地址

我是一个 akka 菜鸟:我试图以 akka-sample-cluster-scala transformatino 为例并将其打破以在 2 台机器上运行。

我相信我可以通过配置来做到这一点。我怀疑是我太天真了。

我也在 vm 中运行这些,这些 vm 的网络设置正确,因此 ip 范围很奇怪。有一个域,所以我同时使用 NAT 和仅主机网络。这可能是一个问题,但我相当肯定它不会是这样。

我也从 netstat 知道这不是因为其他东西有端口。nmap -p 2550 192.168.56.101 表示端口在后端运行时打开

我不明白为什么前端试图连接到 2551 上的主机(当我通过它 2550 时它失败并出现同样的异常(下))

所以我把 akka-sample-cluster-scala/src/main/resources/application.conf 改成这个 所以在'master'上

在“奴隶”上(它们是相同的)

然后我想要后端运行的地方我正在这样做

而在另一端

我怀疑我完全糊涂了,这对任何阅读的人来说都是胡说八道。如果您能帮助启发我,不胜感激。

错误是在一台机器上,后端似乎已启动并坐在那里等待

在客户端我收到以下异常

0 投票
2 回答
3405 浏览

scala - 选择 Akka 或 Spark 进行并行处理?

在选择并行化任务时,我通常使用 Spark。阅读有关 Akka 并行处理的文章,例如http://blog.knoldus.com/2011/09/19/power-of-parallel-processing-in-akka/似乎使用 Akka 进行并行化处于较低水平。Spark 似乎从用户那里抽象了一些较低级别的概念,例如 map reduce。Spark 为分组和过滤数据提供了高级抽象。Akka 在并行化任务方面是 Spark 的竞争对手,还是他们在解决不同的问题?

在决定使用哪个之前,我应该考虑什么?

0 投票
1 回答
604 浏览

akka - Akka Actor 跨 JVM 和服务器扩展,akka.io 上的示例

我发现Akka 登陆页面上提供的 Akka 远程处理的介绍性示例作为介绍有点难以理解,并且学习远程处理的来龙去脉所需的文档长度因介绍性目的而结构不正确。

下面是来自上述示例的代码,我想要求在一些公平的上下文中描述该代码的含义,同时涉及是否可以远程向任何参与者发送消息的问题,就好像它是本地的一样只需要仅仅改变配置。先前关于这最后一点的答案似乎与当前的 Akka 文档有些矛盾,而文档本身对这一点有些不确定。

因此,对这个示例代码的介绍性解释也会非常有帮助。一个解释应该希望能够选择一个可以在单个 JVM 内以及跨 JVM 和服务器边界轻松扩展的参与者架构,而不是进入几天甚至更多的实验模式。

谢谢!

0 投票
1 回答
103 浏览

scala - 向现有成员添加角色?

我正在查看 Akka 源代码。有一种方法可以获取成员的角色 ( .getRoles),但是有没有一种方法可以向现有成员添加新角色?我想使用代码而不是通过配置动态添加它。

0 投票
1 回答
1062 浏览

playframework - 从 Play 控制器调用 Akka 演员

我一直在使用分布式工作模式,并且遇到了从 Web 请求推送工作的问题。

示例项目有一个前端:

还有一个 WorkProducer:

当我从 Play Framework 控制器直接发送到前端时,这一切都很好:

消息似乎丢失了。前端收到消息,但下游的演员似乎没有。

我已修改播放配置以使用 ClusterActorRefProvider

但无济于事。