springboot集成rabbitmq

Spring Boot整合RabbitMQ主要涉及到以下几个步骤：

1. 添加依赖
2. 配置RabbitMQ
3. 创建消息接收者（消费者）
4. 创建消息发送者（生产者）

以下是一个简单的例子：

1. 添加依赖（pom.xml）

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

2. 配置RabbitMQ（application.properties）

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

3. 创建消息接收者（消费者）

@Component
public class Receiver {
 
    @RabbitListener(queues = "myQueue")
    public void receiveMessage(String content) {
        System.out.println("Received message: " + content);
    }
}

4. 创建消息发送者（生产者）

@Component
public class Sender {
 
    @Autowired
    private AmqpTemplate amqpTemplate;
 
    public void sendMessage(String message) {
        amqpTemplate.convertAndSend("myQueue", message);
    }
}

5. 使用生产者发送消息

@Autowired
private Sender sender;
 
public void send() {
    sender.sendMessage("Hello, RabbitMQ!");
}

在这个例子中，我们定义了一个名为myQueue的队列，并且通过Sender类发送了一个简单的字符串消息。Receiver类通过@RabbitListener注解监听这个队列，并接收消息。

注意：确保RabbitMQ服务器正在运行并且网络配置允许访问。