Aeron单播流订阅端故障及Offer返回-1相关技术咨询

订阅端故障后的整体表现 #

当单播流的订阅端发生故障（如进程崩溃、网络断开），发布端调用offer()发送消息时，会开始返回-1，代表当前无活跃的已连接订阅端。默认配置下，故障期间发布端尝试发送的消息会被直接丢弃，除非配置了持久化或缓存策略。

问题a的详细解答 #

发布端如何跟踪订阅端状态？ #

• Aeron依靠订阅端心跳机制和媒体驱动的连接状态管理来跟踪订阅端：
  1. 订阅端正常连接时，会定期向发布端所在的媒体驱动发送心跳包，证明自身存活。
  2. 若发布端的媒体驱动在设定的超时时间内未收到某订阅端的心跳，会将该订阅端从「活跃订阅者列表」中移除。
  3. 当发布端调用offer()时，会先查询这个活跃列表——如果列表为空，就返回-1。
• 对于订阅端短暂故障的场景，媒体驱动会持续监控订阅端的重连请求，一旦订阅端恢复并重新发起连接，会被重新加入活跃列表，此时offer()会恢复正常返回值。

为何offer()仅追加消息却返回负响应码？ #

这是对Aeron机制的误解：单播流中，offer()并不是单纯向本地缓冲区追加消息——Aeron的设计核心是低延迟、无冗余，默认策略下，只有存在活跃订阅端时，媒体驱动才会为流分配缓冲区资源用于消息传递。当没有订阅端时，追加消息到缓冲区没有意义（没有消费者会读取），因此offer()直接返回-1，避免浪费系统资源。

能否缓存消息后续再发送？ #

默认情况下不行，Aeron默认策略是无订阅者时丢弃消息。但可以通过以下方式实现缓存/重发：

• 启用持久化日志（Persistent Log）：配置发布端将消息写入持久化存储，当订阅端恢复连接后，媒体驱动会将存储的消息重传给订阅端。
• 自定义发布策略：通过扩展Aeron的API，实现自定义的消息缓存逻辑，在无订阅者时临时缓存消息，待订阅端恢复后再发送。
• 注意：以上方式会引入额外的延迟和存储开销，需要根据业务对延迟、可靠性的要求权衡使用。

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