node 使用 amqplib 库连接 rabbitMq,消费者采用需要手动ack方式。最近消息生产速度越来越快,消费者已经吃满cpu了,rabbitMq只要有消息就会马上发给消费者处理,如何才能让rabbitmq一次只给每个消费者几条消息,每ack一条消息再发一条呢?
node 使用 amqplib 库连接 rabbitMq,消费者采用需要手动ack方式。最近消息生产速度越来越快,消费者已经吃满cpu了,rabbitMq只要有消息就会马上发给消费者处理,如何才能让rabbitmq一次只给每个消费者几条消息,每ack一条消息再发一条呢?
3 回答2.7k 阅读✓ 已解决
1 回答1k 阅读✓ 已解决
1 回答1.1k 阅读✓ 已解决
2 回答1.2k 阅读
2 回答664 阅读✓ 已解决
2 回答1.7k 阅读
2 回答1.1k 阅读
可以用Qos来控制一次传给消费者消息的数量。