rabbitmq - 为什么 "await Publish"挂起/未完成/未完成

Question

下面的代码已经工作了一段时间，但突然停止返回:

await availableChangedPublishEndpoint
   .Publish<IAvailableStockChanged>(
        AvailableStockCounter.ConvertSkuQtyToAvailableStockChangedEvent(
            newAvailable,
            absMessage.Warehouse)
        );

ConvertSkuQtyToAvailableStockChangedEvent 中没有什么聪明之处。 - 它只是将一个简单的类映射到另一个。

我们在这段代码之前和之后添加了日志，它肯定就在此时停止了。其他系统发布良好，其他消息正在从该应用程序发送(例如日志实际上是通过 RabbitMQ 发送的)。我们已重新部署并升级到最新的 MassTransit 版本。我们看到这些消息正在被发布 - 可能多次，但是这个 Publish方法永远不会返回。

Answer 1

我们有一个损坏的 RabbitMQ 节点，并在一个节点上重新启动干净的服务修复了它。我知道这种行为可能还有其他原因，但这是我们的问题。

systemctl 重新启动rabbitmq-server

进一步研究 RabbitMQ，我们发现连接到此交换的一些空队列未同步(见下文)，当我们尝试同步它们时，它们不起作用。

我们也无法删除其中一些不同步的队列。

我们认为其中一个节点的意外关闭导致了此问题 - 但它使大多数队列/交换完全正常。