c# - NServiceBus 事件在超时队列中结束

Question

我正在使用 HandleMyEvent 类处理事件

public class HandleMyEvent :  IHandleMessages<MyEvent>
{

    private readonly IBus _bus;
    private readonly IWorkorker _workerTools;


    public HandleProductInstanceEvent( IBus bus, IWorkorker worker)
    {
        _bus = bus;
        _workerTools = worker;

    }

    public void Handle(IProductInstancesUpdatedEvent message)
    {
        var worker = new myWorker(_bus, _worker);
        myWorker.DoWork(message.data);
    }
}

myWorker.DoWork 在完成前最多可以运行 5 分钟。

当发布者发送单个“MyEvent”时，处理程序似乎在超时队列中的消息结束之前接收到 5 个事件，我猜它在放弃之前重试了 5 次。

在日志文件中我可以找到这个条目

NServiceBus.Unicast.Queuing.FailedToSendMessageException: Failed to send message to address: My.Bus.Service@MyServer ---> System.Messaging.MessageQueueException: Cannot enlist the transaction.
   at System.Messaging.MessageQueue.SendInternal(Object obj, MessageQueueTransaction internalTransaction, MessageQueueTransactionType transactionType)
   at NServiceBus.Transports.Msmq.MsmqMessageSender.Send(TransportMessage message, Address address) in c:\work\3206e2123f54fce4\src\NServiceBus.Core\Transports\Msmq\MsmqMessageSender.cs:line 59

为什么会出现此错误？

Answer 1

您收到该错误是因为在 NServiceBus 中处理 MSMQ 消息，默认情况下，在超时为 1 分钟的事务中运行。

一旦超过事务超时，任何新操作(例如发送消息或在数据库中存储内容)都将失败并显示

Cannot enlist the transaction.

你应该 increase your transaction timeout超过预期的处理时间或 turn off transactions在这个端点上。

请注意，消息处理程序运行 5 分钟是很长的时间。在如此长的时间段内对事务资源进行事务处理并因此锁定并不是最佳选择。

一旦消息处理失败，事务回滚，将消息放回队列。然后重试您配置的许多第一级重试尝试。在您的场景中很可能是 5 个。之后，它被转移到二级重试。

.timeout 队列是超时管理器的输入队列，负责处理二级重试。如果消息没有立即从此队列中提取，则说明您没有在该端点上运行超时管理器。