Docker环境下RabbitMQ消费者莫名死亡，请求排查原因

1. 缺失连接/通道的异常处理与重连机制 #

Docker环境下网络波动更频繁，RabbitMQ连接可能因超时、心跳失败等原因被断开，但你的代码没有处理连接断开后的重连逻辑，也没有监听通道的关闭事件。一旦连接/通道失效，消费者就会从RabbitMQ列表中消失，而进程本身不会退出。

修复措施：

• 监听IConnection的ConnectionShutdown事件，在连接断开时触发重连逻辑，重新创建通道和消费者。
• 监听IModel的ModelShutdown事件，捕获通道关闭的原因，及时重建通道和消费者。

示例代码片段：

_connection.ConnectionShutdown += (sender, args) =>
{
    Console.WriteLine($"连接已断开，原因：{args.ReplyText}");
    // 重新调用Subscribe方法重建消费者
    ReSubscribe(queueName, onMessageReceived, onError);
};

channel.ModelShutdown += (sender, args) =>
{
    Console.WriteLine($"通道已关闭，原因：{args.ReplyText}");
    ReSubscribe(queueName, onMessageReceived, onError);
};

2. 未保持通道的引用，可能被GC回收 #

你在Subscribe方法中创建的channel是局部变量，方法执行完毕后如果没有被外部引用，可能被.NET GC回收，导致通道失效，消费者消失。Docker环境下GC策略可能更激进，更容易触发这种情况。

修复措施：

• 将创建的channel和consumer存储到全局集合中，保持强引用，避免被GC回收。

示例：

// 全局集合存储活跃的通道和消费者
private readonly List<(IModel Channel, EventingBasicConsumer Consumer)> _activeConsumers = new();

public void Subscribe(string queueName, Func<string, Task<bool>> onMessageReceived, Action<Exception> onError)
{
    var channel = _connection.CreateModel();
    var consumer = new EventingBasicConsumer(channel);
    
    // ... 原有逻辑 ...
    
    channel.BasicConsume(queueName, false, consumer);
    
    // 添加到全局集合保持引用
    lock (_activeConsumers)
    {
        _activeConsumers.Add((channel, consumer));
    }
    
    // 监听通道关闭，从集合中移除
    channel.ModelShutdown += (sender, args) =>
    {
        lock (_activeConsumers)
        {
            _activeConsumers.RemoveAll(item => item.Channel == channel);
        }
    };
}

3. 心跳配置问题 #

RabbitMQ客户端默认心跳间隔为60秒，如果Docker容器的网络延迟或进程阻塞导致客户端无法及时发送心跳，RabbitMQ会判定连接失效并断开，消费者随之消失。

修复措施：

• 在创建连接时显式配置心跳间隔，比如设置为30秒，同时确保客户端进程不会长时间阻塞（比如onMessageReceived不要耗时过长，避免影响心跳发送）。

示例连接配置：

var factory = new ConnectionFactory()
{
    HostName = "rabbitmq-host",
    RequestedHeartbeat = TimeSpan.FromSeconds(30),
    // 其他配置项
};
_connection = factory.CreateConnection();

4. 异步回调的潜在问题 #

EventingBasicConsumer.Received事件的异步委托中，如果onMessageReceived抛出未被捕获的异常（虽然你包了try-catch，但要注意异步操作的异常传播），或者异步操作长时间阻塞，可能导致通道无法正常处理后续消息，甚至被RabbitMQ关闭。

修复措施：

• 确保onMessageReceived中的异步操作有合理的超时控制，避免长时间阻塞。
• 在try-catch中捕获所有异常，确保BasicAck或BasicNack总能被正确调用（除非通道已失效）。

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