福安网站开发,网络工程主要学什么就业方向,怎么彻底关闭微信小程序,seo技术培训茂名目录 一、问题背景
二、从消息转化器根源解决问题
1.引入依赖
2.在服务生产者和消费者中都重新定义一个 MessageConverter#xff0c;注入到 Spring 容器中 一、问题背景 在SpringAMQP的发送方法中#xff0c;接收消息的类型是Object#xff0c;也就是说我们可以发送任意…目录 一、问题背景
二、从消息转化器根源解决问题
1.引入依赖
2.在服务生产者和消费者中都重新定义一个 MessageConverter注入到 Spring 容器中 一、问题背景 在SpringAMQP的发送方法中接收消息的类型是Object也就是说我们可以发送任意对象类型的消息接下来做个小实验
如下注入一个队列到容器中接着在提供一个服务生产者供测试发送一个对象数据观察 RabbitMQ 客户端队列数据形式
Configuration
public class FanoutConfig {Beanpublic Queue objectQueue() {return new Queue(object.queue);}}Testpublic void testObjectMessage() {HashMapString, Object map new HashMap();map.put(国家, china);rabbitTemplate.convertAndSend(object.queue, map);}运行后查看 RabbitMQ 队列数据如下 为什么发送的消息变成了这个样子呢 这是因为SpringAMQP会帮我们序列化为字节后发送Spring的对消息对象的处理是由org.springframework.amqp.support.converter.MessageConverter 来处理的。而默认实现是SimpleMessageConverter基于JDK的ObjectOutputStream完成序列化。 但是这样的数据就有可能引发以下两种问题
转化后数据过长影响传输效率。容易引发 sql 注入问题。 二、从消息转化器根源解决问题 我们只需要在服务生产者和消费者的 Spring 启动类中都重新定义一个 MessageConverter 类型的Bean即可。这里推荐用JSON方式序列化~
具体步骤如下
1.引入依赖
因为服务生产者和服务消费者都需要 JSON 来序列化和反序列化因此直接在的父类中引入依赖即可 dependencygroupIdcom.fasterxml.jackson.core/groupIdartifactIdjackson-databind/artifactId/dependency2.在服务生产者和消费者中都重新定义一个 MessageConverter注入到 Spring 容器中
使用 Bean 注解注入即可
SpringBootApplication
public class ConsumerApplication {public static void main(String[] args) {SpringApplication.run(ConsumerApplication.class, args);}Beanpublic MessageConverter jsonMessageConverter() {return new Jackson2JsonMessageConverter();}}SpringBootApplication
public class PublisherApplication {public static void main(String[] args) {SpringApplication.run(PublisherApplication.class);}Beanpublic MessageConverter jsonMessageConverter() {return new Jackson2JsonMessageConverter();}}再尝试发送数据结果如下 Ps注意发送方与接收方必须使用相同的MessageConverter
