Azure Functions中IAsyncCollector无法发送ServiceBusMessage的Body属性问题

安全阿岳

2026-9-30

问题根因与解决方案

这个问题绝大多数情况不是业务实现逻辑错误，而是Azure Functions Service Bus扩展绑定的版本兼容问题、类型引用错误导致的属性序列化异常，属于常见已知坑点，非Service Bus服务侧Bug。

排查与修复步骤

第一步：核对函数运行模型、扩展包版本与类型引用
不同版本扩展包、不同进程模型的Service Bus绑定依赖的类型完全独立，混用会导致属性无法被绑定正确读取：
- 3.x版本Service Bus扩展包：输出绑定支持的消息类型为Microsoft.Azure.ServiceBus.Message，使用高版本的ServiceBusMessage会出现属性丢失
- 5.x及以上版本进程内（In-Process）托管模型：必须引用Azure.Messaging.ServiceBus命名空间下的ServiceBusMessage类型，配套使用Microsoft.Azure.WebJobs.Extensions.ServiceBus 5.x及以上版本扩展包
- 隔离进程（Isolated Worker）托管模型：必须引用Microsoft.Azure.Functions.Worker.Extensions.ServiceBus命名空间下的消息类型，禁止混用进程内模型的ServiceBusMessage类型
第二步：修改消息初始化逻辑，规避绑定序列化缺陷
部分旧版本的Service Bus扩展绑定存在识别空构造函数初始化的消息Body属性的缺陷，改为构造函数直接传入Body即可修复：
```
// 替换原有的空构造+手动赋值Body写法
var m = new ServiceBusMessage(BinaryData.FromString(JsonConvert.SerializeObject(myEvent)));
m.CorrelationId = correlationId.ToString();
await output.AddAsync(m);
```
第三步：临时替代方案验证
如果上述步骤仍无法解决，可直接注入ServiceBusClient实例手动发送消息，绕过输出绑定的序列化逻辑，确认是否为绑定本身的版本缺陷。