NServiceBus对ASP.NET Core Controller消息发布的保障及故障恢复问询

消息恢复能力说明 #

当使用Outbox时，完全可以确保这类场景下的消息被恢复并重发。

Outbox的核心设计就是解决"业务事务提交但消息分发失败"的一致性问题：

• 在ASP.NET Core Controller处理同步命令时，业务数据变更和待发送的消息记录会被放入同一个数据库事务中，只有两者都成功，事务才会提交。
• 事务提交后，NServiceBus的后台进程会负责将Outbox中记录的消息分发到对应队列。如果此时发生故障（比如进程崩溃、网络中断）导致分发未完成，NServiceBus会通过定期轮询Outbox存储的机制，找出所有未标记为"已分发"的消息记录，重新执行分发操作，直到消息成功送达并标记状态，以此保证消息的最终一致性。

代码仓库中的对应位置 #

在NServiceBus的官方代码仓库中，相关恢复逻辑主要分布在以下位置：

• 核心轮询调度逻辑：位于NServiceBus.Core项目的Outbox/OutboxPoller.cs，这个类负责按配置的时间间隔轮询Outbox存储，筛选出未完成分发的消息，触发重发流程。
• 消息重发的核心处理逻辑：在NServiceBus.Core项目的Outbox/OutboxBehavior.cs中，负责处理从Outbox读取的待重发消息，执行实际的发送操作，并更新消息的分发状态。
• 数据库持久化层的实现：如果使用特定数据库的Outbox实现（比如SQL Server），对应的状态读取和更新逻辑在对应的持久化项目中，例如NServiceBus.Persistence.Sql下的Outbox/SqlOutboxPersister.cs，负责与数据库交互，管理Outbox记录的生命周期。

内容的提问来源于stack exchange，提问作者geeko