springBoot 整合rabbitMQ

Spring Boot 提供了很好的支持来整合 RabbitMQ，以下是整合步骤：

添加依赖

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

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

配置 RabbitMQ

在 application.properties 文件中配置 RabbitMQ：

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

创建消息发送者

创建一个消息发送者类，该类包含一个发送消息的方法：

@Component
public class Sender {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend("queue_name", message);
        System.out.println("Message sent: " + message);
    }
}

创建消息接收者

创建一个消息接收者类，该类包含一个处理接收到的消息的方法：

@Component
public class Receiver {

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

测试

在任何一个 Spring Boot 应用程序中调用发送消息的方法：

@Autowired
private Sender sender;

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

在控制台上会看到以下输出：

Message sent: Hello RabbitMQ!
Message received: Hello RabbitMQ!

这就证明了我们的 RabbitMQ 整合成功了。