spring 整合RabbitMQ

Spring 框架提供了对 RabbitMQ 的支持，可以方便地将 RabbitMQ 集成到 Spring 项目中。

下面是整合 RabbitMQ 的步骤：

1. 添加 RabbitMQ 的依赖

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

<dependency>
    <groupId>org.springframework.amqp</groupId>
    <artifactId>spring-rabbit</artifactId>
    <version>2.3.1.RELEASE</version>
</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 队列

使用 `RabbitAdmin` 对象创建队列：

@Configuration
public class RabbitMQConfig {

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

    @Bean
    public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) {
        return new RabbitAdmin(connectionFactory);
    }
}

4. 发送消息

使用 `RabbitTemplate` 对象发送消息：

@Autowired
private RabbitTemplate rabbitTemplate;

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

5. 接收消息

使用 `@RabbitListener` 注解指定要监听的队列，并使用 `Message` 对象接收消息：

@RabbitListener(queues = "myQueue")
public void receiveMessage(Message message) {
    String content = new String(message.getBody());
    System.out.println("Received message: " + content);
}

以上就是使用 Spring 框架整合 RabbitMQ 的步骤。