ALTER TABLE message ADD UNIQUE KEY uk_msgid (msg_id);
INSERT INTO message (msg_id, room_id, payload)
VALUES (?, ?, ?) ON DUPLICATE KEY UPDATE id = id;

用户连点两次发送,或者超时后客户端自动补发,message 表出现两条内容完全一样的记录,create_time 相差 3 毫秒,下游推送也发了两遍。这类现象通常不是突然出现的,往前翻半天日志能看到苗头。

追下去是这么回事:客户端等 ack 超时就重发,服务端没有去重键,收到就插。重连补发和正常发送走同一段逻辑,两条都当新消息处理。

这次卡住的地方就在「消息重复投递」这一环,单独把它拎出来验证,别和其他改动混在同一次发布里。同一份配置存在多处的,先确认改的是被加载的那一份。

新版本先放一台机器上跑一天再全量,问题一般在这段时间暴露。

处理上按这个顺序:客户端生成 msgId 用 UUID 重发时保持不变;服务端在 msg_id 上建唯一索引 冲突就直接返回已存在;ack 带回 msgId 客户端收到才删本地待发队列;下游消费按 msgId 去重 别指望上游只发一次。

确认没问题再收工,连点五次发送 message 表只有一条记录 五条 ack 内容一致。

作者 9823189