使用 Spring Boot JMS 发送对象

Question

我做了 2 个类：1 个发送和 1 个接收。目前我可以只发送一个基本的字符串，而且效果很好

发件人

@Component
public class Sender {

    @Autowired
    private JmsTemplate jmsTemplate;

    //Script must be serializable
    public void testSend(/*Script*/String message)
    {
        jmsTemplate.convertAndSend("my-destination", message);      
    }
}

接收者

@Component
public class Receiver {

    @Autowired
    private ConfigurableApplicationContext context;

    @JmsListener(destination = "my-destination")
    public void receive(String message) {
        System.out.println(message);

        try {
            Thread.sleep(4000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        context.close();
    }
}

我无法在这里实现正确的代码，如果有人能告诉我如何做，我将不胜感激

我会做几乎相同的事情，但要发送复杂的 java 对象（可序列化）。并且接收者类应该能够识别对象的类。

Answer 1

你可以直接创建一个 ByteMessage 并序列化你的对象（对象必须是可序列化的）：

    this.jmsTemplate.send("my-destination", new MessageCreator() {
        public Message createMessage(Session session) throws JMSException {
            final ByteArrayOutputStream bOut = new ByteArrayOutputStream();
            final ObjectOutputStream oOut = new ObjectOutputStream(bOut);
            oOut.writeObject(_object); // where object is the object to serialize
            bytes[] data = bOut.toByteArray();
            return session.createByteMessage(data);
        }
    });

和

    @JmsListener(destination = "my-destination")
    public void receive(Message message) {
        final BytesMessage message = (BytesMessage) _message;
        final byte[] array = new byte[Long.valueOf(message.getBodyLength()).intValue()];
        message.readBytes(array);
        final ByteArrayInputStream bIn = new ByteArrayInputStream(_bytes);
        final ObjectInputStream oIn = new ObjectInputStream(bIn);
        Object obj = oIn.readObject(); // the deserialized object
    }