欢迎来到“雪碧聊技术”CSDN博客!
在这里,您将踏入一个专注于Java开发技术的知识殿堂。无论您是Java编程的初学者,还是具有一定经验的开发者,相信我的博客都能为您提供宝贵的学习资源和实用技巧。作为您的技术向导,我将不断探索Java的深邃世界,分享最新的技术动态、实战经验以及项目心得。
让我们一同在Java的广阔天地中遨游,携手提升技术能力,共创美好未来!感谢您的关注与支持,期待在“雪碧聊技术”与您共同成长!
目录
一、消息转换器
1、通过一个案例,引出消息转换器
①案例介绍
②具体操作
第一步:在rabbitMQ控制台,新建一个队列object.queue
第二步:直接写代码,往object.queue队列中发送一条消息,消息类型为Map
第三步:在控制台查看该消息,总结问题
2、上述案例存在的问题
上述采用的是默认的序列化方式,即:JDK序列化(序列化就是将对象变成字符串)。
①我们传入队列的Map对象,被序列化成了一串字符串,可读性太差;
②而且本来内容不多,序列化后,字符串内容太长了,即:消息变大了;
③这个JDK序列化生成的字符串,容易被修改,有安全风险。
3、如何解决上述问题?
使用JSON序列化的方式,将Map对象序列化成一个JSON字符串。这样可读性就强了。
具体方法就是①引入jackson-databind依赖 ②编写对应的配置类。
然后就完事了。
4、步骤
①引入jackson依赖
<!--引入jackson依赖-->
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.17.0</version>
</dependency>
②配置MessageConverter(转换器)
@Configuration //表明这是个配置类
public class MessageConverterConfig {
@Bean
public MessageConverter jacksonMessageConverter(){
return new Jackson2JsonMessageConverter();
}
}
注意:要找对包,别瞎找:
③再次发送消息到队列(代码不变)
④ 去rabbitMQ控制台,查看结果
⑤接收时,发的啥类型,就用啥类型接收
@Component //交给spring管理
public class MqListener {
@RabbitListener(queues = "object.queue")
public void listenObjectQueue(Map<String, Object> msg){
System.out.println("消费者收到了object.queue队列的消息:"+msg);
}
}
⑥查看监听到的结果
消费者收到了object.queue队列的消息:{name=jack, age=21}
可见此时监听到的也是JSON格式的字符串(对应一个Map对象)。
以上就是消息转换器的全部内容,想了解更多RabbitMQ知识,请关注本博主~~