我的工厂AI质检系统用Rust 1.85异步闭包重构后,消息积压从20分钟降到2分钟

去年十月份,我们的AI质检系统在生产线上跑了三个月后,开始出现一个让我凌晨三点爬起来看监控的问题:Redis Stream消息积压。每天凌晨的换班时段,质检数据流会暴增三倍,然后整个消息处理链路就开始堵。等到早上七点工人换班的时候,系统已经积压了20分钟的数据,生产线主任直接打电话骂人。 这个问题折…