rabbit mq消息侦听器

Question

我正在使用

@Autowired
RabbitTemplate temp;
temp.convertAndSend("aQueue", msg);

发送和

@Autowired
RabbitTemplate temp;
return temp.receiveAndConvert("aQueue");

对于现在从rappid mq接收消息，我希望使用类似以下内容的侦听器：

@Component

public class MessengerListener implements MessageListener{

    @Override
    public void onMessage(Message arg0) {


    }

}

问题是onMessage监听器与Messages一起工作是否有可能在类似的函数中接收简单的可序列化对象？

Answer 1

我强烈建议您不要这样做，您应该将XML、JSON（我推荐JSON）等传递给onMessage（…）并解组响应，而不是通过JMS序列化对象。

使用下面类似的方法来解组/编组有效负载

<dependency>
    <groupId>com.google.code.gson</groupId>
    <artifactId>gson</artifactId>
    <version>2.8.2</version>
</dependency