Spring Cloud Stream集成RabbitMQ消费端payload显示ASCII编码问题

我之前也踩过这个坑！你遇到的问题本质上是消息的反序列化环节没有正确匹配生产者指定的application/json类型——生产者发的是JSON格式，但消费端的IntegrationFlow默认把消息当成原始字节数组处理了，你看到的那些ASCII数字其实就是字节数组里每个元素的数值（比如JSON里的{对应的ASCII码是123，就会显示成123）。

咱们一步步来解决：

1. 先确认消费端的绑定配置 #

首先要保证消费端的绑定明确指定了content-type为application/json，这样Spring Cloud Stream才会自动使用对应的转换器。比如在application.yml里配置：

spring:
  cloud:
    stream:
      bindings:
        # 这里替换成你实际的输入绑定名称
        user-operation-input:
          destination: your-queue-name
          content-type: application/json

2. 修正IntegrationFlow的处理逻辑 #

接下来在你的IntegrationFlow里，显式添加JSON反序列化的处理步骤，让Spring把字节数组转换成你需要的实体类（或者Map）。

示例代码（推荐用实体类保证类型安全） #

@EnableBinding(UserOperationConsume.class)
public class ConsumerController {

    @Bean
    public IntegrationFlow consumeUserOperationFlow(UserOperationConsume bindings) {
        return IntegrationFlows.from(bindings.input())
                // 显式指定把JSON转换成你的实体类
                .transform(Transformers.fromJson(YourUserOperationPayload.class))
                .handle(this::processReceivedMessage)
                .get();
    }

    private void processReceivedMessage(Message<YourUserOperationPayload> message) {
        YourUserOperationPayload payload = message.getPayload();
        System.out.println("Received formatted message: " + payload);
    }
}

// 你的输入绑定接口
interface UserOperationConsume {
    @Input("user-operation-input")
    SubscribableChannel input();
}

// 对应的消息实体类，和生产者发送的JSON结构对应
class YourUserOperationPayload {
    private String userId;
    private String operation;
    // 省略getter、setter和toString方法
}

如果不想定义实体类，也可以转成Map： #

.transform(Transformers.fromJson(Map.class))
.handle(message -> {
    Map<String, Object> payload = (Map<String, Object>) message.getPayload();
    System.out.println("Received JSON as Map: " + payload);
})

3. 备选方案：手动解析原始字节数组 #

如果因为某些原因不能用内置转换器，也可以手动把字节数组转成字符串再解析JSON：

.handle(message -> {
    byte[] rawBytes = (byte[]) message.getPayload();
    String jsonString = new String(rawBytes, StandardCharsets.UTF_8);
    // 用Jackson手动解析
    YourUserOperationPayload payload = new ObjectMapper().readValue(jsonString, YourUserOperationPayload.class);
    System.out.println("Received parsed message: " + payload);
})

最后检查依赖 #

确保你的项目里有jackson-databind依赖（Spring Boot项目默认会包含，但如果是自定义依赖管理的话要确认），它是Spring处理JSON序列化/反序列化的核心依赖。

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