Spring Boot 3集成SQS时Java 8 Instant类型反序列化失败排查

核心原因 #

你配置的@Primary自定义ObjectMapper没有被SQS消息监听的反序列化流程正确引用，导致默认的ObjectMapper未注册JavaTimeModule，无法处理Instant类型。

具体解决方案 #

1. 确保SQS消息转换器绑定自定义ObjectMapper

修改Spring配置类，明确将自定义ObjectMapper注入到SqsMessagingMessageConverter中，同时让SqsTemplate和监听器工厂使用这个转换器：

@Configuration
public class SqsConfig {

    // 保留带@Primary的自定义ObjectMapper配置
    @Bean
    @Primary
    public ObjectMapper customObjectMapper() {
        ObjectMapper objectMapper = new ObjectMapper();
        JavaTimeModule javaTimeModule = new JavaTimeModule();
        objectMapper.registerModule(javaTimeModule);
        objectMapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
        return objectMapper;
    }

    // 配置SQS消息转换器，绑定自定义ObjectMapper
    @Bean
    public SqsMessagingMessageConverter sqsMessagingMessageConverter(ObjectMapper objectMapper) {
        SqsMessagingMessageConverter converter = new SqsMessagingMessageConverter();
        MappingJackson2MessageConverter jacksonConverter = new MappingJackson2MessageConverter();
        jacksonConverter.setObjectMapper(objectMapper);
        jacksonConverter.setSerializedPayloadClass(String.class);
        converter.setPayloadConverter(jacksonConverter);
        return converter;
    }

    // 配置SqsTemplate使用自定义转换器
    @Bean
    public SqsTemplate sqsTemplate(AmazonSQSAsync amazonSqsAsync, SqsMessagingMessageConverter converter) {
        return SqsTemplate.builder()
                .sqsAsyncClient(amazonSqsAsync)
                .messageConverter(converter)
                .build();
    }

    // 配置监听器工厂使用自定义转换器，确保@SqsListener生效
    @Bean
    public SqsMessageListenerContainerFactory<?> sqsListenerContainerFactory(
            AmazonSQSAsync amazonSqsAsync,
            SqsMessagingMessageConverter messageConverter) {
        SqsMessageListenerContainerFactory<?> factory = new SqsMessageListenerContainerFactory<>();
        factory.setAmazonSqs(amazonSqsAsync);
        factory.setMessageConverter(messageConverter);
        return factory;
    }
}

2. 优化监听器接收方式（推荐）

不要在监听器里接收String类型再手动反序列化，直接接收Event对象，让Spring自动用绑定的转换器处理：

@SqsListener("your-queue-name")
public void handleEvent(Acknowledgement ack, Event event) {
    // 直接使用event对象，无需手动反序列化
    // 业务处理逻辑...
    ack.acknowledge();
}

如果必须接收String类型，确保在监听器里注入自定义的ObjectMapper，禁止手动new ObjectMapper()：

@Component
public class EventListener {

    private final ObjectMapper objectMapper;

    // 构造注入带@Primary的自定义ObjectMapper
    public EventListener(ObjectMapper objectMapper) {
        this.objectMapper = objectMapper;
    }

    @SqsListener("your-queue-name")
    public void handleEvent(Acknowledgement ack, String eventStr) {
        try {
            Event event = objectMapper.readValue(eventStr, Event.class);
            // 业务处理逻辑...
        } catch (JsonProcessingException e) {
            // 异常处理逻辑
        }
        ack.acknowledge();
    }
}

3. 给Event类的Instant字段添加显式注解（可选但保险）

虽然注册了JavaTimeModule，显式指定序列化格式可以避免潜在的格式匹配问题：

public class Event {
    private String eventName;

    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd'T'HH:mm:ss.SSSXXX")
    private Instant dateTime;

    // Getters & Setters
}

验证要点 #

• 检查所有ObjectMapper的Bean是否只有自定义版本带有@Primary注解，避免冲突
• 确认发送消息时sqsTemplate.send()使用的是绑定了自定义转换器的实例
• 查看监听器容器日志，确认使用的是你配置的SqsMessageListenerContainerFactory

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