如何在ASP.NET Web应用端检测RabbitMQ RPC服务程序是否运行？

针对RabbitMQ RPC模式下服务宕机导致Web应用请求挂起的问题，推荐结合超时兜底和前置消费者检测的方案，既避免请求无限挂起，又能提前给用户反馈。

1. 给RPC调用添加超时处理（核心） #

前置检测存在竞态风险（检测时服务正常，发送请求后服务宕机），所以必须给CallAsync添加超时逻辑，确保请求不会无限挂起。利用Task.WhenAny结合延迟任务实现：

private async Task<string> InvokeAsync(string n)
{
    // 启动RPC调用任务和超时任务
    var rpcTask = RpcClient.CallAsync(n);
    var timeoutTask = Task.Delay(TimeSpan.FromSeconds(5)); // 根据业务调整超时时间

    // 等待第一个完成的任务
    var completedTask = await Task.WhenAny(rpcTask, timeoutTask);
    
    if (completedTask == timeoutTask)
    {
        // 处理超时：提示用户、抛出异常或返回错误信息
        warning.Text = "服务无响应，请检查服务状态";
        throw new TimeoutException("RPC请求超时，服务可能未运行");
    }

    // 超时任务未触发，获取RPC响应
    var response = await rpcTask;
    lblAcknowledged.Text = response;
    warning.Text = response;
    return response;
}

2. 前置检测RPC队列的消费者数量（辅助） #

通过RabbitMQ的API获取目标RPC队列的消费者数量，若为0则说明没有服务在监听。这个方法可以提前拦截无效请求，减少不必要的RPC调用：

using RabbitMQ.Client;

private bool IsRpcServiceAvailable(string rpcQueueName)
{
    // 替换为你的RabbitMQ连接配置
    var factory = new ConnectionFactory 
    { 
        HostName = "localhost",
        // 按需添加用户名、密码、端口等配置
    };

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

    try
    {
        // 被动声明队列：如果队列不存在会抛出异常，说明服务从未启动过
        var queueInfo = channel.QueueDeclarePassive(rpcQueueName);
        // 消费者数量>0，说明有服务在监听队列
        return queueInfo.ConsumerCount > 0;
    }
    catch (RabbitMQ.Client.Exceptions.OperationInterruptedException)
    {
        // 队列不存在，服务未启动
        return false;
    }
}

在调用前使用该检测：

private async Task<string> InvokeAsync(string n)
{
    const string targetRpcQueue = "your_rpc_queue_name"; // 替换为你的RPC队列名
    if (!IsRpcServiceAvailable(targetRpcQueue))
    {
        warning.Text = "服务未运行，请启动服务后重试";
        throw new InvalidOperationException("RPC服务未启动");
    }

    // 后续执行RPC调用（仍需保留超时处理）
    var rpcTask = RpcClient.CallAsync(n);
    var timeoutTask = Task.Delay(TimeSpan.FromSeconds(5));
    var completedTask = await Task.WhenAny(rpcTask, timeoutTask);
    
    // 省略超时处理和响应逻辑（同方案1）
}

关键说明 #

• 为什么检查连接/队列无效？
  • 检查连接仅验证Web应用与RabbitMQ服务器的连通性，和服务程序是否运行无关；
  • Web应用会自动创建不存在的队列，所以队列存在不代表有消费者监听。
• 必须结合两种方案：前置检测提升用户体验，超时处理兜底竞态场景，避免请求挂起。

内容的提问来源于stack exchange，提问作者j.hull