How to gracefully stop consuming messages with @RabbitListener(如何优雅地停止使用@RabbitListener 消费消息)
问题描述
有没有办法优雅地停止 ListenerContainer
及其关联的 Consumers
.
Is there a way to gracefully stop a ListenerContainer
, and its associated Consumers
.
我正在努力实现的目标.
- 停止使用消息.
- 优雅地停止
ListenerContainer
. - 等待长时间运行的消费者,完成后确认.
我可以使用 consumer.stop()
停止 ListenerContainers
,但活动的长时间运行的消费者不会成功完成,处理的消息也不会acked 并因此将在 ListenerContainer 恢复后再次处理.
I'm able to stop the ListenerContainers
using consumer.stop()
, but active long running consumers won't complete successfully, and processed messages won't be acked and will therefore be processed again, once the ListenerContainer has been resumed.
输出
Waiting for workers to finish.
Workers not finished.
Closing channel for unresponsive consumer: Consumer@6d229b1c
消息已处理,但未确认.
The message was processed, but not acked.
我或许可以使用 setForceCloseChannel(false)
实现正常关闭,但是否可以验证取消的消费者是否已完成?SimpleMessageListenerContainer.doShutDown() 有一个本地范围的列表cancelledConsumers".
I might be able to achieve a graceful shutdown using setForceCloseChannel(false)
, but is it possible to verify if the cancelled consumers has finished? SimpleMessageListenerContainer.doShutDown() has a local scoped List "canceledConsumers".
推荐答案
增加关机超时时间.
请参阅消息侦听器容器配置.
关机超时
当容器关闭时(例如,如果其封闭的 ApplicationContext 已关闭),它会等待处理中的消息,直至达到此限制.默认为五秒.
When a container shuts down (for example, if its enclosing ApplicationContext is closed), it waits for in-flight messages to be processed up to this limit. Defaults to five seconds.
/**
* The time to wait for workers in milliseconds after the container is stopped. If any
* workers are active when the shutdown signal comes they will be allowed to finish
* processing as long as they can finish within this timeout. Defaults
* to 5 seconds.
* @param shutdownTimeout the shutdown timeout to set
*/
public void setShutdownTimeout(long shutdownTimeout) {
这篇关于如何优雅地停止使用@RabbitListener 消费消息的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
本文标题为:如何优雅地停止使用@RabbitListener 消费消息
基础教程推荐
- 由于对所需库 rt.jar 的限制,对类的访问限制? 2022-01-01
- 如何对 HashSet 进行排序? 2022-01-01
- 如何使用 Eclipse 检查调试符号状态? 2022-01-01
- Java 中保存最后 N 个元素的大小受限队列 2022-01-01
- 首次使用 Hadoop,MapReduce Job 不运行 Reduce Phase 2022-01-01
- 如何强制对超级方法进行多态调用? 2022-01-01
- 如何使用 Stream 在集合中拆分奇数和偶数以及两者的总和 2022-01-01
- 在螺旋中写一个字符串 2022-01-01
- 如何在不安装整个 WTP 包的情况下将 Tomcat 8 添加到 Eclipse Kepler 2022-01-01
- Spring Boot Freemarker从2.2.0升级失败 2022-01-01