如何在Java中向RabbitMQ消息负载中添加SOH Unicode字符

嗨，看起来你遇到的问题是发送带SOH（\u0001）字符的消息时，RabbitMQ里的负载变成了转义后的字符串，而不是实际的SOH控制字符。我来帮你分析下原因并给出解决方案：

问题根源 #

最可能的原因是消息被JSON序列化器处理了——如果你的Spring AMQP配置中默认使用了Jackson2JsonMessageConverter（比如项目中引入了Spring Boot的JSON相关依赖），它会把字符串消息序列化成JSON格式的字符串，这就会把\u0001转义成字面量的\\u0001，导致接收方无法识别实际的控制字符。

另外，默认的SimpleMessageConverter其实是可以正确处理字符串中的控制字符的，但如果有自定义的Converter覆盖了默认配置，也会出现这个问题。

解决方案 #

方案1：直接发送字节数组（最可靠）

绕过字符串序列化的问题，直接把包含SOH的字符串转成字节数组发送，这样RabbitMQ会原封不动地存储字节：

import java.nio.charset.StandardCharsets;

// 构造包含SOH的字符串
String content = "test\u0001test";
// 转成UTF-8字节数组
byte[] payload = content.getBytes(StandardCharsets.UTF_8);
// 发送字节数组
rabbitTemplate.convertAndSend(messageQueueName, payload, m -> {
    m.getMessageProperties().setContentType("text/plain");
    m.getMessageProperties().setContentEncoding("UTF-8");
    return m;
});

这样发送的消息负载就是实际的字节，其中包含0x01（SOH的ASCII码），接收方只要按UTF-8解码字节数组就能得到带SOH的字符串。

方案2：确保使用StringMessageConverter

如果想继续用字符串发送，需要明确配置Spring AMQP使用StringMessageConverter，而不是JSON转换器：

1. 在配置类中定义StringMessageConverter的Bean：

import org.springframework.amqp.support.converter.StringMessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {

    @Bean
    public StringMessageConverter stringMessageConverter() {
        return new StringMessageConverter();
    }
}

2. 发送时指定使用这个Converter（或者让RabbitTemplate自动注入）：

rabbitTemplate.setMessageConverter(stringMessageConverter());
rabbitTemplate.convertAndSend(messageQueueName, "test\u0001test", m -> {
    m.getMessageProperties().setContentType("text/plain");
    m.getMessageProperties().setContentEncoding("UTF-8");
    return m;
});

方案3：检查接收方的处理逻辑

有时候问题可能出在接收方——如果接收方把消息负载当成JSON字符串解析，也会把\u0001当成转义字符处理。确保接收方直接按字节数组转成字符串，而不是用JSON解析器处理。

比如接收方代码：

@RabbitListener(queues = "${message.queue.name}")
public void receiveMessage(byte[] payload) {
    String content = new String(payload, StandardCharsets.UTF_8);
    // 处理包含SOH的字符串
}

验证方法 #

你可以用RabbitMQ管理界面查看消息的原始字节（而不是字符串显示），或者用命令行工具rabbitmqctl导出消息，确认0x01字节是否存在。很多RabbitMQ UI工具会把控制字符显示成转义的Unicode字面量，但实际字节是正确的——这时候接收方只要正确解码就能识别SOH。

备注：内容来源于stack exchange，提问作者bob morane