回复内容类型

DeepSeek V3 中英对照 Reply ContentType

如果你正在使用一个复杂的消息转换器，例如 ContentTypeDelegatingMessageConverter，你可以通过在监听器上设置 replyContentType 属性来控制回复的内容类型。这使得转换器能够为回复选择合适的委托转换器。

@RabbitListener(queues = "q1", messageConverter = "delegating",
        replyContentType = "application/json")
public Thing2 listen(Thing1 in) {
    ...
}

java

默认情况下，为了向后兼容，由转换器设置的任何内容类型属性在转换后都会被此值覆盖。像 SimpleMessageConverter 这样的转换器使用回复类型而不是内容类型来确定所需的转换，并适当地在回复消息中设置内容类型。这可能不是期望的行为，可以通过将 converterWinsContentType 属性设置为 false 来覆盖。例如，如果你返回一个包含 JSON 的 String，SimpleMessageConverter 会将回复中的内容类型设置为 text/plain。以下配置将确保即使使用 SimpleMessageConverter，内容类型也会被正确设置。

@RabbitListener(queues = "q1", replyContentType = "application/json",
        converterWinsContentType = "false")
public String listen(Thing in) {
    ...
    return someJsonString;
}

java

当返回类型是 Spring AMQP 的 Message 或 Spring Messaging 的 Message<?> 时，这些属性（replyContentType 和 converterWinsContentType）不适用。在第一种情况下，不涉及转换；只需设置 contentType 消息属性。在第二种情况下，行为是通过消息头来控制的：

@RabbitListener(queues = "q1", messageConverter = "delegating")
@SendTo("q2")
public Message<String> listen(String in) {
    ...
    return MessageBuilder.withPayload(in.toUpperCase())
            .setHeader(MessageHeaders.CONTENT_TYPE, "application/xml")
            .build();
}

java

此内容类型将通过 MessageProperties 传递给转换器。默认情况下，为了向后兼容，转换器设置的任何内容类型属性在转换后都会被此值覆盖。如果您希望覆盖该行为，请将 AmqpHeaders.CONTENT_TYPE_CONVERTER_WINS 设置为 true，这样转换器设置的任何值都将被保留。