Aspire中RabbitMQ容器Unhealthy状态问题排查求助

核心问题分析 #

RabbitMQ.Client v7.0.0对核心API做了重大重构：IModel接口被标记为过时并由IChannel替代，而你当前使用的健康检查组件（HealthChecks.RabbitMQ）依赖旧版IModel接口，导致类型加载失败。

具体解决步骤 #

1. 替换为适配v7的健康检查实现 #

放弃默认的RabbitMQHealthCheck，自定义健康检查逻辑，使用RabbitMQ.Client v7的新API：

using Microsoft.Extensions.Diagnostics.HealthChecks;
using RabbitMQ.Client;
using System.Threading.Tasks;

public class RabbitMQV7HealthCheck : IHealthCheck
{
    private readonly IConnectionFactory _connectionFactory;
    private readonly string _queueName; // 可选：指定要检查的队列

    public RabbitMQV7HealthCheck(IConnectionFactory connectionFactory, string queueName = null)
    {
        _connectionFactory = connectionFactory;
        _queueName = queueName;
    }

    public async Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
    {
        try
        {
            await using var connection = _connectionFactory.CreateConnection();
            await using var channel = connection.CreateChannel();

            // 可选：检查指定队列是否存在
            if (!string.IsNullOrEmpty(_queueName))
            {
                var queueExists = channel.QueueDeclarePassive(_queueName);
                if (queueExists.MessageCount < 0)
                {
                    return HealthCheckResult.Unhealthy($"队列 {_queueName} 不存在");
                }
            }

            return HealthCheckResult.Healthy("RabbitMQ连接正常");
        }
        catch (Exception ex)
        {
            return HealthCheckResult.Unhealthy("RabbitMQ连接失败", ex);
        }
    }
}

2. 在Aspire Host中注册自定义健康检查 #

在Program.cs中替换默认的RabbitMQ健康检查，传入所需参数：

var builder = DistributedApplication.CreateBuilder(args);

// 注册RabbitMQ容器并禁用默认健康检查
var rabbitMq = builder.AddRabbitMQ("rabbitmq")
                      .WithHealthCheck(false);

// 注册自定义健康检查
builder.Services.AddHealthChecks()
       .AddCheck<RabbitMQV7HealthCheck>(
           "rabbitmq-custom",
           failureStatus: HealthStatus.Unhealthy,
           tags: new[] { "rabbitmq", "messaging" },
           parameters: new Dictionary<string, object>
           {
               { "queueName", "your-target-queue" } // 可选：传入要检查的队列名称
           });

builder.Build().Run();

3. 解决依赖版本冲突 #

检查项目文件（.csproj），确保所有引用RabbitMQ.Client的包都统一使用v7.0.0，添加版本锁定：

<PropertyGroup>
  <Version>1.0.0</Version>
  <RabbitMQClientVersion>7.0.0</RabbitMQClientVersion>
</PropertyGroup>

<ItemGroup>
  <PackageReference Include="RabbitMQ.Client" Version="$(RabbitMQClientVersion)" />
  <PackageReference Include="Aspire.Host" Version="9.0.0" />
  <!-- 其他依赖包 -->
</ItemGroup>

4. 健康检查参数说明 #

自定义健康检查的参数可通过AddCheck方法的parameters字典传入，若不需要检查特定队列，可直接省略queueName参数。如果需要动态获取参数，可在健康检查类中通过context.Registration.Parameters读取。

关键注意事项 #

• 保留RabbitMQ.Client v7.0.0时，必须确保所有依赖该库的组件（包括业务代码、健康检查）都使用新API（IChannel替代IModel）。
• Aspire Host v9.0.0默认集成的健康检查未适配RabbitMQ.Client v7，因此必须禁用默认检查并替换为自定义实现。

内容的提问来源于stack exchange，提问作者Thomas LE BERRE