Azure Service Bus发送消息至队列时静默失败问题求助

核心问题 #

监听器处理队列消息后发送至响应队列时，第二条消息无报错但未进入响应队列，ServiceBusClient已注册为单例，其他函数可正常发送消息。

代码问题排查 #

给出的发送代码如下：

try
{
    await using var sender = _serviceBusClient.CreateSender(queueName);
    var message = new ServiceBusMessage(messageContent);
    await sender.SendMessageAsync(message);

    _logger.LogInformation("Message sent successfully to {QueueName} at {Time}", queueName, DateTime.UtcNow);
    _logger.LogInformation("Sender state: Closed={Closed}, HasPending=Unknown", sender.IsClosed); // SDK doesn’t expose pending

    return true;
}
catch (ServiceBusException sbEx) when (sbEx.IsTransient)
{
    _logger.LogError(sbEx, "ServiceBusException while sending to {QueueName}. IsTransient: {IsTransient}",
        queueName, sbEx.IsTransient);
    System.Threading.Thread.Sleep(2000);
    return false;
}
catch (Exception ex)
{
    _logger.LogInformation($"Error sending message to service bus queue: {ex.Message}");
    return false;
}

可能的原因及修复方案 #

1. await using 导致Sender提前释放 #

await using var sender会在代码块结束时立即释放Sender，而Azure Service Bus的Sender在释放时可能中断尚未完成的内部异步操作。即便调用了await SendMessageAsync，某些场景下（如SDK内部缓冲机制），消息可能还处于待发送状态就被释放，导致消息丢失。

修复：复用Sender实例，而非每次发送都创建新实例。ServiceBusClient是单例，Sender本身线程安全，可长期复用：

// 在类中初始化Sender作为私有成员（假设queueName固定）
private readonly ServiceBusSender _sender;

public YourListenerClass(ServiceBusClient serviceBusClient, string responseQueueName)
{
    _sender = serviceBusClient.CreateSender(responseQueueName);
}

// 发送方法修改为：
try
{
    var message = new ServiceBusMessage(messageContent);
    await _sender.SendMessageAsync(message);

    _logger.LogInformation("Message sent successfully to {QueueName} at {Time}", queueName, DateTime.UtcNow);
    return true;
}
catch (ServiceBusException sbEx) when (sbEx.IsTransient)
{
    _logger.LogError(sbEx, "ServiceBusException while sending to {QueueName}. IsTransient: {IsTransient}",
        queueName, sbEx.IsTransient);
    await Task.Delay(2000); // 替代Thread.Sleep，避免阻塞异步线程
    return false;
}
catch (Exception ex)
{
    _logger.LogError(ex, "Error sending message to service bus queue: {Message}", ex.Message);
    return false;
}

2. 异常日志级别过低，遗漏关键错误 #

原代码中普通Exception使用LogInformation记录，且仅输出消息内容，若日志级别配置为Warning或Error，这类信息可能不会被输出，导致真实错误被忽略（比如非瞬态的ServiceBusException：权限不足、队列不存在等）。

修复：将普通Exception的日志改为LogError，并传入完整异常对象以保留堆栈信息：

catch (Exception ex)
{
    _logger.LogError(ex, "Error sending message to service bus queue: {Message}", ex.Message);
    return false;
}

3. 线程阻塞导致异步上下文混乱 #

原代码在异步方法中使用Thread.Sleep(2000)阻塞线程，可能破坏异步上下文，影响后续操作的正常执行。

修复：替换为await Task.Delay(2000)，避免阻塞线程。

4. 消息内容异常 #

第二条消息的messageContent可能存在格式错误、体积过大或包含特殊字符，导致ServiceBus静默拒绝消息（此类情况少见，但需排查）。

排查：在发送前增加日志输出messageContent的长度和内容摘要，确认第二条消息内容合法。

额外建议 #

• 启用ServiceBus SDK的详细日志，查看内部发送过程的细节，精准定位静默失败原因。
• 若存在批量发送场景，使用SendMessagesAsync批量发送，减少Sender创建的开销。

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