AWS Spring 无法设置对象映射器答案

【问题标题】：AWS Spring can't set object mapperAWS Spring 无法设置对象映射器
【发布时间】：2022-01-04 20:26:45
【问题描述】：

我试图在 spring MessageTemplate 设置 jackson 序列化程序以发送已经使用 jacksonMapper 和 SQS/SNS 格式化的消息，问题是它一直发送未格式化的消息，即使使用符号 @JsonProperty 或 @JsonFormat

这是我的配置：

@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
) {

   @Bean
   fun notificationMessageTemplate(): NotificationMessagingTemplate {
       return NotificationMessagingTemplate(buildAmazonSNSAsync())
   }

   @Bean
   fun queueMessagingTemplate(): QueueMessagingTemplate {
       return QueueMessagingTemplate(buildAmazonSQSAsync())
   }

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

   @Bean
   fun queueMessageHandlerFactory(objectMapper: ObjectMapper): QueueMessageHandlerFactory {
       val messageConverter = MappingJackson2MessageConverter()
       messageConverter.objectMapper = objectMapper.registerModule(JavaTimeModule())

       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()
   }
}

但是当我使用 LocalDateTime 发送对象时，即使使用 @JsonFormat 它也会不断发送错误的格式：

data class Blob(

    @JsonFormat(pattern = "yyyy-MM-dd'T'HH:mm:ss'Z'")
    val timestamp: LocalDateTime

)

我做了这个简单的调度函数来通过 SNS(topic) 发送消息并连接一个队列来接收响应。


class Dispatcher(
    private val private val notificationTemplate: NotificationMessagingTemplate
)

fun dispatch(blob: Blob) {
    val header = mapOf("randon" to "message")
    notificationTemplate.convertAndSend("topic", blob, header)
}

想要的结果：

\"timestamp\"=\"2021-11-26T19:18:46.905505\"

当前结果：

"timestamp\":{\"nano\":913070000,\"year\":2021,\"monthValue\":11,\"dayOfMonth\":26,\"hour\":19,\"minute\":18,\"second\":46,\"month\":\"NOVEMBER\",\"dayOfWeek\":\"FRIDAY\",\"dayOfYear\":330,\"chronology\":{\"calendarType\":\"iso8601\",\"id\":\"ISO\"}}

我不知道发生了什么。

附言。我也测试了SQS，结果是一样的。

【问题讨论】：

标签： spring amazon-web-services kotlin jackson

【解决方案1】：

在awspring内部搜索后，我发现SimpleMessageConverter是默认设置的，经过一番研究，我找到了在sendAndConvert()函数中设置自定义映射器的正确方法。这是配置：


    @Bean
    fun notificationMessageTemplate(objectMapper: ObjectMapper): NotificationMessagingTemplate {
        // here we set the custom message converter
        val messageConverter = MappingJackson2MessageConverter()
        messageConverter.objectMapper = objectMapper
        // as we want to send it as a Json, we need to set the serialization to String
        messageConverter.serializedPayloadClass = String::class.java

        val notificationMessageTemplate = NotificationMessagingTemplate(buildAmazonSNSAsync())
        // here is where we set the proper message converter
            notificationMessageTemplate.messageConverter = messageConverter
        return notificationMessageTemplate
    }

    @Bean
    fun queueMessagingTemplate(objectMapper: ObjectMapper): QueueMessagingTemplate {
        val messageConverter = MappingJackson2MessageConverter()
        messageConverter.objectMapper = objectMapper
        messageConverter.serializedPayloadClass = String::class.java

        val queueMessageConverter = QueueMessagingTemplate(buildAmazonSQSAsync())
        queueMessageConverter.messageConverter = messageConverter
        return queueMessageConverter
    }

设置此映射器后，每个符号都可以正常工作。

结果如下：

\"timestamp\":\"2021-11-29T17:46:52Z\"

【讨论】：