分布式消息服务RABBITMQ版-配置RabbitMQ消息预取值:设置预取值

时间:2024-07-30 10:35:32

设置预取值

以下示例演示在Java客户端为单个消费者设置预取值为10。

ConnectionFactory factory = new ConnectionFactory();

Connection connection = factory.newConnection();
Channel channel = connection.createChannel();

//设置预取值为10。
channel.basicQos(10, false);

QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume("my_queue", false, consumer);

在Java客户端中,global的默认值为false,因此以上示例可以简单地写为channel.basicQos(10)

global取值的含义如下:

  • false:分别作用于通道上的每个新消费者。
  • true:在通道上的所有消费者之间所共享。
support.huaweicloud.com/usermanual-rabbitmq/rabbitmq_ug_0013.html