导致:org.springframework.jms.support.converter.MessageConversionException:无法在消息上找到类型 id 属性 [_type]

2024-01-15

我正在尝试这个 Spring JMS 示例,但它给出了错误。https://spring.io/guides/gs/messaging-jms/ https://spring.io/guides/gs/messaging-jms/造成原因:org.springframework.jms.support.converter.MessageConversionException: Could not find type id property [_type] on message from destination [queue://mailbox]有趣的是,如果我克隆它并运行一切都运行良好。如果我复制并粘贴,则会出现错误。

 @Bean // Serialize message content to json using TextMessage
public MessageConverter jacksonJmsMessageConverter() {
    MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
    converter.setTargetType(MessageType.TEXT);
    converter.setTypeIdPropertyName("_type");
    return converter;
}

这段代码实际上导致了错误。搜索网络和文档,我仍然不知道如何以及设置 setTypeIdPropertyName 值以及“_type”在该项目中指的是什么?既然消息不具有这样的属性,那么它是从哪里来的呢?


TypeIdPropertyName是标识实体的属性名称。 Jackson 映射器应该知道反序列化传入 JSON 时要使用哪个实体。

该请求应如下所示:

{  
   "_type" : "hello.Email",
   "to" : "Imran",
   "from" : "dzatorsky"
}

顺便说一句,我认为这不是最好的解决方案,因为 JMS 已经知道要使用什么类型(您在方法中声明它)。另一个缺点是您在消息中指定实体和包的名称,这将很难维护(包或实体名称的每次更改都会很痛苦)。

这是更强大的配置:

@EnableJms
@Configuration
public class JmsListenerConfig implements JmsListenerConfigurer {

    @Bean
    public DefaultMessageHandlerMethodFactory handlerMethodFactory() {
        DefaultMessageHandlerMethodFactory factory = new DefaultMessageHandlerMethodFactory();
        factory.setMessageConverter(messageConverter());
        return factory;
    }

    @Bean
    public MessageConverter messageConverter() {
        return new MappingJackson2MessageConverter();
    }

    @Override
    public void configureJmsListeners(JmsListenerEndpointRegistrar registrar) {
        registrar.setMessageHandlerMethodFactory(handlerMethodFactory());
    }
}

另外,如果您使用 Spring JmsTemplate 发送消息,您可以将此组件添加到您的配置中:

/**
 * Used to convert JMS messages from/to JSON. Registered in Spring-JMS automatically via auto configuration
 */
@Component
public class JsonMessageConverter implements MessageConverter {

    @Autowired
    private ObjectMapper mapper;

    /**
     * Converts message to JSON. Used mostly by {@link org.springframework.jms.core.JmsTemplate}
     */
    @Override
    public javax.jms.Message toMessage(Object object, Session session) throws JMSException, MessageConversionException {
        String json;

        try {
            json = mapper.writeValueAsString(object);
        } catch (Exception e) {
            throw new MessageConversionException("Message cannot be parsed. ", e);
        }

        TextMessage message = session.createTextMessage();
        message.setText(json);

        return message;
    }

    /**
     * Extracts JSON payload for further processing by JacksonMapper.
     */
    @Override
    public Object fromMessage(javax.jms.Message message) throws JMSException, MessageConversionException {
        return ((TextMessage) message).getText();
    }
}

通过此配置,您可以跳过消息中烦人的“_type”字段。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

导致:org.springframework.jms.support.converter.MessageConversionException:无法在消息上找到类型 id 属性 [_type] 的相关文章

随机推荐