目录
一、问题背景
二、从消息转化器根源解决问题
1.引入依赖
2.在服务生产者和消费者中都重新定义一个 MessageConverter,注入到 Spring 容器中
一、问题背景
在SpringAMQP的发送方法中,接收消息的类型是Object,也就是说我们可以发送任意对象类型的消息,接下来做个小实验
如下,注入一个队列到容器中,接着在提供一个服务生产者供测试,发送一个对象数据,观察 RabbitMQ 客户端队列数据形式
@Configuration
public class FanoutConfig {
@Bean
public Queue objectQueue() {
return new Queue("object.queue");
}
}
@Test
public void testObjectMessage() {
HashMap<String, 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 来序列化和反序列化,因此直接在的父类中引入依赖即可
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
</dependency>
2.在服务生产者和消费者中都重新定义一个 MessageConverter,注入到 Spring 容器中
使用 @Bean 注解注入即可
@SpringBootApplication
public class ConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(ConsumerApplication.class, args);
}
@Bean
public MessageConverter jsonMessageConverter() {
return new Jackson2JsonMessageConverter();
}
}
@SpringBootApplication
public class PublisherApplication {
public static void main(String[] args) {
SpringApplication.run(PublisherApplication.class);
}
@Bean
public MessageConverter jsonMessageConverter() {
return new Jackson2JsonMessageConverter();
}
}
再尝试发送数据,结果如下:
Ps:注意发送方与接收方必须使用相同的MessageConverter文章来源:https://www.toymoban.com/news/detail-565401.html
文章来源地址https://www.toymoban.com/news/detail-565401.html
到了这里,关于SpringAMQP - 消息传输时,如何提高性能?解决 SQL 注入问题?的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!