Spring JMS中MappingJackson2MessageConverter反序列化异常无法捕获问题

云原生阿岚

2026-5-9

我来帮你拆解下这个问题，你遇到的情况其实是Spring JMS配置里的两个常见陷阱叠加导致的：

问题根源

首先看日志里的提示：Execution of JMS message listener failed, and no ErrorHandler has been set.——这说明你的自定义JmsErrorHandler根本没被容器正确加载。原因很简单：你在配置容器工厂时，先设置了ErrorHandler，再调用configurer.configure()，而configure()方法会覆盖容器的默认配置（包括重置ErrorHandler为null），导致你的自定义处理器被覆盖了。

其次，反序列化异常确实发生在@JmsListener方法执行之前的参数解析阶段，但只要ErrorHandler正确生效，就能捕获到包装了JsonMappingException的ListenerExecutionFailedException。

解决方案

1. 修复容器工厂的配置顺序

这是最关键的一步，把configurer.configure()放在setErrorHandler()之前，确保你的自定义配置不会被默认配置覆盖：

@Bean
public JmsListenerContainerFactory<?> jmsListenerQueueFactory(ConnectionFactory connectionFactory, 
                                                              DefaultJmsListenerContainerFactoryConfigurer configurer, 
                                                              JmsErrorHandler jmsErrorHandler) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    // 先应用Spring的默认配置
    configurer.configure(factory, connectionFactory);
    // 再设置自定义ErrorHandler，覆盖默认值
    factory.setErrorHandler(jmsErrorHandler);
    return factory;
}

修改后，再发送无效消息，你应该能看到控制台打印WE HAVE THE ERROR!，说明ErrorHandler已经生效了。此时你可以在handleError()方法里通过t.getCause().getCause()层层获取到底层的JsonMappingException，执行自定义的响应逻辑（比如把无效消息转发到死信队列、发送告警通知等）。

2. （可选）精细化控制反序列化异常

如果你想在反序列化阶段就直接处理异常（比如记录更详细的消息元数据），可以自定义MappingJackson2MessageConverter的子类，重写fromMessage()方法捕获异常：

@Component
public class CustomJacksonJmsConverter extends MappingJackson2MessageConverter {

    private static final Logger logger = LoggerFactory.getLogger(CustomJacksonJmsConverter.class);

    @Override
    public Object fromMessage(Message message) throws JMSException, MessageConversionException {
        try {
            return super.fromMessage(message);
        } catch (MessageConversionException e) {
            // 记录消息ID、目的地等元数据，方便排查问题
            logger.error("Failed to deserialize JMS message [ID: {}, Destination: {}]", 
                        message.getJMSMessageID(), message.getJMSDestination(), e);
            // 重新抛出异常，确保ErrorHandler能捕获到
            throw new MessageConversionException("Deserialization failed for message: " + message.getJMSMessageID(), e);
        }
    }
}

然后替换原来的转换器Bean：

@Bean
public MessageConverter jacksonJmsMessageConverter() {
    CustomJacksonJmsConverter converter = new CustomJacksonJmsConverter();
    converter.setTargetType(MessageType.TEXT);
    converter.setTypeIdPropertyName("_type");
    return converter;
}

3. （可选）为单个监听器指定ErrorHandler

如果某个监听器需要特殊的错误处理逻辑，你可以直接在@JmsListener注解上指定错误处理器，优先级高于全局配置：

@JmsListener(id = MY_ID, destination = MY_DEST, errorHandler = jmsErrorHandler)
public void processMessage(MyPojoMessage myPojoMessage) {
    // 业务逻辑
}

注意：这里的jmsErrorHandler必须是Spring容器中的Bean，若有多个同类型Bean，记得用@Qualifier指定具体实例。

验证效果

调整配置后，再次发送无效JSON消息，你会发现：

JmsErrorHandler.handleError()被触发，控制台打印你设置的日志
你可以通过Throwable的链式调用获取到最底层的JsonMappingException，进行针对性处理

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