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文件中配置RabbitMQ连接信息：

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

3. 创建RabbitMQ队列

在应用程序中创建RabbitMQ队列：

@Configuration
public class RabbitMQConfig {
 
    @Bean
    public Queue queue() {
        return new Queue("myqueue");
    }
}

4. 发布消息

在应用程序中发布消息：

@Autowired
private RabbitTemplate rabbitTemplate;
 
public void send() {
    rabbitTemplate.convertAndSend("myqueue", "Hello, RabbitMQ!");
}

5. 接收消息

在应用程序中接收消息：

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

这些步骤可以帮助您在Spring Boot应用程序中集成RabbitMQ。