使用 RabbitTemplate 集成 RabbitMQ

在 Spring Boot 中集成 RabbitMQ 并使用 RabbitTemplate 进行消息的发送和接收是一个常见的需求。下面我将指导你如何在你的项目中实现这一功能。

1. 添加依赖

首先，你需要在你的 pom.xml 文件中添加 RabbitMQ 的依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2. 配置 RabbitMQ

在 application.properties 或 application.yml 文件中配置 RabbitMQ 的连接信息：

# application.properties
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

或者 YAML 格式：

# application.yml
spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

3. 创建消息生产者

创建一个服务类来发送消息：

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class MessageProducer {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void sendMessage(String message) {
        System.out.println("Sending message = " + message);
        this.rabbitTemplate.convertAndSend("your-exchange-name", "routing-key", message);
        System.out.println("Sent the message successfully");
    }
}

注意替换 "your-exchange-name" 和 "routing-key" 为你的交换机名称和路由键。

4. 创建消息消费者

创建一个监听器来接收消息：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class MessageConsumer {

    @RabbitListener(queues = "your-queue-name")
    public void receiveMessage(String message) {
        System.out.println("Received message = " + message);
    }
}

确保 "your-queue-name" 是你想要监听的队列名称。

5. 配置交换机、队列和绑定

通常情况下，你需要在配置文件或通过代码显式地声明你的交换机、队列和绑定关系。这可以通过在 Spring Boot 应用启动时执行的 @Configuration 类中的 @Bean 方法来完成：

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitConfig {

    @Bean
    public Queue queue() {
        return new Queue("your-queue-name");
    }

    @Bean
    public TopicExchange exchange() {
        return new TopicExchange("your-exchange-name");
    }

    @Bean
    public Binding binding(Queue queue, TopicExchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with("routing-key");
    }
}

6. 测试

最后，你可以创建一个控制器或直接调用 MessageProducer 类中的 sendMessage 方法来测试消息是否能够正确发送并被消费者接收到。

以上步骤应该能帮助你在 Spring Boot 应用中集成 RabbitMQ，并使用 RabbitTemplate 来进行消息的发送和接收。