AWS Spring中MessageTemplate配置ObjectMapper后Jackson序列化不生效问题

问题根因 #

你配置的QueueMessageHandlerFactory中自定义的Jackson消息转换器仅对消息消费逻辑生效，发送消息使用的NotificationMessagingTemplate、QueueMessagingTemplate未绑定该自定义转换器，默认使用的通用转换器不识别Jackson注解，也未注册Java8时间类型序列化模块，导致LocalDateTime被拆分为多字段输出。

修复方案 #

修改你的配置类，将自定义Jackson消息转换器注入到发送用的消息模板中：

1. 先抽离公共的Jackson消息转换器Bean，避免重复构建
2. 给两个消息模板显式设置消息转换器
3. 消费端配置直接复用该转换器即可

修改后的完整配置代码如下：

@Configuration
class AwsMessagingConfigurationLocal(
   @Value("\${cloud.aws.region.static}") val region: String,
   @Value("\${cloud.aws.credentials.accessKey}") val accessKey: String,
   @Value("\${cloud.aws.credentials.secretKey}") val secretKey: String,
   @Value("\${cloud.aws.endpoint}") val endpoint: String
) {
    // 抽离公共的Jackson消息转换器
    @Bean
    fun mappingJackson2MessageConverter(objectMapper: ObjectMapper): MappingJackson2MessageConverter {
        val messageConverter = MappingJackson2MessageConverter()
        // 指定序列化后的 payload 类型为字符串，适配SQS/SNS的消息格式要求
        messageConverter.serializedPayloadClass = String::class.java
        // 注册Java时间序列化模块，识别@JsonFormat注解
        messageConverter.objectMapper = objectMapper.registerModule(JavaTimeModule())
        return messageConverter
    }

    @Bean
    fun notificationMessageTemplate(messageConverter: MappingJackson2MessageConverter): NotificationMessagingTemplate {
        val template = NotificationMessagingTemplate(buildAmazonSNSAsync())
        // 给SNS发送模板绑定自定义转换器
        template.messageConverter = messageConverter
        return template
    }

    @Bean
    fun queueMessagingTemplate(messageConverter: MappingJackson2MessageConverter): QueueMessagingTemplate {
        val template = QueueMessagingTemplate(buildAmazonSQSAsync())
        // 给SQS发送模板绑定自定义转换器
        template.messageConverter = messageConverter
        return template
    }

    @Bean
    fun simpleMessageListenerContainerFactory(): SimpleMessageListenerContainerFactory {
        val messageListenerContainerFactory = SimpleMessageListenerContainerFactory()
        messageListenerContainerFactory.setAmazonSqs(buildAmazonSQSAsync())
        return messageListenerContainerFactory
    }

    @Bean
    fun queueMessageHandlerFactory(messageConverter: MappingJackson2MessageConverter): QueueMessageHandlerFactory {
        val queueMessageHandlerFactory = QueueMessageHandlerFactory()
        queueMessageHandlerFactory.messageConverters = listOf(messageConverter)
        queueMessageHandlerFactory.setArgumentResolvers(listOf(NotificationMessageArgumentResolver(messageConverter)))
        return queueMessageHandlerFactory
    }

    private fun buildAmazonSNSAsync(): AmazonSNSAsync {
        return AmazonSNSAsyncClientBuilder.standard()
            .withEndpointConfiguration(AwsClientBuilder.EndpointConfiguration(endpoint, region))
            .withCredentials(AWSStaticCredentialsProvider(BasicAWSCredentials(accessKey, secretKey)))
            .build()
    }

    private fun buildAmazonSQSAsync(): AmazonSQSAsync {
        return AmazonSQSAsyncClientBuilder.standard()
            .withEndpointConfiguration(AwsClientBuilder.EndpointConfiguration(endpoint, region))
            .withCredentials(AWSStaticCredentialsProvider(BasicAWSCredentials(accessKey, secretKey)))
            .build()
    }
}

额外验证点 #

如果修改后仍不生效，可检查以下项：

• 确认Blob类的@JsonFormat注解导入的是com.fasterxml.jackson.annotation.JsonFormat包，不是其他JSON库的注解
• 若全局需要统一日期格式，可直接给ObjectMapper配置默认序列化规则，无需每个字段加注解
• Spring Cloud AWS 2.x以上版本若出现类型匹配报错，可给MappingJackson2MessageConverter添加配置messageConverter.isStrictContentTypeMatch = false

内容的提问来源于stack exchange，提问作者Márcio Dalfré