Spring云流消息自/到JSON转换配置

Question

我正在使用Spring Cloud Stream和RabbitMQ活页夹。它可以很好地处理字节[]负载和Java本机序列化，但我需要处理JSON负载。

这是我的处理器类。

@EnableBinding(Processor.class)
public class MessageProcessor {
    @ServiceActivator(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT)
    public OutputDto handleIncomingMessage(InputDto inputDto) {
        // Run some job.
        return new OutputDto();
    }
}

输入到和输出到是带有Jackson注释的POJO。

• 如何配置JSON转换策略
• 消息头应该如何被接受和处理

Answer 1

在消费者中，您可以添加内容类型配置，例如：。

spring.cloud.stream.bindings.input.content-type: application/x-java-object;type=my.package.InputDto

您还可以添加

spring.cloud.stream.bindings.output.content-type: application/json

强制传出消息负载为JSON（用于互操作等）。

请注意，“input”（输入）和“output”（输出）是活页夹频道名称（即，如应用程序中处理器的定义）。

我认为这很有可能变得更容易或更自动化，但要在Spring Cloud中实现这一点，还需要一些工程上的努力。如果您想遵循github中的问题：https://github.com/spring-cloud/spring-cloud-stream/issues/156.

要手动将消息发送到Spring Cloud Stream，您可以自己手动设置标头（但使用Stream更容易）。JSON消息在Rabbit管理员UI中如下所示：

priority:   0
delivery_mode:  2
headers:    
    contentType:    text/plain
    originalContentType:    application/json
content_type:   text/plain