.NET环境下向RabbitMQ发布消息时如何定义瞬时错误重试策略

建议捕获的瞬时异常 #

1. RabbitMQ.Client 自定义异常 #

• AlreadyClosedException：你之前认为该异常重试无意义的结论仅适用于未开启客户端自动恢复的场景。只要你在初始化ConnectionFactory时开启了AutomaticRecoveryEnabled = true，客户端会自动在后台尝试重建连接/通道，此时等待数百毫秒后重试，大概率可以拿到可用的新通道完成发布，属于典型可重试瞬时异常。
• OperationInterruptedException：操作被RabbitMQ服务端主动中断，通常由临时限流、队列短暂不可用、集群节点切换等瞬时原因触发，重试成功率很高。
• BrokerUnreachableException：初始化连接时无法访问RabbitMQ节点，多由网络波动、DNS解析临时失效导致，重试可解决。

2. 系统级网络异常 #

• IOException：底层网络IO临时中断，比如TCP闪断、连接被临时重置，属于典型瞬时错误。
• SocketException：Socket层报错，常见的连接超时、端口不可达、网络不可用等场景大多属于瞬时故障。
• TimeoutException：发布操作超时，多由网络抖动、服务端临时高负载导致，短时间重试即可恢复。

参考Polly策略实现 #

// 定义重试策略：指数退避，最多重试3次，每次间隔100ms/200ms/400ms
var publishRetryPolicy = Policy
    .Handle<AlreadyClosedException>()
    .Or<OperationInterruptedException>()
    .Or<BrokerUnreachableException>()
    .Or<IOException>()
    .Or<SocketException>()
    .Or<TimeoutException>()
    .WaitAndRetry(
        retryCount: 3,
        sleepDurationProvider: attempt => TimeSpan.FromMilliseconds(100 * Math.Pow(2, attempt - 1)),
        onRetry: (ex, ts, attempt, context) => 
        {
            // 此处可加重试日志逻辑
        });

// 调用方式
publishRetryPolicy.Execute(() => 
{
    // 你的BasicPublish逻辑
    channel.BasicPublish(exchange, routingKey, basicProperties, body);
});

注意事项 #

1. 务必开启RabbitMQ客户端自动恢复配置，示例如下：

var factory = new ConnectionFactory
{
    HostName = "你的RabbitMQ地址",
    UserName = "用户名",
    Password = "密码",
    AutomaticRecoveryEnabled = true, // 开启自动连接恢复
    NetworkRecoveryInterval = TimeSpan.FromSeconds(3) // 网络恢复尝试间隔
};

2. 仅对幂等消息开启重试，非幂等消息建议先做幂等校验再重试，避免重复消息问题。
3. 可以搭配Polly熔断策略使用，连续多次发布失败时触发熔断，避免无效请求占满资源。
4. 重试多次失败的消息建议存入死信队列或本地落盘，后续人工处理，避免消息丢失。

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