spring boot 集成rabbitmq 简单模式

集成 RabbitMQ 并不是很难，下面是一个简单的 Spring Boot 集成 RabbitMQ 的示例：

1. 首先，需要在 `pom.xml` 文件中添加 RabbitMQ 的依赖：

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

2. 在 `application.yml` 文件中添加 RabbitMQ 的配置：

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

3. 创建一个消息生产者（即发送消息的一方）：

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

@Component
public class Producer {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send(String message) {
        rabbitTemplate.convertAndSend("queue-name", message);
    }

}

4. 创建一个消息消费者（即接收消息的一方）：

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

@Component
@RabbitListener(queues = "queue-name")
public class Consumer {

    @RabbitHandler
    public void receive(String message) {
        System.out.println("Received message: " + message);
    }

}

5. 最后，在任何一个组件中注入 `Producer` 并调用 `send` 方法即可发送消息，消息会被发送到名为 `queue-name` 的队列中。当有消息到达队列时，`Consumer` 中的 `receive` 方法会被自动调用，接收消息并进行处理。

以上就是一个简单的 Spring Boot 集成 RabbitMQ 的示例。需要注意的是，以上代码只是一个简单的示例，实际应用中还需要考虑很多其他因素，例如消息可靠性、消息确认机制、消息重试机制等等。