一:消息类型
- Map
- String(含json字符串类型)
二:处理方法
2.1 Map消息
如果发送的消息类型是map类型,可以通过SerializationUtils.deserialize方法将消息转换成map类型。
2.2 字符串类型(含json格式)
通过String类的构造函数接收byte[]类型的消息数据,获得jsonStr后可以转换成其它类,然后再进行相关操作。
这里@RabbitListener注解在方法上,如果类中有多个@RabbitListener(queues = TopicRabbitmqConfig.EVENT_MSG_QUEUE_NAME)注解的方法,测试的结果是轮流的调用。
三:另一种接收方式
注意,这里RabbitListener注解在类上,方法中通过@RabbitHandler注解标识。
四:发送消息
发送消息可参看本博客中这篇文章: