springboot添加rabbitmq

在Spring Boot中添加RabbitMQ的步骤如下：

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

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

2. 配置RabbitMQ连接：在`application.properties`或`application.yml`文件中，添加以下配置信息：

spring.rabbitmq.host=your_host
spring.rabbitmq.port=your_port
spring.rabbitmq.username=your_username
spring.rabbitmq.password=your_password

替换`your_host`、`your_port`、`your_username`和`your_password`为你的RabbitMQ服务器的相关信息。

3. 创建消息生产者：创建一个类来定义消息的发送。可以使用`AmqpTemplate`接口提供的方法来发送消息。

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

@Component
public class RabbitMQProducer {

    @Autowired
    private AmqpTemplate amqpTemplate;

    public void sendMessage(String exchange, String routingKey, Object message) {
        amqpTemplate.convertAndSend(exchange, routingKey, message);
    }
}

4. 创建消息消费者：创建一个类来处理接收到的消息。可以使用`@RabbitListener`注解来监听特定的队列，并处理接收到的消息。

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

@Component
public class RabbitMQConsumer {

    @RabbitListener(queues = "your_queue_name")
    public void receiveMessage(Object message) {
        // 处理接收到的消息
    }
}

替换`your_queue_name`为你要监听的队列名称。

现在，你可以在其他类中使用`RabbitMQProducer`来发送消息，同时在`RabbitMQConsumer`中处理接收到的消息。

这就是在Spring Boot中添加RabbitMQ的基本步骤。你还可以进一步了解RabbitMQ的高级用法和配置，例如设置交换机、队列和绑定等。