从队列消费不同类型对象：类型判断失效问题排查与解决

你的代码中instanceof判断全部不成立，大概率是因为接收端没有正确使用配置的消息转换器，导致消息没有被反序列化为目标实体类，而是变成了LinkedHashMap或者原始的Message对象。以下是具体的排查和解决步骤：

1. 确保@JmsListener使用自定义的容器工厂 #

你的配置类中定义了jmsListenerContainerFactory并绑定了自定义的MessageConverter，但默认情况下@JmsListener不会自动使用这个工厂，需要显式指定：

@JmsListener(destination = "destination", containerFactory = "jmsListenerContainerFactory") 
public void receiveMessageForEmailService(Object object) {
    if (object instanceof BusinessUser) {
        // do something
    }
    if (object instanceof NormalUser) {
        // do something
    }
}

或者在容器工厂Bean上添加@Primary，让它成为默认工厂：

@Bean
@Primary
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory() {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(cachingConnectionFactory()); // 建议使用缓存连接工厂而非原始工厂
    factory.setMessageConverter(messageConverter());
    return factory;
}

2. 简化代码：使用重载的接收方法 #

Spring JMS支持根据消息类型自动路由到对应参数类型的接收方法，无需手动判断instanceof，代码更简洁：

@JmsListener(destination = "destination", containerFactory = "jmsListenerContainerFactory")
public void handleBusinessUser(BusinessUser businessUser) {
    // 处理企业用户逻辑
}

@JmsListener(destination = "destination", containerFactory = "jmsListenerContainerFactory")
public void handleNormalUser(NormalUser normalUser) {
    // 处理普通用户逻辑
}

3. 排查消息转换的匹配问题 #

如果上述步骤仍未解决，先确认接收对象的实际类型，排查转换失败原因：

@JmsListener(destination = "destination", containerFactory = "jmsListenerContainerFactory") 
public void receiveMessageForEmailService(Object object) {
    System.out.println("实际接收类型：" + object.getClass().getName());
    System.out.println("消息内容：" + object.toString());
}

• 如果输出是LinkedHashMap，说明消息中的_type属性值和你配置的typeIdMappings不匹配。比如发送时_type是类的全限定名（如com.xxx.BusinessUser），但你映射的是businessUser，此时需要调整typeIdMappings为全限定名，或者确保发送端的_type使用短名称。
• 如果输出是ActiveMQTextMessage之类的原始消息类型，说明接收端完全没有使用消息转换器，需要检查容器工厂的messageConverter是否正确绑定。

4. 优化连接工厂使用 #

建议发送端和接收端都使用cachingConnectionFactory而非原始的ActiveMQConnectionFactory，提升性能：

@Bean
public JmsTemplate jmsTemplate(){
    JmsTemplate jmsTemplate = new JmsTemplate(cachingConnectionFactory()); // 替换为缓存连接工厂
    jmsTemplate.setMessageConverter(messageConverter());
    return jmsTemplate;
}

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