如何配置RabbitMQ(AMQP)实现Map<Integer,List<ChatDTO>>序列化？

核心原因 #

默认JSON序列化器（比如Jackson2JsonMessageConverter）序列化Map时，会把Integer类型的键自动转成String（因为JSON规范里对象键必须是字符串），反序列化时不会自动转回Integer，导致消费时String强转Integer抛出ClassCastException。

解决方法 #

1. 自定义Jackson的Map键反序列化规则 #

给Jackson配置专门的键反序列化逻辑，让它把JSON里的字符串键自动转成Integer：

@Configuration
public class RabbitMQConfig {

    @Bean
    public Jackson2JsonMessageConverter jackson2JsonMessageConverter() {
        ObjectMapper objectMapper = new ObjectMapper();
        // 注册自定义键反序列化器，处理Integer类型的Map键
        objectMapper.registerModule(new SimpleModule()
                .addKeyDeserializer(Integer.class, new KeyDeserializer() {
                    @Override
                    public Object deserializeKey(String key, DeserializationContext ctxt) throws IOException {
                        return Integer.parseInt(key);
                    }
                }));
        return new Jackson2JsonMessageConverter(objectMapper);
    }

    @Bean
    public AmqpTemplate amqpTemplate(ConnectionFactory connectionFactory) {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setMessageConverter(jackson2JsonMessageConverter());
        return rabbitTemplate;
    }
}

2. 把Map封装成自定义实体类（更稳妥） #

别直接用Map<Integer, List<ChatDTO>>当消息体，封装成一个自定义类，让Jackson能明确识别类型：

public class ChatMessage {
    private Map<Integer, List<ChatDTO>> chatMap;

    // 构造器、getter、setter方法
}

发送时传ChatMessage对象，消费时直接接收ChatMessage类型，再从中取出Map，彻底避免键类型转换问题。

3. 对齐消费者的接收类型 #

消费时别用Map<Integer, List<Object>>接收，直接用Map<Integer, List<ChatDTO>>，和发送的类型完全匹配，减少类型转换风险：

@RabbitListener(queues = "chat-queue")
public void handleChatMessage(Map<Integer, List<ChatDTO>> message) {
    // 业务逻辑处理
}

验证要点 #

• 确认AmqpTemplate用的是自定义的Jackson2JsonMessageConverter，不是默认序列化器
• 查看队列里的JSON消息内容，即使键是字符串，自定义反序列化器也能转成Integer

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