springboot项目整合rabbitmq

整合 RabbitMQ 可以让你的 Spring Boot 项目具备更好的异步处理和消息传递能力。下面是整合的步骤：

1. 添加 RabbitMQ 依赖

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

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

2. 配置 RabbitMQ

在 application.properties 文件中添加以下配置：

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

如果你使用的是 RabbitMQ 的默认端口和默认用户，那么可以不用配置端口和用户名密码。

3. 创建消息接收者

@Component
public class Receiver {

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

这里使用了 `@RabbitListener` 注解来监听名为 `myQueue` 的队列，并在接收到消息时打印出消息内容。

4. 创建消息发送者

@Component
public class Sender {

    @Autowired
    private RabbitTemplate rabbitTemplate;

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

这里使用了 `RabbitTemplate` 类来发送消息到名为 `myQueue` 的队列。

5. 测试

@SpringBootTest
class RabbitmqApplicationTests {

    @Autowired
    private Sender sender;

    @Test
    void testSendMessage() {
        sender.sendMessage("Hello, RabbitMQ!");
    }
}

在测试方法中调用 `Sender` 的 `sendMessage` 方法发送消息。当消息被发送时，`Receiver` 中的 `processMessage` 方法会被自动调用，从而处理消息。

以上就是整合 RabbitMQ 的基本步骤，你可以根据自己的需求进行配置和扩展。