问题标签 [akka.net-cluster]

我们正在开发一个项目来处理金融交易。我们希望在这些事务所在的三台机器上拥有一个“分布式内存”。所有机器都将拥有自己的事务副本，因为事务更新请求可能会到达这些机器中的任何一台。

我们正在考虑使用 Akka.net 集群来尝试解决这个问题。有没有办法在 Akka 集群中使用每个实体的子模式（所有事务都通过它们自己的事务 ID 访问，我们希望事务参与者不必从磁盘加载任何内容）？

我对我的 PoC 进行了一些性能测试。我看到的是我的演员没有收到发送给他的所有消息，并且性能非常低。我向我的应用程序发送了大约 150k 条消息，这导致我的处理器达到 100% 的利用率峰值。但是当我停止发送请求时，2/3 的消息没有传递给参与者。以下是来自应用洞察的简单指标：

为了证明我在 mongo 中持久化的事件数量与我的演员收到的消息几乎相同。

其次，处理消息的性能非常令人失望。我每秒收到大约 300 条消息。

我知道默认情况下 Akka.NET 消息传递最多一次，但我没有收到任何错误说该消息被丢弃。

这是代码：集群分片注册：

控制器：

演员：

消息路由器。

akka.conf

目前我正在使用 dockerhub 上的 akka.net lighthouse docker 镜像。与 Akka.Bootstrap.Docker 一起，可以很好地从环境变量中覆盖 akka hocon 配置。我在我的 k8s 部署文件中设置了以下环境变量

但是，如果我想启用 hyperion 序列化，它会失败并显示以下消息：

序列化程序“hyperion”的类型名称未解析为实际类型：“Akka.Serialization.HyperionSerializer, Akka.Serialization.Hyperion”

Akka.NET Lighthouse 的文档非常稀缺，所以你们中的任何人都知道如何将 hyperion 序列化与 Akka.NET lighthouse 一起使用吗？

Im using distributed pub/sub in an Akka.net cluster and I've begun seeing this error when pub/sub grows to approx. 1000 subscribers and 3000 publishers.

max allowed size 128000 bytes, actual size of encoded Akka.Cluster.Tools.PublishSubscribe.Internal.Delta was 325691 bytes

I don't know, but I'm guessing distributed pub/sub is trying to pass the pub/sub list to other actor systems on the cluster?

Anyway, I'm a little hesitant about boosting size limits because of this post. So what would be a reasonable approach to correcting this?

我们在我们的项目中使用 akka.net 进行分布式工作服务。我们使用 Blazor 应用程序作为 UI（具有 API 角色的参与者系统）和 dot net core worker 服务多个实例（具有 WLM 角色的相同参与者系统）。一切正常，但是我们在服务稳定性方面存在问题。一些服务节点因消息而间歇性关闭 - 远程对等点重置连接。在这种情况下，我们无法找到这种分离的根本原因。请告诉我们提高系统稳定性的方法。此外，有没有办法记录系统解除关联的根本原因。

提前谢谢了。

我对 AKKA.NET 将“SampleActor”制作为“CustomCluster”中的单例有一个有趣的问题。不会引发异常或警告。在调试过程中，我无法将 SampleActor 初始化为集群单例，即使在单元测试中，我也能够以完整路径毫无问题地将该 ActorRef 获取到该演员，但该演员似乎没有初始化（构造函数和其他“OnStart”类型的功能没有被击中。我已经尝试直接向参与者“告诉”消息，以普通方式使用它（如集群中的“OrdinaryActor”）它正在接收这些消息并且运行良好。通过代理发送消息并使用完整的actor ref路径不工作，我确信这是因为演员没有被初始化。

在这一点上我错过了什么？有完整的配置akka.cluster.singleton，我尝试了许多不同的方法。

我们的集群在本地运行（目前），一切似乎都配置正确。我们的主要计算消息分布在我们的种子节点上。但是，我们会间歇性地丢失消息。您可以在屏幕截图中看到两次运行的行为。哪些消息被标记为死信完全不一致。

我们的消息总是以相同的方式发送，它们看起来像这样。最后一个参数表示要找到的第 n 个素数。

我们的集群是这样设置的：一个非种子节点，它是一个组路由器，向两个种子节点发送消息，这两个种子节点被配置为池路由器。

非种子节点：localhost:0（随机端口）

种子节点 1: localhost:8081 (leader)

种子节点 2：本地主机：8082

谁能指出我们正确的方向？我们的配置有问题吗？先感谢您。