43
用 API 批量更新 5000 个商品价格，products/update 事件像洪水一样涌进来，消费者直接 OOM。
已采纳 · 提问者确认解决
59
先把判断放在前面：每次写操作都会触发一个事件，批量导入会放大成数千条投递，且并发很高。
1处理顺序
- 接收层只做「写队列」，不做任何业务处理，保证快速返回。
- 消费者按商品 id 做合并，短时间内的多次更新只处理最后一次。
- 导入期间临时降级：只记录 id，导入结束后统一回查一次。
- 给队列设上限与背压，避免内存被打满。
- 大批量导入用 Bulk Operations，事件量会显著减少。
验收：5000 个商品导入期间服务内存稳定，最终数据一致。
风
风格技术团队 回答于 1 个月前
