请求/响应模式：停止消费者在应用程序重新启动时重新处理消息

Question

我正在使用 Masstransit 请求/响应模式。所以我有一个请求者应用程序和一个消费者应用程序，它们运行得非常好。我没有配置任何重试/重新传递，就好像消费者发生了任何错误一样，请求者将处理它或者可能会发送另一个请求。到目前为止一切顺利。

但是如果消费者应用程序在进程中间崩溃并重新启动，消费者会尝试从队列中获取消息并开始重新处理它，这不适用于我的情况。因为当消费者应用程序崩溃时，请求者会得到错误响应（或超时）。我知道 MassTransit 中的 MessageRetry 完全在内存中。

我的问题是，我们能否以某种方式阻止消费者在应用程序重启时重新处理消息？或者我们需要从服务总线队列中删除待处理的消息？

Answer 1

请求客户端发送的消息与请求客户端之间没有连接。使用请求超时作为默认值，MassTransit 将消息的TimeToLive 设置为相同的值。一旦 TimeToLive 过期，传输应该删除该消息。

如果消费者应用程序在使用消息时崩溃，则该消息将保留在队列中。如果该消息反复导致您的应用程序崩溃，您可以检查ReceiveContext 上的Redelivered 属性（ConsumeContext 上的一个属性），如果您认为该消息导致进程崩溃，则可能以另一种方式处理该消息崩溃。

当然，真正的解决方案是修复消费者，使其不会导致进程崩溃...

更新

如果您希望 Azure 服务总线在消费进程崩溃时将消息移动到死信队列，则可以使用 DeliveryCount 或 1 配置接收端点。