一文讲透RabbitMQ 消息队列中的拒绝机制

更新时间：2025年07月21日 10:18:53 作者：逸水心

在消息队列系统中,如果消费者由于某些原因无法处理当前接收到的消息,可以通过以下机制拒绝消息,下面就来介绍了RabbitMQ 消息队列中的拒绝机制,感兴趣的可以了解一下

一. RabbitMQ 中的拒绝机制

1. RabbitMQ 中的拒绝机制

在 RabbitMQ 中，消费者可以通过以下两种方式拒绝消息：

（1）basic.reject（拒绝单条消息）

功能：拒绝单条消息，并指定是否将消息重新放回队列。

参数：

deliveryTag：消息的唯一标识符（由 RabbitMQ 分配）。
requeue：布尔值，决定消息是否重新入队（true 表示重新入队，false 表示丢弃）。

示例代码（Python）：

import pika

def callback(ch, method, properties, body):
    print(f"Received message: {body}")
    # 模拟处理失败
    if some_condition:
        ch.basic_reject(delivery_tag=method.delivery_tag, requeue=True)
    else:
        ch.basic_ack(delivery_tag=method.delivery_tag)

channel.basic_consume(queue='my_queue', on_message_callback=callback)

（2）basic.nack（批量拒绝消息）

功能：拒绝多条消息，支持批量操作。

参数：

deliveryTag：消息的唯一标识符。
multiple：布尔值，决定是否拒绝 deliveryTag 之前的所有未确认消息。
requeue：布尔值，决定消息是否重新入队。

示例代码（Python）：

def callback(ch, method, properties, body):
    print(f"Received message: {body}")
    # 模拟处理失败
    if some_condition:
        ch.basic_nack(delivery_tag=method.delivery_tag, multiple=False, requeue=True)
    else:
        ch.basic_ack(delivery_tag=method.delivery_tag)

2. 拒绝消息后的处理方式

拒绝消息后，消息的处理方式取决于 requeue 参数的值：

requeue 值	消息处理方式
True	消息重新入队，可能被其他消费者或当前消费者再次消费（需确保队列未满）。
False	消息直接丢弃，或进入死信队列（需提前配置死信队列规则）。

3. 死信队列（Dead Letter Queue, DLQ）

如果消息被拒绝且 requeue=False，消息可能被丢弃。为了避免消息丢失，可以通过配置 死信队列 将消息转发到另一个队列，供后续分析或重试。

配置死信队列的步骤（RabbitMQ）：

声明队列时绑定死信交换器：

channel.queue_declare(
    queue='my_queue',
    arguments={
        'x-dead-letter-exchange': 'dlx_exchange',  # 死信交换器名称
        'x-message-ttl': 60000  # 可选：消息过期时间（毫秒）
    }
)

声明死信交换器和队列：

channel.exchange_declare(exchange='dlx_exchange', exchange_type='direct')
channel.queue_declare(queue='dlx_queue')
channel.queue_bind(exchange='dlx_exchange', queue='dlx_queue', routing_key='dlx_key')

消费者处理失败时拒绝消息并进入死信队列：

def callback(ch, method, properties, body):
    if some_condition:
        ch.basic_nack(delivery_tag=method.delivery_tag, requeue=False)
    else:
        ch.basic_ack(delivery_tag=method.delivery_tag)

二. Spring AMQP 中的拒绝机制

4. Spring AMQP 中的拒绝机制

在 Spring AMQP 中，可以通过以下方式实现消息拒绝：

（1）手动确认模式（AcknowledgeMode.MANUAL）

代码示例：

@RabbitListener(queues = "my_queue", ackMode = "MANUAL")
public void onMessage(Message message, Channel channel) throws IOException {
    try {
        // 处理消息
        if (someCondition) {
            // 拒绝消息并重新入队
            channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
        } else {
            // 确认消息
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
        }
    } catch (Exception e) {
        // 异常处理
        channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
    }
}

（2）自动确认模式（AcknowledgeMode.AUTO）

Spring 会根据方法是否抛出异常自动决定是否发送 basic.nack 或 basic.ack。

配置示例（YAML）：

spring:
  rabbitmq:
    listener:
      simple:
        acknowledge-mode: auto

三. RocketMQ 中的拒绝机制

5. RocketMQ 中的拒绝机制

在 RocketMQ 中，消费者无法直接“拒绝”消息，但可以通过以下方式模拟：

（1）消费失败时返回ConsumeConcurrentlyStatus.RECONSUME_LATER

功能：消息会重新投递（默认延迟10秒）。

代码示例（Java）：

public class MyConsumer implements MessageListenerConcurrently {
    @Override
    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
        try {
            // 处理消息
            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
        } catch (Exception e) {
            // 消费失败，重新投递
            return ConsumeConcurrentlyStatus.RECONSUME_LATER;
        }
    }
}

（2）限制重试次数

通过 maxReconsumeTimes 配置最大重试次数，避免无限循环：

consumer.setMaxReconsumeTimes(3); // 最大重试3次

四、常见场景&注意事项

6.常见场景与处理建议

场景 1：消息格式错误或业务逻辑异常

处理方式：
- 拒绝消息（requeue=False）并记录日志。
- 配置死信队列，将消息转发到专门的错误队列供人工处理。

场景 2：资源不足或临时故障

处理方式：
- 拒绝消息并重新入队（requeue=True），等待资源恢复后重新消费。
- 在死信队列中设置重试逻辑（如定时任务重新投递）。

场景 3：消息已过期或无效

处理方式：
- 拒绝消息（requeue=False）并丢弃。
- 配置死信队列，记录过期消息用于分析。

7. 注意事项

避免无限循环：
- 如果消息多次被拒绝并重新入队，可能导致无限消费循环。需结合 死信队列 或 重试次数限制 解决。
资源占用：
- 频繁拒绝消息并重新入队可能增加系统负载，需合理配置 requeue 和 prefetchCount。
消息可靠性：
- 使用 手动确认 和 死信队列 保障消息不丢失。

总结

消费者拒绝消息的核心在于通过 basic.reject/basic.nack（RabbitMQ）或 RECONSUME_LATER（RocketMQ）控制消息的后续处理。结合 死信队列 和 重试机制，可以有效处理异常场景，确保消息的可靠性和系统的健壮性。

到此这篇关于一文讲透RabbitMQ 消息队列中的拒绝机制的文章就介绍到这了,更多相关RabbitMQ 拒绝机制内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

RabbitMQ消息拒绝如何解决

Maui Blazor 使用摄像头实现代码
由于Maui Blazor中界面是由WebView渲染，所以再使用Android的摄像头时无法去获取，因为原生的摄像头需要绑定界面组件，这篇文章主要介绍了Maui Blazor 使用摄像头实现,需要的朋友可以参考下
2023-01-01
深度卷积神经网络各种改进结构块汇总
这篇文章主要为大家介绍了深度卷积神经网络各种改进结构块汇总，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-05-05
5G频段阐述
这篇文章主要介绍了5G频段阐述方法的相关资料,需要的小伙伴可以参考下面
2021-08-08
asp php 清空access mysql mssql数据库的代码
php清空mysql asp情况access或mssql
2008-12-12
TIOBE编程语言排行榜前20的语言入门书籍推荐
这篇文章主要为大家推荐了TIOBE编程语言排行榜前20的语言入门书籍，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-11-11
skynet.rawcall使用应用场景分析
skynet.rawcall 是 Skynet 框架中用于直接传递原始二进制数据的低级通信接口,适用于需要绕过自动序列化/反序列化、手动控制内存或实现高性能传输的场景,下面给大家介绍skynet.rawcall使用应用场景分析,感兴趣的朋友一起看看吧
2025-04-04
grafana安装及使用教程详解
这篇文章主要介绍了grafana安装及使用教程详解,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2021-01-01
软件测试面试如何测试一个杯子
本文主要介绍软件测试面试如何测试一个杯子,这里帮大家整理了详细的面试资料，和面试需要准备的知识点，有兴趣的小伙伴可以参考下
2016-08-08
一文详解 OpenGL ES 纹理颜色混合的方法
在OpenGL中绘制的时候，有时候想使新画的颜色和已经有的颜色按照一定的方式进行混合。怎么实现这个效果呢，下面小编给大家带来了OpenGL ES 纹理颜色混合的实现方法，感兴趣的朋友跟随小编一起看看吧
2021-12-12
vscode使用nuget包管理工具
这篇文章介绍了vscode使用nuget包管理工具的方法，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-06-06