c# - 如何在不锁定队列的情况下通过 NServiceBus 发送大量消息？

Question

所以我正在对 NServiceBus 进行一些性能评估，我意识到如果您尝试同时发送 1000 条消息，它的行为会非常奇怪......它实际上将它们全部异步发送(这很好)但它会锁定来自处理程序的队列。结果是处理程序无法处理任何消息，直到发件人完成所有消息的发送。

该行为以两种略有不同的方式出现。

• 在处理程序内部，如果您进行大量发送，看起来接收队列会被锁定，直到处理程序完成(假设您在每次发送之间添加一个线程休眠，接收方将不会开始处理消息，直到处理程序完成。

• 如果我只是从更新的总线发送消息，那么短暂的休眠会破坏这种关系，但如果我只是“一次”发送 1000 条消息，处理程序将不会收到第一条消息，直到最后一个是写的，即使每个(在那个时候)都应该是一个单独的调用。

这里是否有一个未记录的批量发送策略或其他正在发生的事情......我知道你不会“想要”正常执行此操作，但了解在从处理程序发送或批量发送期间会发生什么知道一个普通的 BUS 非常重要 ;-)。

Answer 1

默认情况下，NServiceBus 消息处理程序在 TransactionScope 中运行。消息的处理、您对业务数据所做的任何更新以及任何新消息的发送都将完成或一起回滚。这就是事务性消息传递的意义所在。

如果您在消息处理程序中发送 1000 条消息，那么在底层消息传递基础结构成功接收所有消息之前，它不会完成。这可能需要一些时间，具体取决于您的硬件。

如果您想退出这种默认安全的方法，您可以采取多种措施。你可以disable transactional handling对于你的 NServiceBus 端点，或者你可以只 suppress the ambient transaction scope发送消息时。但是请注意，您不再有任何事务保证，因此如果您在发送这 1000 条消息中的 500 条后出现异常，那 500 条将被发送，而 500 条不会。