Spring Integration中使用Paho接收二进制MQTT消息异常问题

我完全懂你遇到的困扰——DefaultPahoMessageConverter默认会把MQTT消息的payload转换成UTF-8字符串，而像PNG这类二进制数据里有大量非UTF-8兼容的字节，转成字符串再转回字节时肯定会破坏原始内容。你之前尝试设置BytesMessageMapper没效果，大概率是因为默认的转换器逻辑还是优先做了String转换，没真正启用字节模式。

下面是确保无损接收二进制消息的正确方案：

1. 自定义DefaultPahoMessageConverter，启用字节模式 #

核心就是在初始化转换器时，通过构造函数传入true参数，指定payload以原始字节数组形式保留，跳过String转换步骤：

@Configuration
public class MqttConfig {

    @Bean
    public DefaultPahoMessageConverter pahoMessageConverter() {
        // 传入true表示直接保留payload的字节数组，不转为String
        return new DefaultPahoMessageConverter(true);
    }

    // 其他MQTT相关配置（客户端工厂等）
}

2. 在入站适配器中绑定自定义转换器 #

确保你的MQTT消息驱动适配器使用上面定义的转换器，覆盖默认的String转换逻辑：

@Bean
public MessageProducer mqttInboundAdapter(MqttPahoClientFactory clientFactory,
                                          DefaultPahoMessageConverter converter) {
    MqttPahoMessageDrivenChannelAdapter adapter = new MqttPahoMessageDrivenChannelAdapter(
            "mqtt-binary-receiver", // 自定义客户端ID
            clientFactory,
            "your-binary-topic" // 订阅的二进制消息主题
    );
    adapter.setQos(1);
    adapter.setConverter(converter); // 绑定自定义转换器
    adapter.setOutputChannel(mqttBinaryInputChannel());
    return adapter;
}

@Bean
public MessageChannel mqttBinaryInputChannel() {
    return new DirectChannel();
}

3. 直接处理二进制消息 #

此时消息的payload已经是byte[]类型，无需额外转换，直接处理即可：

@ServiceActivator(inputChannel = "mqttBinaryInputChannel")
public void handleBinaryMqttMessage(byte[] payload) {
    // 示例：将二进制数据保存为PNG图片
    try (FileOutputStream outputStream = new FileOutputStream("received-image.png")) {
        outputStream.write(payload);
        System.out.println("二进制消息接收并保存成功");
    } catch (IOException e) {
        e.printStackTrace();
    }
}

为什么之前设置BytesMessageMapper没效果？ #

DefaultPahoMessageConverter的setBytesMessageMapper方法只有在payloadAsBytes为true时才会生效。如果用默认构造器初始化转换器（payloadAsBytes默认为false），转换器会优先把payload转为String，此时设置BytesMessageMapper不会改变这个核心逻辑，所以二进制内容还是会损坏。

按照上面的步骤配置后，就能确保MQTT的二进制消息以原始字节数组的形式被接收和处理，不会出现内容损坏的问题。

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