在 Apache Storm 中，消息重发的处理机制是怎样的？请列举并比较几种减少消息丢失的具体策略。

回答思路

1. 【回答框架 1】Storm 通过 ACK 机制保证消息处理。当元组被完全处理（即其所有衍生元组均被 ack），Spout 会收到 ack；若超时或处理失败（fail），Spout 会收到 fail 并触发重发。
2. 【回答框架 2】减少消息丢失的策略主要有：1) 开启 ACK 机制，确保每个元组被处理或被失败；2) 在 Spout 中实现可靠的重发逻辑，例如设置消息超时时间、将消息持久化（如使用 Kafka 作为数据源，重发时从 Kafka 重新拉取）；3) 使用事务性拓扑或 Trident 来提供恰好一次或至少一次的语义；4) 适当增加超时时间，避免频繁重发；5) 合理设置并行度，避免节点过载导致失败。
3. 【回答框架 3】至少一次语义下，重发可能导致重复处理，需在业务层做幂等处理。优化重发策略时，需权衡延迟和吞吐量。
4. 【回答框架 4】在实现重发时，需注意 Spout 的 fail 回调中应重新发射原始元组，并确保重发不会无限循环或导致雪崩。
5. 【关键点 1】ACK 机制决定消息是否重发。
6. 【关键点 2】常用策略：开启 ACK、Spout 可靠重发、持久化中间数据。
7. 【关键点 3】事务性拓扑或 Trident 可提供更强一致性。
8. 【关键点 4】重发导致重复处理，需业务幂等。
9. 【关键点 5】超时时间和并行度设置影响消息丢失率。
10. 【易错点 1】依赖 ACK 但未设置超时或处理 fail，导致消息丢失。
11. 【易错点 2】重发时未考虑下游状态，导致重复副作用。
12. 【易错点 3】无限重发可能造成系统压力增大。