springboot集成RabbitMQ

1. 添加 Maven 依赖

首先，你需要在你的 pom.xml 文件中添加 Spring Boot RabbitMQ Starter 的依赖。

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

2. 配置 RabbitMQ

在 application.properties 或 application.yml 文件中添加 RabbitMQ 的配置信息。

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

3. 创建消息生产者

创建一个服务类来发送消息到 RabbitMQ 队列。

import org.springframework.amqp.rabbit.core.RabbitTemplate;  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.stereotype.Service;  @Service  
public class MessageProducerService {  @Autowired  private RabbitTemplate rabbitTemplate;  public void sendMessage(String queueName, String message) {  rabbitTemplate.convertAndSend(queueName, message);  }  
}

4. 创建消息消费者

创建一个类来监听 RabbitMQ 队列并处理接收到的消息。

import org.springframework.amqp.rabbit.annotation.RabbitListener;  
import org.springframework.stereotype.Component;  @Component  
public class MessageConsumerService {  @RabbitListener(queues = "myQueue")  public void receiveMessage(String message) {  System.out.println("Received message: " + message);  }  
}

5. 运行和测试

创建一个简单的 REST API 或使用 Spring Boot 的命令行运行器来测试 RabbitMQ 的集成。

import org.springframework.boot.CommandLineRunner;  
import org.springframework.boot.SpringApplication;  
import org.springframework.boot.autoconfigure.SpringBootApplication;  
import org.springframework.context.annotation.Bean;  @SpringBootApplication  
public class RabbitmqApplication {  public static void main(String[] args) {  SpringApplication.run(RabbitmqApplication.class, args);  }  @Bean  public CommandLineRunner run(MessageProducerService producer) {  return args -> {  producer.sendMessage("myQueue", "Hello RabbitMQ!");  };  }  
}