RabbitMQ中各类消息类型如何处理

一：消息类型

• 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注解标识。

四：发送消息

    发送消息可参看本博客中这篇文章：

RabbitMQ实战（一）Spring Boot 整合 RabbitMQ