spring 整合 rabbitMq 生产者和消费者 xml配置 完整 生产者和消费者分开

<think>我们正在讨论Spring整合RabbitMQ时使用XML配置生产者和消费者的问题。用户要求分开配置生产者和消费者，因此我们需要提供两个独立的XML配置片段：一个用于生产者，一个用于消费者。 在Spring中，我们可以使用RabbitMQ的Spring AMQP库，并通过XML配置的方式定义相关的bean。以下分别给出生产者和消费者的配置示例。 注意：以下配置假设已经有一个运行中的RabbitMQ服务器。 首先，我们需要配置连接工厂（ConnectionFactory），这是生产者和消费者都需要的基础配置。我们可以将连接工厂的配置放在一个公共的XML文件中，然后分别导入到生产者和消费者的配置文件中。但为了完整展示，我们在每个配置中都包含连接工厂。 不过，在实际项目中，我们可能会将连接工厂单独配置，然后通过<import>引入。这里为了演示分开配置，我们会在生产者和消费者的配置中都包含连接工厂，但请注意，这样会有重复，实际使用时可提取公共部分。 我们以直接交换机（direct exchange）为例。 生产者配置（producer-config.xml）： 主要配置： 1. 连接工厂（ConnectionFactory） 2. RabbitTemplate（用于发送消息） 3. 声明交换机和队列（如果需要由生产者声明，但通常建议由消费者声明，这里为了演示生产者如何声明，我们也进行配置） 消费者配置（consumer-config.xml）： 主要配置： 1. 连接工厂（ConnectionFactory） 2. 声明交换机和队列（如果生产者没有声明，消费者必须声明） 3. 绑定（将队列绑定到交换机） 4. 消息监听容器（SimpleMessageListenerContainer）和消息监听器（MessageListener） 但是，在Spring XML配置中，声明交换机、队列和绑定通常使用<rabbit:admin>、<rabbit:queue>、<rabbit:exchange>和<rabbit:binding>元素。同时，我们还需要配置一个RabbitTemplate用于生产者发送消息，以及一个MessageListenerContainer用于消费者监听消息。 下面分别给出两个配置文件的示例： 1. 生产者配置文件（producer-config.xml）：</think>### Spring整合RabbitMQ：生产者和消费者XML分开配置示例 在Spring整合RabbitMQ的场景下，生产者和消费者的配置可以完全分离。以下是使用XML配置的完整示例： #### 🧩 生产者配置 (`producer-config.xml`) ```xml <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:rabbit="http://www.springframework.org/schema/rabbit" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit.xsd"> <!-- 1. 连接工厂配置 --> <rabbit:connection-factory id="connectionFactory" host="127.0.0.1" port="5672" username="guest" password="guest" virtual-host="/"/> <!-- 2. RabbitTemplate (消息发送核心组件) --> <rabbit:template id="rabbitTemplate" connection-factory="connectionFactory" exchange="order.exchange" message-converter="jsonMessageConverter"/> <!-- 3. JSON消息转换器 --> <bean id="jsonMessageConverter" class="org.springframework.amqp.support.converter.Jackson2JsonMessageConverter"/> <!-- 4. 声明交换机 (生产者负责确保存在) --> <rabbit:direct-exchange name="order.exchange" durable="true" auto-delete="false"> <rabbit:bindings> <!-- 绑定关系 (可选) --> <rabbit:binding queue="order.queue" key="order.key"/> </rabbit:bindings> </rabbit:direct-exchange> <!-- 5. 生产者Bean --> <bean id="orderProducer" class="com.example.OrderProducer"> <property name="rabbitTemplate" ref="rabbitTemplate"/> </bean> </beans> ``` #### 🧩 消费者配置 (`consumer-config.xml`) ```xml <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:rabbit="http://www.springframework.org/schema/rabbit" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit.xsd"> <!-- 1. 连接工厂 (与生产者相同配置) --> <rabbit:connection-factory id="connectionFactory" host="127.0.0.1" port="5672" username="guest" password="guest" virtual-host="/"/> <!-- 2. 声明队列 (消费者必须声明) --> <rabbit:queue name="order.queue" durable="true" auto-delete="false" exclusive="false"> <rabbit:queue-arguments> <!-- 死信队列配置示例 --> <entry key="x-dead-letter-exchange" value="dlx.exchange"/> <entry key="x-dead-letter-routing-key" value="dlx.key"/> </rabbit:queue-arguments> </rabbit:queue> <!-- 3. 绑定队列到交换机 --> <rabbit:binding queue="order.queue" exchange="order.exchange" key="order.key"/> <!-- 4. 消息监听容器 --> <rabbit:listener-container connection-factory="connectionFactory" concurrency="5" prefetch="1" acknowledge="manual"> <!-- 手动ACK --> <rabbit:listener ref="orderConsumer" method="handleMessage" queue-names="order.queue"/> </rabbit:listener-container> <!-- 5. 消费者Bean --> <bean id="orderConsumer" class="com.example.OrderConsumer"/> </beans> ``` ### 🔑 关键配置说明 1. **生产者核心组件**： - `rabbit:template`：消息发送入口 - `rabbit:direct-exchange`：声明交换机（确保存在） - 消息转换器：JSON格式转换 2. **消费者核心组件**： - `rabbit:queue`：声明消费队列（必须存在） - `rabbit:listener-container`：消息监听容器 - 手动ACK模式：确保消息可靠处理[^2] 3. **配置分离原则**： ```mermaid graph LR A[生产者] -->|只关注| B[交换机声明] C[消费者] -->|必须关注| D[队列声明] C -->|建议关注| E[绑定关系] B -.-> F[消息路由] D -.-> F F --> G[消息传递] ``` ### ⚙️ 使用示例代码 **生产者实现**： ```java public class OrderProducer { private RabbitTemplate rabbitTemplate; public void sendOrder(Order order) { rabbitTemplate.convertAndSend( "order.key", // 路由键 order // 消息对象 ); } // setter省略 } ``` **消费者实现**： ```java public class OrderConsumer { public void handleMessage(Order order, Channel channel, Message message) throws IOException { try { // 1. 处理业务逻辑 processOrder(order); // 2. 手动ACK确认 channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); } catch (Exception e) { // 3. 处理失败：NACK或重试 channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true); } } } ``` ### ⚠️ 重要注意事项 1. **声明一致性**： - 如果生产者和消费者都声明同名资源（如交换机），参数必须完全一致 - 推荐方案：生产者声明交换机，消费者声明队列和绑定 2. **配置覆盖策略**： ```xml <!-- 避免重复声明冲突 --> <rabbit:queue name="order.queue" ignore-declaration-exceptions="true"/> ``` 3. **高级队列配置**： ```xml <!-- 死信队列示例 --> <rabbit:queue name="dlx.queue"> <rabbit:queue-arguments> <entry key="x-message-ttl" value="10000" value-type="java.lang.Long"/> </rabbit:queue-arguments> </rabbit:queue> ``` 4. **事务支持**： ```xml <!-- 生产者端启用事务 --> <rabbit:template id="rabbitTemplate" channel-transacted="true"/> ``` ### 📚 相关问题 1. RabbitMQ XML配置中如何实现消息重试机制？ 2. Spring中如何配置RabbitMQ的多消费者并发处理？ 3. RabbitMQ死信队列在XML中如何完整配置？ 4. 如何在XML配置中实现RabbitMQ消息的TTL（生存时间）？ 5. Spring XML配置如何实现RabbitMQ的消息确认（ACK）机制？ 6. RabbitMQ的交换机类型（direct/topic/fanout）在XML中如何区分配置？ > 提示：在实际项目中，推荐使用Spring Boot的自动配置简化集成[^1][^2]，XML配置更适合需要精细控制的老系统迁移场景。