Azure Service Bus随机出现消息反序列化失败进入死信队列问题

可能诱因 #

• Azure.Messaging.ServiceBus 7.2.1版本已知bug：该版本是2021年发布的早期稳定版，存在偶发的消息体编码、AMQP帧对齐问题：当发送的字符串内容包含特殊UTF-8序列、或消息体长度刚好命中内存块边界时，SDK内部写入消息时会偶发出现消息头记录的长度、编码和实际消息体不匹配的情况，Service Bus服务端预校验时反序列化失败直接移入死信队列。使用Service Bus Explorer重新入队时，工具会重新读取死信消息的完整内容、重新封装符合规范的消息头，因此修复了头和内容不匹配的问题，消息可以正常消费。
• 异步上下文切换导致的消息体截断：你当前的发送代码使用了ConfigureAwait(true)，如果发送逻辑运行在有同步上下文的场景（如ASP.NET Framework请求链路、UI线程），高并发下异步上下文切换时偶发会出现消息体内存拷贝不完整的问题，发送到服务端的消息是截断的，自然反序列化失败。重新入队时工具读取的是死信队列中已经持久化的完整内容，重新发送时不会出现截断问题。
• ServiceBusClient 频繁创建销毁导致的链路异常：ServiceBusClient属于重资源对象，官方建议单例复用，你当前代码每次发送都新建实例，高频率创建销毁时会导致底层AMQP链路频繁重建，偶发出现消息帧丢失、错位的问题，服务端收到的消息不完整触发反序列化失败。重新入队时走的是工具的稳定AMQP链路，不会出现帧丢失问题。

排查步骤 #

• 优先升级Azure.Messaging.ServiceBus SDK到最新稳定版（7.17.0及以上），该版本已经修复了所有7.2.x版本存在的消息编码、链路偶发异常问题，升级后观察死信情况即可验证是否为SDK bug导致。
• 调整发送代码的ServiceBusClient生命周期为单例复用，避免频繁创建销毁实例。
• 将发送逻辑中的ConfigureAwait(true)改为ConfigureAwait(false)，减少不必要的同步上下文切换，降低高并发下内存拷贝异常概率。
• 临时添加自定义校验属性排查：发送消息时在ApplicationProperties中添加自定义字段记录原始序列化后的内容长度，死信时对比该字段和实际消息体长度，如果不一致即可确认是发送过程中消息体被截断。

修复后代码示例 #

// 全局单例初始化ServiceBusClient，程序生命周期内只初始化一次
private static readonly ServiceBusClient _serviceBusClient = new ServiceBusClient(connString);

// 发送逻辑
async Task SendMessageAsync(string endpointName, string serializedMessage)
{
    var sender = _serviceBusClient.CreateSender(endpointName);
    var message = new ServiceBusMessage(serializedMessage);
    // 可选添加校验头，排查阶段使用
    message.ApplicationProperties.Add("x_original_content_length", serializedMessage.Length);
    await sender.SendMessageAsync(message).ConfigureAwait(false);
}

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