官网友情链接 wechatapi.net微信消息进入业务系统以后大多数消息格式正常。但生产环境永远会遇到少量异常数据字段缺失未知消息类型文件信息不完整特殊字符解析异常历史版本结构不同。如果消费者遇到一条异常消息就不断重试而队列又使用严格顺序消费很可能出现一条脏数据卡住后面几万条正常消息。所以个人微信二次开发的消息消费层需要异常隔离。WechatApi 可以作为个人微信API接入层把私聊、群聊和不同消息类型带入业务系统。本地事件消费者需要允许异常消息进入独立处理区而不是阻塞正常流水线。一、什么是毒消息一条消息无论重试多少次都会失败。例如代码不支持某种新消息类型。它就属于poison message。无限重试没有意义。二、一个具体例子队列中M100正常M101格式异常M102正常M103正常。如果M101失败后立即重新入队头部。系统一直M101失败。M102、M103永远跑不到。这是严重问题。三、有限重试后隔离例如M101失败3次。进入quarantine queue。主队列继续M102。这样异常不扩大。四、隔离不是删除保留原始payload错误重试次数消息类型账号trace_id。修复程序后还能重新处理。五、WechatApi 的位置WechatApi 负责原始消息接入。本地消费层负责解析重试隔离重放。六、未知消息类型尤其应该隔离遇到新类型。不要直接丢弃。保存原始数据。开发适配后重新处理。这样系统更有扩展性。七、文件消息异常和文本消息分开文件字段缺失。不要影响文本消息消费。不同类型最好有不同处理器。八、隔离消息要有优先级重点客户异常消息高。普通群未知表情类型低。人工先看重要的。九、异常中心聚合如果1000条消息都因为同一解析错误进入隔离。异常中心显示某消息类型解析异常影响1000条。不要1000个告警。十、修复后重放代码发布新版本。选择此错误类型全部重放。分批执行。十一、重放仍然要幂等部分消息可能已经完成前置步骤。不能重复发客户回复。步骤状态必须存在。十二、Schema版本原始消息保存schema_version。历史重放时使用对应解析器。十三、日志从首次失败重试隔离修复重放成功。完整链路。十四、数据看板隔离消息数量按类型平均解决时间重放成功率。反映系统兼容性。十五、权限普通客服看业务异常。技术管理员看原始payload。敏感字段需要脱敏。十六、告警阈值偶发1条不一定告警。短时间大量隔离立即提醒。十七、消费者健康隔离机制让主消费队列可以持续工作。这比追求“每条必须当场成功”更加可靠。十八、总结个人微信二次开发的消息链路中真正危险的不是出现一条异常消息。而是这一条消息把整个队列堵住。WechatApi 可以把各种真实微信消息持续送进系统。本地消费层通过有限重试异常隔离原始事件保留死信重放让少量异常不会扩大成全局事故。成熟的消息系统应该允许一条消息暂时处理不了但绝不能因为它让后面所有正常客户消息都停止处理。