RabbitMQ技术问题：如何通过DefaultConsumer从消费者标签提取消息体？

我正在搭建一个简单的RabbitMQ消息传递应用，其中生产者模块用Java实现，消费者模块用Scala编写。目前Java生产者已经能够成功将消息投递到RabbitMQ服务器的queue1队列，核心代码如下：

// 初始化RabbitMQ核心参数
String queue = "queue1"; 
String exchange = "queue1"; 
String routing_key = "queue1"; 

// 创建RabbitMQ连接与信道
Connection connection = factory.newConnection(); 
Channel channel = connection.createChannel(); 

// 声明持久化队列（重启RabbitMQ后队列不会丢失）
channel.queueDeclare(queue, true, false, false, null); 
// 声明Direct类型交换机（原代码截断，补充常规实现逻辑）
channel.exchangeDeclare(exchange, BuiltinExchangeType.DIRECT);
// 绑定队列与交换机，指定路由键
channel.queueBind(queue, exchange, routing_key);

// 示例：发布消息到队列
String message = "Hello from Java Producer!";
channel.basicPublish(exchange, routing_key, null, message.getBytes(StandardCharsets.UTF_8));

核心实现细节 #

• 采用持久化队列：queueDeclare方法的第二个参数设为true，保障队列在RabbitMQ服务重启后不会丢失，适合需要可靠消息存储的场景。
• 交换机、队列、路由键同名：基于Direct交换机实现一对一的消息路由，简化了简单场景下的消息投递逻辑。
• 后续可基于此开发Scala消费者：使用RabbitMQ的Scala客户端（或基于Java客户端的封装）监听queue1队列，实现消息的接收与业务处理。

内容的提问来源于stack exchange，提问作者manuel mourato