为何无法向高级层Service Bus Topic推送500KB消息？

针对你遇到的高级层Topic只能接收最大64KB消息的问题，以下是关键的遗漏配置排查点及解决方法：

1. 客户端未配置AMQP大消息分块支持 #

Azure Service Bus高级层本身支持大消息，但默认的AMQP客户端配置可能未启用分块传输，导致超过64KB的消息被静默截断。需要在创建ServiceBusClient时显式配置AMQP传输参数，匹配Topic的消息大小限制：

修改AzureServiceBusFactory中的GetServiceBusClient方法：

protected virtual ServiceBusClient GetServiceBusClient(string connectionString)
{
    var key = $"{connectionString}";

    lock (this._lockObject)
    {
        if (this.ClientDoesnotExistOrIsClosed(connectionString))
        {
            var client = new ServiceBusClient(connectionString, new ServiceBusClientOptions
            {
                TransportType = ServiceBusTransportType.AmqpTcp,
                AmqpTransportSettings = new AmqpTransportSettings
                {
                    // 设置与Topic一致的最大消息大小（1024KB）
                    MaxMessageSize = 1024 * 1024,
                    // 启用分块传输，确保大消息能被拆分发送
                    EnableLinkRedirect = true
                }
            });

            this._clients[key] = client;
        }

        return this._clients[key];
    }
}

2. 显式配置Sender的消息大小限制 #

在创建ServiceBusSender时，单独指定最大消息大小，确保与Topic配置对齐：
修改GetClient方法中创建Sender的代码：

var sender = client.CreateSender(senderName, new ServiceBusSenderOptions
{
    MaxMessageSize = 1024 * 1024
});

3. 验证序列化过程是否存在截断 #

检查message.AsJson()扩展方法的实现，确认JSON序列化时没有对输出内容做长度限制。可以临时将序列化后的字符串长度写入日志，验证其是否达到预期的500KB左右，排除序列化层面的截断问题。

4. 确认命名空间的定价层级 #

再次确认你的Service Bus命名空间确实是高级层：基础层默认最大消息大小为64KB，即使Topic单独设置了更大的值，也会被命名空间的层级限制覆盖。可以在Azure门户中查看命名空间的定价层级信息。

额外排查建议 #

• 启用SDK调试日志，查看发送过程中是否有隐藏的警告：
  在ServiceBusClientOptions中添加诊断配置：

  new ServiceBusClientOptions
  {
      // ...其他配置
      Diagnostics = new ServiceBusDiagnosticsOptions
      {
          LogLevel = LogLevel.Debug
      }
  }
  

• 使用Azure Service Bus Explorer工具直接向该Topic发送500KB的测试消息，验证是否能完整接收，快速定位是代码问题还是服务端配置问题。

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