如何在Actor Cluster Sharding中实现至多一次消息投递？

核心问题拆解 #

当前的痛点集中在分片重平衡期间：代理内存缓冲区的消息在重启时丢失，超时重试又会导致重复投递；而用ActorSelection检查Actor可用性的方式在高并发下性能瓶颈明显。以下是不需要ActorSelection的替代方案：

1. 利用ShardRegion内置状态查询替代ActorSelection #

Akka Cluster Sharding的ShardRegion本身支持高效状态查询，无需通过ActorSelection定位EntityActor：

• 代理节点向ShardRegion发送GetShardRegionState消息，直接获取所有分片的状态（包括是否处于重平衡中、分片所在节点），这是集群内部的轻量通信，比跨节点的ActorSelection效率高得多。
• 代理可维护本地分片状态缓存，按需触发查询或定期同步，一旦发现目标分片不可用，直接将消息写入外部持久化存储（如Redis、关系型数据库），而非存入代理内存缓冲区。

2. 给消息添加唯一ID，实现EntityActor端幂等处理 #

要保证至多一次投递，核心是避免重复处理：

• 所有从代理发出的消息都携带全局唯一ID（如UUID）。
• EntityActor收到消息后，先检查本地缓存或数据库中是否已有该ID的处理记录：若存在则直接忽略；若不存在则处理消息并记录ID。
• 这种方式即使因重试导致消息重复到达，也不会产生重复业务操作，完全适配至多一次的语义。

3. 用外部持久化存储替代代理内存缓冲区 #

放弃代理的内存缓冲区，将消息持久化作为发送前的必要步骤：

• 代理收到业务请求后，先将消息（含唯一ID、目标分片信息）写入外部存储，再向ShardRegion发送消息。
• 若5秒内未收到确认：
  • 先查询目标分片状态，若分片已恢复可用则重新发送；
  • 若分片仍在重平衡，则等待状态更新后再发送；
• 代理重启后，从存储中读取所有未标记为“已确认”的消息，按分片状态分批重发；消息发送成功后，立即在存储中标记为已处理或删除。

4. 基于Actor生命周期回调实现状态主动通知 #

通过EntityActor和代理的状态联动，避免主动查询的开销：

• 在EntityActor的Passivate回调中，向代理节点发送“分片即将下线”的通知，代理收到后暂停向该分片发消息，转存消息到外部存储。
• 当分片重新激活（EntityActor的preStart方法）时，主动向代理发送“分片已就绪”的通知，代理立即从存储中取出对应分片的消息进行投递。
• 这种被动接收状态的方式，比主动查询更高效，能减少高并发下的状态查询压力。

5. 优化ShardRegion重平衡配置，缩短不可用窗口 #

通过调整Akka配置参数，减少分片重平衡的持续时间：

• 调小akka.cluster.sharding.rebalance-interval（默认10s），加快分片重平衡的触发频率；
• 调整akka.cluster.sharding.wait-for-state-timeout，让ShardRegion更快返回分片状态，避免代理长时间等待；
• 合理设置akka.cluster.sharding.max-draining-retries，控制分片下线前的消息排空次数，减少消息滞留。

内容的提问来源于stack exchange，提问作者HappyCoding