scala - Akka Sharding 与持久演员的背压

Question

是否有 Akka 流背压模型或用于将 akka 分片与持久演员一起使用的东西？

因为我有一个问题，我有一个带有持久演员的 akka 分片集群。（使用 cassandra 作为日志插件）。
有时应该同时创建很多演员。（例如，当我们想向所有用户发送广播消息时。）
并且成千上万的持久性参与者试图在短时间内（例如 3 秒）恢复，并且在负载很重的情况下，cassandra 无法一次响应并且很多参与者失败多次恢复，再也没有恢复。

Answer 1

我认为您想要的是具有指数退避的监督策略。所以如果重启（即从数据库恢复）失败，它不会立即重试，而是增加时间间隔，以免数据库过载。Akka 通过BackoffSupervisor提供了这个。

要将其与集群分片一起使用，您必须为定义监管策略的实体创建一个中间父参与者，请参阅集群分片文档（集群分片监管策略本身不可插入，如本Github 问题中所述）。