java——spring boot集成RabbitMQ——work队列示例——手动ack的确认

淩亂°似流年 2023-09-29 19:12 85阅读 0赞

1、简单队列模式里面有个缺点。

![b081c727de07e577579dfbe38cd295fd.png][]

PS：消息存储在Channel里面，一次可以存储好几条

我们想让能者多劳，消费能力强的消费者进行多消费。

之前在简单模式下，是自动ack的(自动像broker——表示消息队列服务器实体)进行反馈(类似于会掉)，事件可能还没消费完成，就自动act了然后broker又像此channer里面发送多条消息，导致消息积累，消费慢。

现在在work队列模式下，当事件处理完成之后才ack，且控制channel里面一次只有一条消息。这样哪个消费快，哪个就获取的多和处理的快。

=============================================================================================================

代码在前面的代码里面修改。

生产者里面只修改队列名，其它不变

![210921cf0e5841fc0cf79657088d027b.png][]

消费者修改如下：

![4887e6a608b6e2fdc62c270e363082e7.png][]

取消自动ack

![67ef1ace14f47b0d5a89ea572dfb4023.png][]

设置手动ack，消息处理完成后进行ack：

![97a43e438e1f2a5af012b6793c53f419.png][]

PS：表示哪个消息的进行手动ack。具体消息标记通过系统上下文获取

非lmd写法：

![1d395aa941dcfa741982d0f4f04692f7.png][]

如果生产者还没启动，则系统里面还没有队列，需要在消费者里面设置队列。

![fdd1138d11e75ea2bad25a60050fcc98.png][]

[b081c727de07e577579dfbe38cd295fd.png]: https://img-blog.csdnimg.cn/img_convert/b081c727de07e577579dfbe38cd295fd.png
[210921cf0e5841fc0cf79657088d027b.png]: https://img-blog.csdnimg.cn/img_convert/210921cf0e5841fc0cf79657088d027b.png
[4887e6a608b6e2fdc62c270e363082e7.png]: https://img-blog.csdnimg.cn/img_convert/4887e6a608b6e2fdc62c270e363082e7.png
[67ef1ace14f47b0d5a89ea572dfb4023.png]: https://img-blog.csdnimg.cn/img_convert/67ef1ace14f47b0d5a89ea572dfb4023.png
[97a43e438e1f2a5af012b6793c53f419.png]: https://img-blog.csdnimg.cn/img_convert/97a43e438e1f2a5af012b6793c53f419.png
[1d395aa941dcfa741982d0f4f04692f7.png]: https://img-blog.csdnimg.cn/img_convert/1d395aa941dcfa741982d0f4f04692f7.png
[fdd1138d11e75ea2bad25a60050fcc98.png]: https://img-blog.csdnimg.cn/img_convert/fdd1138d11e75ea2bad25a60050fcc98.png