创建监听Service Bus订阅的Windows Service：MessageHandler未触发

核心问题 #

你的代码里OnStart方法的finally块会在启动处理器后立即释放processor和client实例，导致监听器刚启动就被销毁，根本无法持续监听消息，自然不会触发MessageHandler。

修复步骤 #

1. 移除OnStart中的资源释放逻辑：将processor和client的Dispose操作移到OnStop方法中，保证服务运行期间实例始终存活。
2. 保留类级成员引用：确保processor和client作为类的成员变量，让OnStop能访问到实例进行清理。
3. 优化错误处理流程：启动失败时才清理资源，避免正常启动后提前销毁实例。

修正后的代码示例 #

// 类级成员，确保OnStop能访问到实例
private ServiceBusClient _client;
private ServiceBusProcessor _processor;
private readonly ILogger _logger;

protected override async void OnStart(string[] args)
{
    _logger.Information("服务已启动");

    _client = new ServiceBusClient(connectionString, new ServiceBusClientOptions()
    {
        TransportType = ServiceBusTransportType.AmqpWebSockets
    });

    // 创建消息处理器
    _processor = _client.CreateProcessor(topicName, subscriptionName, new ServiceBusProcessorOptions());

    try
    {
        // 绑定消息处理和错误处理事件
        _processor.ProcessMessageAsync += MessageHandler;
        _processor.ProcessErrorAsync += ErrorHandler;

        // 启动消息处理
        await _processor.StartProcessingAsync();
        _logger.Information("消息监听器已启动，等待接收消息");
    }
    catch (Exception ex)
    {
        _logger.Error(ex, "启动监听器时出错");
        // 启动失败时清理资源
        await CleanupResourcesAsync();
    }
}

static async Task MessageHandler(ProcessMessageEventArgs args)  
{
    try
    {              
        var sqliteUploadFileDto = JsonConvert.DeserializeObject<TestDto>(args.Message.Body.ToString());
        _logger.Information($"收到新消息 - {args.Message.Body.ToString()}");
        await args.CompleteMessageAsync(args.Message);
    }
    catch (Exception ex)
    {
        _logger.Error(ex, "处理消息时出错");
        // 异常时放弃消息，让其重新入队（可根据业务调整）
        await args.AbandonMessageAsync(args.Message);
    }
}

static Task ErrorHandler(ProcessErrorEventArgs args)
{
    _logger.Error(args.Exception, "消息监听器发生错误");
    return Task.CompletedTask;
}

protected override async void OnStop()
{
    _logger.Information("正在停止消息监听器...");
    await CleanupResourcesAsync();
    _logger.Information("消息监听器已停止");
}

// 统一的资源清理方法
private async Task CleanupResourcesAsync()
{
    if (_processor != null)
    {
        await _processor.StopProcessingAsync();
        await _processor.DisposeAsync();
    }
    if (_client != null)
    {
        await _client.DisposeAsync();
    }
}

额外注意事项 #

• 确认connectionString、topicName、subscriptionName配置正确，且服务运行账号拥有Service Bus订阅的读取权限。
• .NET Framework 4.6.2使用Azure.Messaging.ServiceBus时，需安装兼容该框架的NuGet包版本（建议选择最新兼容版本）。
• MessageHandler中避免直接抛出异常，优先使用AbandonMessageAsync或DeadLetterMessageAsync处理异常消息，防止消息丢失。

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