spring boot使用rabbitmq

Spring Boot提供了RabbitMQ的集成，可以方便地使用RabbitMQ来实现消息队列的功能。

以下是使用Spring Boot和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=your_host
spring.rabbitmq.port=your_port
spring.rabbitmq.username=your_username
spring.rabbitmq.password=your_password

3. 创建消息发送者

创建一个消息发送者类，通过注入RabbitTemplate来实现消息发送：

@Service
public class MessageSender {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void send(String message) {
        rabbitTemplate.convertAndSend("exchange_name", "routing_key", message);
    }
}

4. 创建消息接受者

创建一个消息接受者类，通过注入@RabbitListener注解来实现消息接收：

@Service
public class MessageReceiver {

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

5. 发送消息

在需要发送消息的地方，注入MessageSender并调用send方法：

@Autowired
private MessageSender messageSender;

public void sendMessage(String message) {
    messageSender.send(message);
}

6. 启动应用程序

启动应用程序后，消息发送者发送消息，消息接受者监听队列并接收消息。

以上就是使用Spring Boot和RabbitMQ实现消息队列的基本步骤。需要注意的是，RabbitMQ是一个分布式消息队列系统，需要正确配置连接信息和队列信息才能保证消息的正确传递。