Py学习  »  MQ

无法读取对象内容spring boot activemq

Suresh • 6 年前 • 1818 次点击  

我尝试使用Spring引导和活动的MQ在消费者端使用POJO。收到消息,但无法转换为对象的实际类型,但出现以下异常:

例外:

2018-08-01 10:51:35.542  INFO 9280 --- [enerContainer-1] com.example.JmsConsumer                  : Message reached in consumer side...
2018-08-01 10:51:35.542  INFO 9280 --- [enerContainer-1] com.example.JmsConsumer                  : +++++++++++++++++++++++++++++++++++++++++++++++++++++
2018-08-01 10:51:35.547  WARN 9280 --- [enerContainer-1] o.s.j.l.DefaultMessageListenerContainer  : Execution of JMS message listener failed, and no ErrorHandler has been set.

java.lang.AbstractMethodError: org.apache.activemq.command.ActiveMQObjectMessage.getBody(Ljava/lang/Class;)Ljava/lang/Object;
    at com.example.JmsConsumer.receive(JmsConsumer.java:49) ~[classes/:na]
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:na]
    at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:na]
    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:na]

POJO:

public class OrderDetails implements Serializable{
    private Long id;
    private String name;
    private double itemPrice;
    private double totalPrice;
    private String orderStatus;

}

出版方:

import javax.jms.JMSException;
import javax.jms.ObjectMessage;
import javax.jms.Session;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Component;

import com.example.model.OrderDetails;
    @Component
    public class JmsProducer  {

        @Autowired
        JmsTemplate jmsTemplate;

        @Value("${jsa.activemq.queue}")
        String queueName;

        public void send(OrderDetails msg) {
            this.jmsTemplate.convertAndSend(queueName, msg);
    }

消费者方面:

import javax.jms.JMSException;
import javax.jms.Message;
import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.jms.annotation.JmsListener;
    import org.springframework.stereotype.Component;
    import org.springframework.web.client.RestTemplate;

    import com.example.model.OrderDetails;
    import com.fasterxml.jackson.databind.ObjectMapper;

    import lombok.extern.slf4j.Slf4j;

        @Component
        @Slf4j
        public class JmsConsumer {

  @JmsListener(destination = "${jsa.activemq.queue}", containerFactory="jsaFactory")
       public void receive(Message message) throws JMSException{
                log.info("Message reached in consumer side...");
                    log.info("+++++++++++++++++++++++++++++++++++++++++++++++++++++");
          OrderDetails response = Message.getBody(OrderDetails.class);
       log.info("Application : object received : {}",response);
            }
      }

活动MQ配置:

import javax.jms.ConnectionFactory;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
import org.springframework.jms.config.JmsListenerContainerFactory;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.support.converter.MappingJackson2MessageConverter;
import org.springframework.jms.support.converter.MessageConverter;
import org.springframework.jms.support.converter.MessageType;

@Value("${jsa.activemq.broker.url}")
    String brokerUrl;

    @Value("${jsa.activemq.borker.username}")
    String userName;

    @Value("${jsa.activemq.borker.password}")
    String password;

    /*
     * Initial ConnectionFactory
     */
    @Bean
    public ConnectionFactory connectionFactory(){
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        connectionFactory.setBrokerURL(brokerUrl);
        connectionFactory.setUserName(userName);
        connectionFactory.setPassword(password);
        connectionFactory.setTrustAllPackages(true);
        return connectionFactory;
    }

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

    /*
     * Used for Receiving Message
     */
    @Bean
    public JmsListenerContainerFactory<?> jsaFactory(ConnectionFactory connectionFactory,
                                                    DefaultJmsListenerContainerFactoryConfigurer configurer) {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setMessageConverter(jacksonJmsMessageConverter());
        configurer.configure(factory, connectionFactory);
        return factory;
    }

        /*
     * Used for Sending Messages.
     */
    @Bean
    public JmsTemplate jmsTemplate(){
        JmsTemplate template = new JmsTemplate();
        template.setConnectionFactory(connectionFactory());
        return template;
    }

在发布服务器和侦听器端,活动的MQ配置是相同的。我已经注册了消息转换器,但我不知道为什么从JSON到对象的转换不起作用。任何解决这个问题的建议都会受到赞赏。

Python社区是高质量的Python/Django开发社区
本文地址:http://www.python88.com/topic/33571
 
1818 次点击  
文章 [ 2 ]  |  最新文章 6 年前
Suresh
Reply   •   1 楼
Suresh    6 年前

我通过直接使用pojo而不是将其作为javax.jms.message使用来解决这个错误。另外,消息转换器bean也应按以下方式初始化:

//使用textmessage将消息内容序列化到json

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

请查看我在Github中的代码:

https://github.com/sureshpec04/spring-boot-jms

manish
Reply   •   2 楼
manish    6 年前

我觉得你的jar有点问题,我想可能是你正在使用的旧版本的jar,请检查你的jar版本和你正在使用的jdk