RabbitMQ获取消息源码解析_rabbit messagelistener message 解析

一、问题场景描述
利用springboot+rabbitmq结合，在消费端消费时，发现直接接受String类型的消息，发现消息是字节数组

 @RabbitListener(queues = "testQueue")
    public void get(String message ){
        System.out.println(message);
        System.out.println("消费者1");
    }
1
2
3
4
5

发送消息“123”，执行结果：

34,49,50,51,34
消费者1

二、源码跟踪
利用idea的debug代码栈，

发现message为一个字节数组内容，那就依此倒序查找在哪里，这个字符串变成字节数组了。
如中间这步，还是字节数组

走到这一步，发现有消息内容对象

查看关键代码

org.springframework.messaging.Message<?> message = this.toMessagingMessage(amqpMessage);
1

一直进去到消息转化器接口实现：SimpleMessageConverter

发现消费消息时，消息转化器转化规则，跟消息内容类型是否是"text"或者是“application/x-java-serialized-object”有关。
如果类型为“text”开头，就表示是文本内容，直接获取消息内容，按照“utf-8”,转成字符串
如果是“application/x-java-serialized-object”，就需要获取内容输入流转成对象流，再解序列化。
如果没有指定，就直接返回生产者生产的消息内容（字节数组）
三、RabbitMQ消息转化器设置
在RabbitTemplate定义时设置

        //消息转化器
//        rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());
        rabbitTemplate.setMessageConverter(new MessageConverter() {
            @Override
            public Message toMessage(Object o, MessageProperties messageProperties) throws MessageConversionException {
               //按照上面源码流程，可以设置内容类型格式，保证springboot解析数据时，正常解析
				//messageProperties.setContentType("text/xml");
				//messageProperties.setContentEncoding("utf-8");
                //当然也可以在发送时，利用序列化工具进行序列化
                Message message = new Message(JSON.toJSONBytes(o),messageProperties);
                System.out.println("调用了消息解析器");
                return message;
            }

            @Override
            public Object fromMessage(Message message) throws MessageConversionException {
                //相应的在接受消费时，再利用序列化工具解序列化
                return null;
            }
        });
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

项目地址：github