springboot如何使用消息队列

Spring Boot提供了多种消息队列的支持，包括RabbitMQ、Kafka、ActiveMQ等。以下是使用RabbitMQ作为消息队列的示例：

1. 添加RabbitMQ依赖

在pom.xml文件中添加以下依赖：

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

2. 配置RabbitMQ连接信息

在application.properties文件中添加以下配置：

spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

3. 发送消息

编写一个发送消息的类：

@Component
public class RabbitMQSender {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void send(String message) {
        rabbitTemplate.convertAndSend("my-exchange", "my-routing-key", message);
    }
}

在上面的代码中，我们注入了RabbitTemplate，它是Spring AMQP提供的一个用于发送和接收消息的工具类。通过rabbitTemplate.convertAndSend()方法发送消息，第一个参数是交换机名称，第二个参数是路由键，第三个参数是消息内容。

4. 接收消息

编写一个接收消息的类：

@Component
public class RabbitMQReceiver {

    @RabbitListener(queues = "my-queue")
    public void receive(String message) {
        System.out.println("Received message: " + message);
    }
}

在上面的代码中，我们使用@RabbitListener注解标记该方法，表示它是一个用于接收消息的方法。@RabbitListener注解的参数queues指定了要监听的队列名称。

5. 测试

在一个Controller中注入RabbitMQSender，调用send方法发送消息，然后可以看到RabbitMQReceiver接收到了消息。

@RestController
public class TestController {

    @Autowired
    private RabbitMQSender rabbitMQSender;

    @GetMapping("/send")
    public void send() {
        rabbitMQSender.send("Hello, RabbitMQ!");
    }
}

以上就是使用Spring Boot和RabbitMQ实现消息队列的基本流程。如果要使用其他消息队列，只需要修改依赖和相应的配置即可。