使用basicQos方法时,参数为prefetchCount 值,告诉RabbitMQ不要在同一时间给一个消费者超过prefetchCount条消息。换句话说,只有在消费者空闲的时候会发送下一条信息。
例如:
channel.basicQos(4);
当consumer接收到4条消息后,不再会接收其它消息,只有当这些消息被消费时,才会接收新的消息。
本文共 224 字,大约阅读时间需要 1 分钟。
使用basicQos方法时,参数为prefetchCount 值,告诉RabbitMQ不要在同一时间给一个消费者超过prefetchCount条消息。换句话说,只有在消费者空闲的时候会发送下一条信息。
例如:
channel.basicQos(4);
当consumer接收到4条消息后,不再会接收其它消息,只有当这些消息被消费时,才会接收新的消息。
转载于:https://my.oschina.net/u/2326611/blog/653755