Azure传输NServiceBus中，单独线程发布的OperationComplete事件丢失问题

我之前在Azure Service Bus传输上用NServiceBus实现长运行流程时，也碰到过几乎一模一样的问题——手动开线程跑任务后，OperationComplete事件总是“失踪”，只有紧跟在OperationStarted后发布才能被收到。咱们来拆解下问题根源和解决方案：

问题核心原因 #

你当前的实现方式有个关键隐患：当你标记初始事件处理任务完成后，NServiceBus会回收对应消息的IMessageHandlerContext上下文。而你在单独线程里发布OperationComplete时，大概率是在使用已被释放的上下文，或者没有使用正确的持久化消息会话，导致事件无法被正确路由到订阅者。

另外，Azure Service Bus的传输特性也可能加剧这个问题：如果你的端点开启了会话模式，后续发布的事件需要和初始消息处于同一个会话上下文，但单独线程的操作已经脱离了这个会话，自然无法被订阅者接收。

具体解决方案 #

1. 放弃手动线程管理，改用NServiceBus Saga（官方推荐） #

Saga是NServiceBus专门为长运行流程设计的组件，它天然支持跟踪流程状态、关联事件，完全不需要你手动处理线程和上下文问题。举个简单的实现示例：

// Saga数据类，用于跟踪长运行操作状态
public class LongRunningOperationSagaData : ContainSagaData
{
    public Guid OperationId { get; set; }
    // 可以添加更多状态字段，比如操作进度、开始时间等
}

// Saga处理类
public class LongRunningOperationSaga : Saga<LongRunningOperationSagaData>,
    IAmStartedByMessages<OperationStarted>,
    IHandleMessages<OperationComplete>
{
    // 配置Saga与消息的关联规则，通过OperationId绑定
    protected override void ConfigureHowToFindSaga(SagaPropertyMapper<LongRunningOperationSagaData> mapper)
    {
        mapper.MapSaga(saga => saga.OperationId)
              .ToMessage<OperationStarted>(msg => msg.OperationId)
              .ToMessage<OperationComplete>(msg => msg.OperationId);
    }

    // 处理OperationStarted事件，触发长运行流程
    public async Task Handle(OperationStarted message, IMessageHandlerContext context)
    {
        Data.OperationId = message.OperationId;
        // 发送命令到专门的处理程序执行长流程（而不是开线程）
        await context.Send(new ExecuteLongRunningProcessCommand { OperationId = message.OperationId });
    }

    // 处理OperationComplete事件，完成流程
    public async Task Handle(OperationComplete message, IMessageHandlerContext context)
    {
        // 执行完成后的业务逻辑，比如通知用户、更新数据库等
        await context.Publish(new OperationFinalized { OperationId = message.OperationId });
        // 标记Saga完成，释放资源
        MarkAsComplete();
    }
}

在这个模式下，长流程的执行由ExecuteLongRunningProcessCommand的处理程序负责，当流程完成时，直接用IMessageHandlerContext发布OperationComplete事件——Saga会通过OperationId自动关联到对应的实例，确保事件100%被接收处理。

2. 若坚持手动实现，确保使用正确的消息会话 #

如果你暂时不想改用Saga，那必须保证发布OperationComplete时使用持久化的IMessageSession，而不是初始消息的IMessageHandlerContext：

• 在你的长流程服务中注入IMessageSession（而不是从初始上下文传递）
• 当长流程完成时，用_messageSession.Publish(new OperationComplete { ... })来发布事件

示例代码：

public class LongRunningProcessService
{
    private readonly IMessageSession _messageSession;

    public LongRunningProcessService(IMessageSession messageSession)
    {
        _messageSession = messageSession;
    }

    public async Task ExecuteProcess(Guid operationId)
    {
        // 执行长运行逻辑...
        await Task.Delay(TimeSpan.FromMinutes(10));

        // 使用IMessageSession发布完成事件
        await _messageSession.Publish(new OperationComplete { OperationId = operationId });
    }
}

同时要检查你的Azure传输配置：如果开启了会话模式，要么关闭它（除非你明确需要会话），要么在发布事件时手动指定会话ID，确保和初始消息的会话一致。

3. 排查订阅与传输配置 #

• 确认OperationComplete事件的处理程序已经在端点配置中注册
• 检查Azure Service Bus的订阅规则，是否存在过滤条件导致事件被丢弃
• 查看死信队列，确认事件没有因为重试失败或其他异常被移入死信

总结 #

手动管理线程和上下文很容易踩NServiceBus传输的坑，官方推荐的Saga模式不仅能解决事件接收问题，还能让长运行流程的状态管理更清晰、更可靠。

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