消费者（消息队列）Message Consumer
你可能会说
消息已经发出去了，但队列一直增长。帮我确认有没有消费者在接收、处理并确认这些消息。
从消息队列中获取待处理消息并执行业务逻辑，处理完成后向队列反馈确认状态的服务实例或后台进程。·例如上传接口只负责发送转码任务，消费者从队列取出任务并执行转码；订单系统也可以让消费者接收“订单已创建”消息，再生成发货记录。没有消费者时，消息会留在队列里堆积；处理失败时消息可能被重新投递，所以发送成功不等于业务已经完成。
也常被叫作消息消费者队列消费者Worker 进程订阅者
消息发出后，谁把它取出来并完成工作
消息 41ready
消息 42ready
消费者数量0
可观察证据队列深度持续增加
生产者发送成功，但没有应用取出处理。
消费者负责接收、处理和反馈
先定位堆积从哪里来：生产者只把消息发送到队列；如果没有消费者，或消费者处理速度跟不上，消息就会持续堆积。
处理后确认结果：消费者收到消息后调用处理逻辑，成功时确认已经处理；失败时由系统按规则重新投递或记录失败，不能假装任务已经完成。
改善要看链路证据：模拟一条消息，能在日志或状态中看到发送、接收、处理和结果反馈，队列堆积也能回落；消费者不是队列本身，一个应用还可能同时是生产者。
你可以这样告诉 AI Agent
“检查这条消息队列的消费者：确认消费者已启动并持续接收消息，处理成功会反馈完成，处理失败不会静默丢失而是按规则重投或记录失败。模拟一条消息，验收它从发送、接收、处理到结果反馈的完整链路。
延伸阅读 · 权威出处
快速练习