怎么用springboot整合rabbitmq

1. 添加依赖

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

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

2. 配置RabbitMQ连接信息

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

# RabbitMQ连接信息
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

3. 创建消息发送者

创建一个消息发送者类，使用RabbitTemplate发送消息，示例代码如下：

@Service
public class MessageSender {
    
    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend("exchangeName", "routingKey", message);
    }
}

4. 创建消息接收者

创建一个消息接收者类，使用@RabbitListener注解监听队列，示例代码如下：

@Service
public class MessageReceiver {

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

5. 创建消息队列

在RabbitMQ中创建一个消息队列，示例代码如下：

@Bean
public Queue queueName() {
    return new Queue("queueName");
}

6. 创建交换机

在RabbitMQ中创建一个交换机，示例代码如下：

@Bean
public FanoutExchange exchangeName() {
    return new FanoutExchange("exchangeName");
}

7. 绑定队列和交换机

将队列绑定到交换机上，示例代码如下：

@Bean
public Binding bindingName(Queue queueName, FanoutExchange exchangeName) {
    return BindingBuilder.bind(queueName).to(exchangeName);
}

至此，使用Spring Boot整合RabbitMQ完成了。