如何检测使用大众运输到兔子mq的连接问题？

Question

如何检测message broker配置是否有效，或者使用到RabbitMQ的大量传输是否丢失到message broker的连接？ 当发布消息时，如果没有代理连接，RabbitMQ存在时似乎不会立即抱怨，并且在RabbitMQ服务器启动时似乎会恢复。 是否有方法侦听连接事件并在配置无效时发出警告？

Answer 1

如果您使用。NET Core并根据文档配置MassTransit，则可以解析IBusHealth实例并在服务中使用它。

AddMassTranSit方法注册默认实例，您可以随时询问该实例的总线健康状态。 这是方法代码:

    public HealthResult CheckHealth()
    {
        var endpointHealthResult = _endpointHealth.CheckHealth();

        var data = new Dictionary<string, object> {["Endpoints"] = endpointHealthResult.Data};

        return _healthy && endpointHealthResult.Status == BusHealthStatus.Healthy
            ? HealthResult.Healthy("Ready", data)
            : HealthResult.Unhealthy($"Not ready: {_failureMessage}", data: data);
    }

如您所见，如果调用busHealth.checkHealth()，它将返回Healthy或Unhalthy，在后一种情况下，还会给出失败端点的列表。

由于BusHealth只监视总线本身及其所有接收端点，因此当您的服务发布消息失败时，您可能不会收到通知。

您可以使用diagnostics侦听器或创建自己的发布或发送观察器，该观察器在发布/发送之前和之后以及任何失败时调用。