springboot引入rabbitmq

RabbitMQ是一个开源的消息代理软件，用于处理应用程序之间的消息传递。Spring Boot是一种让Spring开发变得更简单的工具，你可以使用它来快速地创建基于Spring的应用程序。

一、如何在Spring Boot中引入RabbitMQ：

1. 首先，你需要在项目的pom.xml文件中添加RabbitMQ的依赖。如果你使用的是Maven，可以添加以下依赖：

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

2. 在application.properties或application.yml文件中配置RabbitMQ的相关属性，如下：

spring.rabbitmq.host=your_host  
spring.rabbitmq.port=your_port  
spring.rabbitmq.username=your_username  
spring.rabbitmq.password=your_password

或者

spring:  
  rabbitmq:  
    host: your_host  
    port: your_port  
    username: your_username  
    password: your_password

如何使用RabbitMQ：

在Spring Boot中使用RabbitMQ，主要涉及到生产者（发送消息）和消费者（接收消息）。

1. 生产者：使用RabbitTemplate发送消息。首先，你需要在你的配置类中创建一个RabbitTemplate的Bean。然后，你就可以在你的服务类中注入这个RabbitTemplate并使用它来发送消息。示例代码如下：

@Service  
public class ProducerService {  
    @Autowired  
    private RabbitTemplate rabbitTemplate;  
   
    public void sendMessage(String exchange, String routingKey, Object message){  
        rabbitTemplate.convertAndSend(exchange, routingKey, message);  
    }  
}

2. 消费者：使用@RabbitListener注解来接收消息。首先，你需要在你的服务类上添加@RabbitListener注解，并在方法上使用@Payload注解来接收消息。示例代码如下：

@Service  
@RabbitListener(queues = "your_queue_name")  
public class ConsumerService {  
   
    @Payload  
    public void receiveMessage(String message) {  
        System.out.println("Received message: " + message);  
    }  
}