开发wordpress 需要学习,seo管理系统,龙岩论坛,为企业规划一个网站什么是消费端限流#xff0c;这个一种保护消费者的手段#xff0c;假如说#xff0c;现在是业务高峰期了#xff0c;消息有大量堆积#xff0c;导致MQ消费需要不断的进行消息消费#xff0c;很容易被打挂#xff0c;甚至重启之后还是会被大量消息涌入#xff0c;继续被… 什么是消费端限流这个一种保护消费者的手段假如说现在是业务高峰期了消息有大量堆积导致MQ消费需要不断的进行消息消费很容易被打挂甚至重启之后还是会被大量消息涌入继续被打挂。
为了解决这个问题,RabbitMQ提供了basicQos的方式来实现消费者端限流。我们可以在消费者指定最大的未确认消息数当达到这个限制时RabbitMQ将不再推送新的消息给消费者直到有一些消息得到确认。 想要实现这个功能首先需要把自动提交关闭。 接着进行限流配置 如以上配置可以实现消费者在处理一条消息后才会获取下一条消息。
然后再在消费者处理完一条消息之后手动发送确认消息给到RabbitMQ这样就可以拉取下一条消息了 完整代码
