RabbitMQ怎么與SpringBoot整合使用

223次閱讀

共計 1294 個字符，預計需要花費 4 分鐘才能閱讀完成。

要將 RabbitMQ 與 Spring Boot 整合使用，可以按照以下步驟操作：

添加 RabbitMQ 依賴：
在 Spring Boot 項目的 pom.xml 文件中添加 RabbitMQ 依賴，例如：

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

配置 RabbitMQ 連接信息：
在 application.properties 或 application.yml 文件中配置 RabbitMQ 的連接信息，例如：

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

創建 RabbitMQ 生產者：
創建一個 RabbitMQ 生產者類，用于發送消息到 RabbitMQ 隊列，例如：

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

@Component
public class RabbitMQProducer {@Autowired
    private AmqpTemplate amqpTemplate;

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

創建 RabbitMQ 消費者：
創建一個 RabbitMQ 消費者類，用于監聽并處理 RabbitMQ 隊列中的消息，例如：

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

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