C#操作RabbitMQ遇报错：Cannot access a disposed object（AutorecoveringModel）

核心原因 #

这个异常说明执行BasicAck时，对应的AutorecoveringModel实例已被释放/回收，常见触发场景：

• 连接或Model被提前手动调用Dispose
• 异步操作过程中，AutorecoveringConnection的自动恢复逻辑触发，导致旧Model被回收
• ack时使用的Model实例与当前消费回调关联的实例不一致

消息丢失大概率是因为消费时autoAck参数设为true，即使处理失败、ack抛出异常，RabbitMQ仍会直接标记消息为已消费。

具体解决方案 #

• 严格管控连接和Model生命周期
  不要在消费回调执行完成前手动关闭连接或Dispose Model。AutorecoveringConnection会自动处理连接恢复，但提前释放Model会导致后续ack操作失效。

• 使用当前消费上下文的Model执行ack/nack
  在Received事件回调中，务必使用回调关联的Channel/Model实例执行确认操作，不要复用外部可能已失效的Model对象。

• 禁用自动ack，手动控制消息确认
  消费时将autoAck设为false，仅在消息处理完成后调用BasicAck；处理失败时调用BasicNack并设置requeue: true，让消息重新入队避免丢失。

• 异步操作需保持Model引用有效性
  如果回调内包含异步操作（比如转换Task对象时用了await），要确保异步操作期间Model实例未被回收，避免操作完成后使用已释放的Model。

示例代码 #

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System.Text;
using System.Text.Json;

var factory = new ConnectionFactory 
{ 
    HostName = "localhost", 
    AutomaticRecoveryEnabled = true,
    NetworkRecoveryInterval = TimeSpan.FromSeconds(5)
};

// 连接和Channel保持到消费结束，不要提前Dispose
using var connection = factory.CreateConnection();
using var channel = connection.CreateModel();

// 声明持久化队列，避免服务重启丢失消息
channel.QueueDeclare(queue: "task_queue", 
                     durable: true, 
                     exclusive: false, 
                     autoDelete: false, 
                     arguments: null);

var consumer = new EventingBasicConsumer(channel);
consumer.Received += async (sender, ea) =>
{
    var messageBytes = ea.Body.ToArray();
    var taskJson = Encoding.UTF8.GetString(messageBytes);
    
    try
    {
        // 转换为业务Task对象并处理
        var task = JsonSerializer.Deserialize<YourTaskType>(taskJson);
        await ProcessTaskAsync(task); // 替换为你的业务处理方法
        
        // 使用当前Channel执行ack，确保实例有效
        channel.BasicAck(ea.DeliveryTag, multiple: false);
    }
    catch (Exception ex)
    {
        Console.WriteLine($"消息处理失败: {ex.Message}");
        // 处理失败，将消息重新入队
        channel.BasicNack(ea.DeliveryTag, multiple: false, requeue: true);
    }
};

// 开启消费，禁用自动ack
channel.BasicConsume(queue: "task_queue", autoAck: false, consumer: consumer);

Console.WriteLine("等待消息...按任意键退出");
Console.ReadKey();

额外检查点 #

1. 确认没有在其他代码分支手动调用channel.Dispose()或connection.Dispose()
2. 检查AutomaticRecoveryEnabled是否开启，开启后连接断开会自动恢复，此时旧Model会被替换，确保消费逻辑能适配这种场景
3. 若使用依赖注入，需确保Model/Channel的生命周期配置正确（比如单例或 scopd），避免提前释放

内容的提问来源于stack exchange，提问作者Everton TP