前言

消息隊列（Message Queue）是一種高效的異步通信機(jī)制，它在分布式應(yīng)用系統(tǒng)中扮演著重要的角色。簡單來說，消息隊列將消息發(fā)送者和消息接收者解耦，消息發(fā)送者只需要將消息發(fā)送給隊列，而不需要知道消息是如何被消費者處理的，同時，消息接收者也只需要從隊列中訂閱自己需要的消息，而不需要知道這些消息是由哪個發(fā)送者發(fā)送的。消息隊列能夠提高應(yīng)用程序的可擴(kuò)展性、可靠性以及靈活性，并且能夠緩解高并發(fā)情況下的壓力。

RabbitMQ 是一個開源的 AMQP 消息代理軟件，它基于 Erlang/OTP 平臺，具有高可靠性、高可用性、高可擴(kuò)展性等特點。RabbitMQ 提供了豐富的功能和特性，包括多種消息傳遞模式、多種交換機(jī)類型、消息持久化、集群部署、負(fù)載均衡、事務(wù)支持、各種編程語言客戶端等。同時，RabbitMQ 也提供了豐富的插件，可以與其他系統(tǒng)集成，如 MongoDB、MySQL、ElasticSearch 等。由于其可靠性和高可用性，RabbitMQ 被廣泛應(yīng)用于各種企業(yè)級的分布式應(yīng)用系統(tǒng)中，如電商、金融、物流、游戲等。

下面我們就根據(jù)SpringBoot框架整合RabbitMQ,實現(xiàn)一個簡單的傳輸案例帶大家理解消息隊列的執(zhí)行過程。

一、導(dǎo)入依賴

首先要在pom.xml文件中將依賴導(dǎo)入，代碼如下：

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

二、配置連接MQ信息

RabbitMQ 默認(rèn)的端口號是 5672。這個端口用于 AMQP（高級消息隊列協(xié)議）的常規(guī)連接。包括用戶名、密碼也是默認(rèn)的。

配置如下代碼所示：

spring:
#  rabbitmq消息隊列配置
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

三、編寫代碼

3.1 生產(chǎn)者

• @Component 注解標(biāo)記了該類為一個 Spring 組件，將由 Spring 進(jìn)行管理和依賴注入。
• AmqpTemplate 是 RabbitMQ 提供的一個高級抽象接口，用于簡化與 RabbitMQ 進(jìn)行交互的操作。通過 @Autowired 注解進(jìn)行依賴注入，將 AmqpTemplate 實例注入到 amqpTemplate 字段中。
• sendMessage 方法用于發(fā)送消息到指定的隊列。它接受兩個參數(shù)：queueName 是目標(biāo)隊列的名稱，message 是要發(fā)送的消息內(nèi)容。
• 在方法內(nèi)部，首先打印出要發(fā)送的消息和目標(biāo)隊列的名稱。
• 接下來，使用 amqpTemplate.convertAndSend(queueName, message) 方法將消息發(fā)送到指定的隊列。convertAndSend 方法會自動將消息進(jìn)行序列化，并發(fā)送給 RabbitMQ。
• 最后，打印出消息發(fā)送成功的提示信息。

通過調(diào)用 sendMessage 方法，可以在其他組件中發(fā)送消息到指定的隊列。這個 MessageSender 類使得與 RabbitMQ 進(jìn)行消息的發(fā)送變得更加簡單和方便。

具體代碼如下：

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

    //This method sends a message to a queue given a queue name and message
    public void sendMessage(String queueName, String message) {
        System.out.println("發(fā)送消息:" + message + "=====隊列名稱：" + queueName);
        amqpTemplate.convertAndSend(queueName, message);
        System.out.println("消息發(fā)送成功：" + message);
    }
}

3.2 消費者

• @Component 注解標(biāo)記了該類為一個 Spring 組件，將由 Spring 進(jìn)行管理和依賴注入。
• @RabbitListener(queues = “my-queue”) 注解表示該方法是一個 RabbitMQ 消息監(jiān)聽器，用于監(jiān)聽名為 “my-queue” 的隊列。當(dāng)有消息到達(dá)該隊列時，該方法會被自動調(diào)用。
• receiveMessage 方法定義了接收消息的邏輯。它接受一個 String 類型的參數(shù) message，代表接收到的消息內(nèi)容。
• 在方法內(nèi)部，打印出接收到的消息。

通過使用 @RabbitListener 注解標(biāo)記方法，并指定隊列名稱，你可以在應(yīng)用程序中創(chuàng)建多個這樣的消息接收器，以實現(xiàn)并發(fā)處理不同隊列中的消息。當(dāng)有消息到達(dá) “my-queue” 隊列時，MessageReceiver 組件會自動啟動，receiveMessage 方法會被調(diào)用并處理接收到的消息。這樣，你可以方便地編寫消息處理邏輯，根據(jù)實際需求進(jìn)行相應(yīng)的業(yè)務(wù)操作。

具體代碼如下：

@Component
public class MessageReceiver {
    @RabbitListener(queues = "my-queue")
    public void receiveMessage(String message) {
        System.out.println("接收到消息：" + message);
    }
}

3.3 編寫訪問接口

編寫Controller,這里涉及到的知識點就是以前學(xué)習(xí)過的內(nèi)容，只是設(shè)置/messages/send接口，調(diào)用生產(chǎn)者的sendMessage方法去實現(xiàn)消息的發(fā)送，看消息是否能夠自動接收。

具體代碼如下：

/**
 * 調(diào)用發(fā)送消息
 */
@RestController
@RequestMapping("/messages")
public class MessageController {
    @Autowired
    private MessageSender messageSender;

    @GetMapping("/send")
    public String sendMessage() {
        System.out.println("=======調(diào)用接口=======");
        String message = "Hello, RabbitMQ! 心態(tài)還需努力呀~";
        System.out.println("====開始發(fā)送消息====");
        messageSender.sendMessage("my-queue", message);
        return "消息已發(fā)送：" + message;
    }
}

四、啟動RabbitMQ

4.1 下載RabbitMQ/Erlang

代碼的編寫已經(jīng)完成，但別忘記需要啟動RabbitMQ服務(wù)。如果沒有下載和安裝Erlang、RabbitMQ的請先到官網(wǎng)安裝啟動。

點擊下方即可進(jìn)行下載。注：下載前先確定要下載的兩個版本是否兼容，不兼容啟動會報錯！

• Erlang
• RabbitMQ

4.2 打開RabbitMQ

下載完成后啟動rabbitmq，然后在瀏覽器中訪問localhost:15672接口進(jìn)行登錄，默認(rèn)用戶名、密碼都是guest，登錄后在下圖所示的“Add a new queue”進(jìn)行創(chuàng)建隊列。

這里的隊列名需和在生產(chǎn)者發(fā)送消息到哪個隊列一致，消費者取消息就從這個隊列里取

五、訪問接口查看消息

這里我使用Postman進(jìn)行調(diào)用接口進(jìn)行測試，結(jié)果如圖所示：

可以看到消息已經(jīng)發(fā)送成功，我們看下idea中的打印日志：

可以看到消費者已接收到生產(chǎn)者在my-queue隊列發(fā)送的消息。

總結(jié)

對于簡單的消息發(fā)送和接收就寫完了，消費者只需監(jiān)聽這個消息隊列就可獲取消息，而生產(chǎn)者也只需要將發(fā)送的消息內(nèi)容發(fā)送給某個隊列即可。

該案例重在理解過程，了解生產(chǎn)者，消費者如何實現(xiàn)的消息傳送。就是一個中間件，在消息發(fā)送的過程中起到一個中間站（隊列）的作用。

至于為什么能夠有高效、穩(wěn)定等特性，感興趣的可以自己去研究研究。

以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

最新評論