akka-cluster 相关问题

Akka集群是一种新的(2.1+)功能,允许用户在Akka中间件之上构建集群功能。

降低akka群集中节点/成员的正确方法

当节点在akka群集中变得无法访问时,是否有任何适当的方法来关闭该节点。当某个节点变得无法访问时,我想向其暴露一个api,但我更喜欢寻找另一种方式...

回答 1 投票 1

检查akka actor是否存在于集群中

public void actorExists()throw ActorNotFound {FiniteDuration duration = Duration.create(3,TimeUnit.SECONDS);字符串actorPath =“ akka:// test / studentid”; Await.result(actorSystem ....

回答 1 投票 -1

Akka文档尚不清楚如何获取ExtendedActorSystem以反序列化ActorRef

我正在尝试通过protobuf序列化/反序列化ActorRef。根据Akka的文档,唯一的方法是将ActorRef转换为String,然后将其转换回远程actor ...

回答 1 投票 9

akka型和集群分片支持哪些持久性插件

我正在使用Akka Typed(2.6.0版)和事件源,并且我能够使其与LevelDB插件一起使用。由于我打算使用集群环境,因此LevelDB不适用于...

回答 1 投票 0

AKKA.NET:是否可以在多个正在运行的应用程序上创建唯一的actor?

我正在构建一个Asp.net Core API,它将在多个服务器实例上运行,我的问题是确保使用AKKA.NET在所有运行的应用程序中创建唯一的Actor并发送一个...

回答 1 投票 0

Remote Sender akka Actor在其他群集中30秒后终止

使用ClusterClient.Send,将消息发送到远程actor。远程参与者接收消息并将发件人存储在本地变量中。 30秒后,远程发送方终止。详细信息:两者...

回答 1 投票 0

如何解决在肉桂中出现的部分结果(光弯遥测)

我在三个docker容器之间运行akka集群。我正在运行肉桂以捕获一些遥测,而我遇到的情况是只有池大小,活动线程,运行线程和...

回答 1 投票 0

如何使两个actor系统在docker中运行以形成集群

我正在努力了解Akka和Akka群集。到目前为止,到目前为止,我已经能够创建两个actor系统,并且当我分别在两个不同的环境中分别启动每个actor系统时,它们可以组成一个集群。

回答 1 投票 0

kubernetes k8s上的Akka。停机的不可达节点的调度

在k8s上运行Akka集群,它正在使用下降策略(例如,自动下降),因此,在节点不可达的情况下,不可达的容器退出。问题是...

回答 1 投票 0

使用kubernetes-api发现失败的Akka群集加入

我已经进行了一些尽职调查,甚至研究了Akka代码,但无法弄清楚为什么是通过kubernetes-api发现我的节点的,其中一个节点自我连接,晋升为领导者,但另一个未能.. 。

回答 1 投票 0

从远程部署的actor发送消息时,不相关的ActorRef上的死字母

我遇到了一个问题,即在应用程序运行了一段时间后,发送给akka群集中的远程参与者的消息具有很高的延迟(10+ s)。日志建议提供者尝试......>

回答 1 投票 0

为什么Akka Sharding的“ majority-min-cap”默认设置为5?

我们团队中的我们目前正在考虑是否敢于更改默认设置akka.cluster.sharding.distributed-data.majority-min-cap = 5这经常使Akka分片卡在滚动中...

回答 1 投票 0

如何将Akka集群部署到Kubernetes?

我写了一个小应用程序,它支持Akka Cluster的群集。我想通过支持扩展将其部署到Kubernetes。这是我的docker-compose.yml文件:版本:'3.5'网络:cluster -...

回答 1 投票 0

为什么用父母的名字,如阿卡拆分的PersistenceId的一部分?

我看着分片例如,发现父母的名字被用作PersistenceId的一部分吗? PersistenceId = Context.Parent.Path.Name + “ - ” + Self.Path.Name;我的问题:是对...

回答 1 投票 0

因为'Akka.jvm-exit-on-fatal-error'为ActorSystem [mpe]启用而关闭JVM java.lang.StackOverflowError:null

我正在开发一个需要接受小于1,00,000阈值的SOAP XML请求的修复程序。这样我们就可以在处理之前验证大型xml文档。现在,我对...感到困惑

回答 1 投票 0

阿卡的有状态演员

假设我想用Akka创建一个聊天系统。在系统中,我可能有一个UserActor来管理特定用户的所有消息。如果我现在在Akka集群中部署它,我怎么能......

回答 1 投票 2

Akkalar没有看到对方

在Akka中,我向群集添加了两台不同的计算机。但是有一些问题。如果两台机器同时站起来,那么两侧就会离开而不能看到对方。或者因为......

回答 1 投票 0

如果akka演员出于某种原因失败,如何恢复消息?

我想解决两个场景:我有一个发送者Actor和一个Receiver Actor,发送者actor将如何知道接收者actor没有响应.Terminated case'可用于获取通知......

回答 1 投票 1

如何知道Akka Cluster Client的初始联系人?

Akka Cluster Client需要一个可以联系的初始节点列表,以便与群集保持联系。似乎必须提供至少一个确切的节点地址和端口。在我们的 ...

回答 1 投票 8

AkkaCluster:已终止与MemberRemoved消息

我正在使用akka集群,并且无法确定何时使用Terminated消息来确定成员已离开集群与使用UnreachableMember / MemberRemoved消息。什么 ...

回答 1 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.