Azure Function向Service Bus发送二进制消息被转字符串如何解决

通过Java编写的Azure Function，使用@ServiceBusQueueOutput输出绑定向Azure Service Bus发送二进制字节数组消息时，队列中实际收到的消息内容固定为字符串"System.Byte[]"，内容类型为text/plain。使用Java应用作为消费端读取消息，拿到的也是该字符串对应的字节内容，而非预期的原始字节数组new byte[] { 1, 3, 4, 5, 6, 7, 8, 9}。

复现代码如下：

package azure.functions;

import com.microsoft.azure.functions.ExecutionContext;
import com.microsoft.azure.functions.annotation.FunctionName;
import com.microsoft.azure.functions.annotation.TimerTrigger;
import com.microsoft.azure.functions.annotation.ServiceBusQueueOutput;

public class ServiceBusPeriodicSampleProducer {
    @FunctionName("ServiceBusPeriodicSampleProducer")
    @ServiceBusQueueOutput(
        name = "serviceBusBinaryMessage", 
        queueName = "test-queue", 
        connection = "ServiceBusConnection", 
        dataType = "binary"
    )
    public byte[] sendSampleMessageToServiceBus(
        @TimerTrigger(name = "timerInfo", schedule = "0 * * * * *") String timerInfo, final ExecutionContext context
    ) {
        context.getLogger().info("Java Timer trigger function executed at: " + java.time.LocalDateTime.now());
        return new byte[] { 1, 3, 4, 5, 6, 7, 8, 9};
    }
}

这个问题是Azure Functions跨语言序列化逻辑的默认行为导致的：

1. 直接以方法返回值形式输出byte[]类型时，Java Worker不会将其识别为二进制payload，而是当作普通托管对象序列化后传递给底层的.NET绑定组件。
2. .NET端的Service Bus输出绑定收到非预期的对象类型时，会直接调用对象的ToString()方法获取内容，.NET中字节数组类型的ToString()固定返回字符串System.Byte[]，数组内存储的实际字节值完全没有被读取。
3. 注解中配置的dataType = "binary"仅对输入绑定（触发器接收消息的格式转换）生效，对输出绑定的返回值序列化逻辑没有强制约束，因此配置后无法解决问题。

二选一即可：

• 方案1（推荐）：返回Service Bus原生消息对象，显式传入二进制payload
  引入Service Bus SDK依赖com.azure:azure-messaging-servicebus，将方法返回值改为ServiceBusMessage类型，构造消息时直接传入字节数组，可显式设置内容类型为二进制流，避免被误识别为文本。
  修改后的代码：

package azure.functions;

import com.azure.messaging.servicebus.ServiceBusMessage;
import com.microsoft.azure.functions.ExecutionContext;
import com.microsoft.azure.functions.annotation.FunctionName;
import com.microsoft.azure.functions.annotation.TimerTrigger;
import com.microsoft.azure.functions.annotation.ServiceBusQueueOutput;

public class ServiceBusPeriodicSampleProducer {
    @FunctionName("ServiceBusPeriodicSampleProducer")
    @ServiceBusQueueOutput(
        name = "serviceBusBinaryMessage", 
        queueName = "test-queue", 
        connection = "ServiceBusConnection"
    )
    public ServiceBusMessage sendSampleMessageToServiceBus(
        @TimerTrigger(name = "timerInfo", schedule = "0 * * * * *") String timerInfo, final ExecutionContext context
    ) {
        context.getLogger().info("Java Timer trigger function executed at: " + java.time.LocalDateTime.now());
        byte[] payload = new byte[] { 1, 3, 4, 5, 6, 7, 8, 9};
        ServiceBusMessage message = new ServiceBusMessage(payload);
        message.setContentType("application/octet-stream");
        return message;
    }
}

• 方案2：使用OutputBinding作为入参赋值，绕过返回值默认序列化
  不直接通过方法返回值传递消息，而是将输出绑定声明为方法入参OutputBinding<byte[]>，在方法内部显式调用setValue传入字节数组，此时Worker会正确识别二进制类型，不会触发默认的ToString逻辑。
  修改后的代码：

package azure.functions;

import com.microsoft.azure.functions.ExecutionContext;
import com.microsoft.azure.functions.OutputBinding;
import com.microsoft.azure.functions.annotation.FunctionName;
import com.microsoft.azure.functions.annotation.TimerTrigger;
import com.microsoft.azure.functions.annotation.ServiceBusQueueOutput;

public class ServiceBusPeriodicSampleProducer {
    @FunctionName("ServiceBusPeriodicSampleProducer")
    public void sendSampleMessageToServiceBus(
        @TimerTrigger(name = "timerInfo", schedule = "0 * * * * *") String timerInfo,
        @ServiceBusQueueOutput(
            name = "serviceBusBinaryMessage", 
            queueName = "test-queue", 
            connection = "ServiceBusConnection",
            dataType = "binary"
        ) OutputBinding<byte[]> serviceBusBinaryMessage,
        final ExecutionContext context
    ) {
        context.getLogger().info("Java Timer trigger function executed at: " + java.time.LocalDateTime.now());
        byte[] payload = new byte[] { 1, 3, 4, 5, 6, 7, 8, 9};
        serviceBusBinaryMessage.setValue(payload);
    }
}

两种方案修改后，消费端从Service Bus读取消息时都能拿到原始的字节数组内容。

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