1. 消息重复消费问题分析1.1 重复消费产生原因 public class MessageDuplicationAnalysis { /* * 消息重复消费产生原因： * * 1. 网络异常 * - 消费者处理完消息后，ACK确认丢失 * - 网络抖动导致消息重新投递 * - 消费者重启后重新消费未确认消息 * * 2. 消费者异常 * - 消费者处理过程中崩溃 * - 消费者处理超时 * - 消费者重启或扩容 * * 3. 消息队列机制 * - At Least Once语义保证 * - 消息重试机制 * - 分区重平衡 * * 4. 业务逻辑问题 * - 消费逻辑执行时间过长 * - 消...