文章目录

• • 项目依赖
  • 配置消息转换器
  • 发送消息
  • 接收消息
  • 总结

项目依赖

首先，我们需要在项目中引入 Jackson 的 XML 格式支持。添加以下 Maven 依赖到 pom.xml 文件中：

     com.fasterxml.jackson.dataformat     jackson-dataformat-xml     2.9.10  

配置消息转换器

接下来，我们需要配置 RabbitMQ 的消息转换器，使其能够将 Java 对象转换为 JSON 格式的消息。我们可以通过定义一个 MessageConverter Bean 来实现：

@Bean public MessageConverter messageConverter() {     return new Jackson2JsonMessageConverter(); } 

Jackson2JsonMessageConverter 是 Spring AMQP 提供的一个消息转换器，它使用 Jackson 将 Java 对象转换为 JSON 字符串。

发送消息

下面是一个发送对象消息的测试方法。在这个方法中，我们创建了一个包含姓名和年龄的 Map 对象，并将其发送到 RabbitMQ 的 object.queue 队列中：

@Test public void testSendObject() {     // 1.准备消息     Map msg = new HashMap<>(2);     msg.put("name", "zhangsan");     msg.put("age", 18);     rabbitTemplate.convertAndSend("object.queue", msg); } 

接收消息

为了接收从 object.queue 队列中发送的消息，我们需要定义一个消息监听器。通过 @RabbitListener 注解，我们可以指定监听的队列，并在收到消息时执行相应的处理逻辑：

@RabbitListener(queues = "object.queue") public void listenTopicQueue2(Map msg) {     log.info("消费者2监听到object.queue消息：{}", msg); } 

在这个方法中，当监听器接收到消息时，会将消息内容输出到日志中。

总结

通过以上配置和代码示例，我们展示了如何使用 RabbitMQ 和 Jackson 实现消息队列中的对象传输。首先引入 Jackson 依赖，然后配置消息转换器，将 Java 对象转换为 JSON 字符串发送到队列，最后通过监听器接收并处理消息。这种方式可以有效地实现不同服务之间的数据传输和解耦，有助于构建高效、可扩展的分布式系统。