spring boot整合rabbitmq

Spring Boot与RabbitMQ的整合可以通过使用Spring AMQP实现。下面是一个简单的步骤：

1. 添加依赖：在`pom.xml`文件中添加以下依赖关系：

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

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发送消息。你可以使用`RabbitTemplate`类来发送消息，例如：

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class MessageProducer {

    @Autowired
    private RabbitTemplate rabbitTemplate;

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

4. 创建消费者：创建一个简单的消费者，用于接收RabbitMQ发送的消息。你可以使用`@RabbitListener`注解来定义一个消息监听器，例如：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class MessageConsumer {

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

5. 启用RabbitMQ：通过在Spring Boot应用程序的主类上添加`@EnableRabbit`注解来启用RabbitMQ功能，例如：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.amqp.rabbit.annotation.EnableRabbit;

@SpringBootApplication
@EnableRabbit
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

}

这就是整合Spring Boot和RabbitMQ的基本步骤。你可以根据自己的需求进行更多的高级配置和定制。