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

时间:2024-07-10 15:56:42

设置预取值

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

ConnectionFactory factory = new ConnectionFactory();

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

channel.basicQos(10, false);

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

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

global取值的含义如下:

表1 global取值说明

global取值

说明

false

分别作用于通道上的每个新消费者。

true

在通道上的所有消费者之间所共享。

support.huaweicloud.com/usermanual-rabbitmq/rabbitmq_ug_0013.html