分布式消息服务RABBITMQ版-配置RabbitMQ消息确认机制:消费者确认

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

消费者确认

消费者确认是指服务端通过确认消息是否成功被消费者接收，来判断是否删除队列中的此消息。

消费者确认对数据可靠性十分重要，接收重要消息的消费应用程序在未处理完消息前不应确认消息，以便消费者有足够的时间处理消息，无需担心消息处理过程中由于消费者进程异常（如工作程序崩溃、重启等）导致消息丢失。

消费者确认在客户端上配置，通过配置basicConsume方法启用确认。在channel中启用消费者确认适用于大多数场景。

以下示例演示在Java客户端配置消费者确认（使用Channel#basicAck设置basic.ack为肯定）：

// this example assumes an existing channel instance

boolean autoAck = false;
channel.basicConsume(queueName, autoAck, "a-consumer-tag",
     new DefaultConsumer(channel) {
         @Override
         public void handleDelivery(String consumerTag,
                                    Envelope envelope,
                                    AMQP.BasicProperties properties, byte[] body)
             throws IOException
         {
             long deliveryTag = envelope.getDeliveryTag();
             // positively acknowledge a single delivery, the message will
             // be discarded
             channel.basicAck(deliveryTag, false);
         }
     });

未确认的消息缓存在内存中，如果未确认的消息过多，会导致内存使用率过高，此时可以在客户端配置预取值来限制消费者预取的消息数量，具体方法请参见配置RabbitMQ消息预取值。

上一篇：分布式消息服务RABBITMQ版-创建RabbitMQ Vhost:创建RabbitMQ Vhost（调用API）

下一篇：分布式消息服务RABBITMQ版-删除RabbitMQ Queue:方法五：调用API批量删除队列