Spring JmsMessagingTemplate自定义MessageConverter失效问题咨询

你完全可以在JmsMessagingTemplate中使用org.springframework.jms.support.converter.MessageConverter的实现类，问题出在你的配置方式上——你混淆了两个不同的MessageConverter接口，并且错误地将JMS转换器设置到了MessagingMessageConverter的payloadConverter属性上（这个属性需要的是另一种转换器）。

核心问题分析 #

Spring中有两个极易混淆的MessageConverter接口，职责完全不同：

• org.springframework.jms.support.converter.MessageConverter：负责JMS消息与Java对象之间的转换，是传统JmsTemplate体系的核心转换器。
• org.springframework.messaging.converter.MessageConverter：负责Spring Messaging的Message（带Headers）与Java对象之间的转换，是MessagingTemplate体系的转换器。

而MessagingMessageConverter是一个适配类，同时实现了上述两个接口，起到桥接JMS和Spring Messaging的作用。它的setPayloadConverter()方法接受的是Spring Messaging的MessageConverter，而非你写的JMS转换器——这就是你的自定义逻辑没生效的根本原因，你把错误类型的转换器赋值给了这个属性。

正确配置方案 #

你需要直接将自定义的JMS转换器设置给JmsMessagingTemplate的jmsMessageConverter属性，无需手动包装MessagingMessageConverter，JmsMessagingTemplate会自动完成适配工作。

调整后的核心配置代码 #

@Configuration 
@EnableJms 
public class MessagingEncryptionPocConfig { 
    // ... 其他Bean（连接工厂、监听器工厂、JAXB Marshaller等）保持不变 ...

    /**
     * 自定义JMS消息转换器（实现org.springframework.jms.support.converter.MessageConverter）
     */
    @Bean
    public org.springframework.jms.support.converter.MessageConverter customJmsConverter(Jaxb2Marshaller jaxb2Marshaller) {
        return new EncryptionDecryptionMessagingConverter(jaxb2Marshaller);
    }

    /**
     * Jms Queue Template
     */
    @Bean(name="queueTemplate") 
    public JmsMessagingTemplate queueTemplate(CachingConnectionFactory cachingConnectionFactory, 
                                              org.springframework.jms.support.converter.MessageConverter customJmsConverter) { 
        JmsMessagingTemplate queueTemplate = new JmsMessagingTemplate(cachingConnectionFactory); 
        queueTemplate.setJmsMessageConverter(customJmsConverter); 
        return queueTemplate; 
    }
}

为什么这样能生效？ #

当JmsMessagingTemplate第一次调用convertAndSend()时，内部的getConverter()方法会自动处理：

1. 检测到jmsMessageConverter是普通JMS转换器（而非MessagingMessageConverter），会自动创建一个MessagingMessageConverter实例。
2. 将你的自定义JMS转换器设置为这个适配类的底层JMS转换器，后续所有消息转换都会走你的自定义逻辑。

额外注意事项 #

• 确保你的EncryptionDecryptionMessagingConverter正确实现了org.springframework.jms.support.converter.MessageConverter的toMessage()和fromMessage()方法，这两个方法是消息转换的核心入口。
• 如果需要同时处理Spring Messaging的Headers逻辑，可以直接自定义MessagingMessageConverter，但此时需要你实现Spring Messaging的MessageConverter接口来处理payload，同时配置底层JMS转换器。

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