C#使用RabbitMQ.Client对RabbitMQ消息进行确认和拒绝的操作

一、为什么需要手动确认消息？

就像网购后需要点"确认收货"，RabbitMQ的消息确认机制能确保消息被正确处理。想象快递员把包裹放你家门口就离开，如果被风吹走了怎么办？自动确认模式（AutoAck）类似这种情况，而手动确认则像要求本人签收后才算完成投递。

二、搭建基础环境

1. 安装必要组件

dotnet add package RabbitMQ.Client --version 6.4.0

2. 连接配置样板

var factory = new ConnectionFactory {
    HostName = "你的服务器IP",
    UserName = "admin",
    Password = "SecureP@ssw0rd",
    Port = 5672
};

using var connection = factory.CreateConnection();
using var channel = connection.CreateModel();

三、完整消息处理示例

// 创建持久化队列
channel.QueueDeclare(
    queue: "order_queue",
    durable: true,    // 队列持久化
    exclusive: false,
    autoDelete: false,
    arguments: null
);

// 创建消费者
var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) => {
    var body = ea.Body.ToArray();
    var message = Encoding.UTF8.GetString(body);
    
    try {
        // 模拟业务处理（如订单创建）
        ProcessOrder(message);
        
        // 成功确认（第二个参数false表示不批量确认）
        channel.BasicAck(
            deliveryTag: ea.DeliveryTag,
            multiple: false
        );
        
        Console.WriteLine($"已处理：{message}");
    }
    catch (Exception ex) {
        // 拒绝消息（第二个参数true表示重新入队）
        channel.BasicNack(
            deliveryTag: ea.DeliveryTag,
            multiple: false,
            requeue: true
        );
        
        Console.WriteLine($"处理失败：{ex.Message}");
    }
};

// 开始消费（关闭自动确认）
channel.BasicConsume(
    queue: "order_queue",
    autoAck: false,  // 关键参数！
    consumer: consumer
);

// 保持程序运行
Console.ReadLine();

void ProcessOrder(string orderData) {
    // 这里添加实际业务逻辑
    if (orderData.Contains("error")) 
        throw new Exception("模拟业务异常");
}

四、核心方法详解

1. BasicAck（确认）

• deliveryTag：消息的唯一标识符
• multiple：是否确认之前所有未确认的消息

2. BasicNack（拒绝）

• requeue参数：
  • true：重新放回队列头部
  • false：直接丢弃或进入死信队列

五、典型应用场景

1. 电商订单系统

• 支付成功：确认消息并更新订单状态
• 库存不足：拒绝消息并重新入队等待重试

2. 文件处理服务

• 成功转码：确认消息并记录日志
• 格式错误：拒绝消息并发送警报

六、技术选型对比

七、避坑指南

1. 遗忘确认会导致内存泄漏（消息堆积）
2. 过早确认可能丢失正在处理的消息
3. 无限重试循环：建议结合最大重试次数
4. 使用prefetchCount控制消费速度：

channel.BasicQos(
    prefetchSize: 0,
    prefetchCount: 5,  // 每次最多取5条
    global: false
);

八、总结与建议

就像在银行办理业务需要"取号-办理-确认完成"的流程，消息确认机制是可靠消息系统的基石。建议在以下场景使用手动确认：

• 涉及资金交易
• 需要严格保证数据一致性
• 处理耗时较长的任务

最终决策应基于业务需求：如果允许少量消息丢失换取更高吞吐量，自动确认可能是更好选择。对于关键业务，请务必实施手动确认+死信队列+重试机制的完整方案。