消息適配器概念講解與基本屬性介紹

1. 前言

Hello，大家好。本小節(jié)會為同學們介紹 RabbitMQ 在 Spring 生態(tài)中的消息適配器，消息適配器是 RabbitMQ 在 Spring 生態(tài)中的又一核心元素，通過針對不同的業(yè)務場景，設置不同的消息適配器，可以實現對不同業(yè)務場景下的消息進行不同方式的處理的目的。

本節(jié)主要內容：

• 消息適配器基礎概念概述；

• 消息適配器基礎配置介紹。

2. 消息適配器基礎概念概述

基礎概念：

消息適配器，可能一說這個名詞，大家就感覺有點陌生，我們可以把消息適配器拆開來進行理解。

首先，消息這一名詞就不用多說了，消息在我們的應用程序中指的就是應用程序中的數據，在 RabbitMQ 中，指的就是在 RabbitMQ 中流轉的消息，也就是說，我們應用程序中的數據在 RabbitMQ 中就被稱為消息。

最后，我們再來看適配器。和之前一樣，我們先從日常生活中舉個例子，比如我們的筆記本電腦，在筆記本電腦上存在不同的對外暴露的類似USB形式的端口，這些端口不僅僅只有USB這一種類型，還有Type-C，以及Light端口等，根據我們的需要來連接這些端口所用的工具就可以看做是一個適配器。

當我們需要將自己的電腦與大屏或投影儀設備相連接時，此時，我們需要一根連接在電腦和大屏或投影儀設備之間的連線，這根線我們通常稱為數據線，在有了這根數據線之后，我們就可以建立起一個在電腦和大屏或投影儀設備之間的連接，就可以將電腦的屏幕投影到大屏或投影儀設備上，這個過程就是我們的電腦適配大屏或投影儀設備的一個過程，而這中間的數據線就被可以被稱為適配器。

如果我們沒有這個數據線來作為電腦與大屏或投影儀設備之間的適配器，那么通常情況下我們就不能將電腦屏幕來進行投影了（Wifi投影的情況除外）。在這一例子中，我們也可以這樣說：即需要一根數據線來將我們的電腦屏幕與大屏或投影儀設備進行適配，以達到投影電腦屏幕的目的。

說白了，適配器其實就是為了適配兩種不同物品，來達到兩種或多種物品之間的協同工作的目的的一種技術手段，而這種技術手段可以是技術實物（比如數據線），也可以是一種可以在空氣中進行傳播的介質（Wifi投屏）。

消息適配器亦是如此，在 Spring-AMQP 中，消息適配器指的就是，為了監(jiān)聽 RabbitMQ 中的消息，從而將消息與具體的業(yè)務邏輯相結合，達到消息適配業(yè)務邏輯的目的的一種技術手段。

在介紹完消息適配器的基礎概念之后，下面讓我們來看一下如何對消息適配器進行簡單的配置吧。

3. 消息適配器基礎配置介紹

還是像上節(jié)小節(jié)一樣，要想在 Spring 中使用消息適配器，需要將 Spring-AMQP 和 AMQP-Stater 的依賴先引入進來，方便起見，同學們可以直接拷貝下放代碼：

3.1 引入消息適配器

以 Maven 引入方式為例，引入代碼如下所示：

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>amqp-client</artifactId>
  <version>3.6.5</version>
</dependency>

在將這兩個依賴進行引入之后，我們就可以對消息適配器進行配置了。

3.2 初始化消息適配器

在 Spring-AMQP 中，我們主要來介紹 MessageListenerAdapter 這一款消息適配器，因為這款消息適配器配置簡單，容易上手，初學者在學起來也易于理解。

本節(jié)以 MessageListenerAdapter 消息適配器為例，主要介紹一下 MessageListenerAdapter 消息適配器在使用之前的操作方法。

初始化 MessageListenerAdapter 消息適配器

像 RabbitAdmin 和 RabbitTemplate 一樣，要想使用消息適配器，需要先對消息適配器進行初始化，這個初始化過程非常簡單，初始化 MessageListenerAdapter 消息適配器的代碼如下所示：

代碼實現：

// 省略連接 RabbitMQ-Server 的步驟
MessageListenerAdapter adapter = new MessageListenerAdapter(new MessageAdapter());

代碼解釋：

1-2 行，我們使用了 new MessageListenerAdapter 的方式，來對 MessageListenerAdapter 消息適配器進行實例化，在實例化的同時，通過向 MessageListenerAdapter 消息適配器的構造方法中傳入我們自定義的消息適配器的實現，來將 MessageListenerAdapter 消息適配器進行初始化。

其中，MessageAdapter 是我們自定義的消息適配器的實現，這種方式有點類似我們的適配器設計模式，MessageListenerAdapter 消息適配器需要我們傳遞一個自定義的消息適配器的實現才能完成初始化操作。

通過上述兩行代碼，我們就完成了 MessageListenerAdapter 消息適配器的初始化操作，我們將在下節(jié)中為同學們介紹，MessageListenerAdapter 消息適配器中的屬性或方法。

Tips: 1. MessageListenerAdapter 消息適配器，其全名為消息監(jiān)聽適配器，只不過我們習慣稱為消息適配器，其主要目的就是為了代替?zhèn)鹘y的消息監(jiān)聽方式，即采用消息監(jiān)聽適配的方式來監(jiān)聽消息的變化，從而適配不同的業(yè)務場景；
2. 采用消息監(jiān)聽適配器的方式來監(jiān)聽消息并適配不同的業(yè)務場景，較采用傳統的消息監(jiān)聽處理方法更靈活，代碼思路更清晰，且支持復雜業(yè)務場景的消息適配處理。
3. 在實際的開發(fā)工作中，如果需要對 RabbitMQ 中的消息進行監(jiān)聽，那么我們一般都會選擇采用 MessageListenerAdapter 消息監(jiān)聽適配器的方式來處理，很少會采用傳統的消息監(jiān)聽方式來處理。

4. 小結

本小節(jié)通過日常生活中的一個例子，為同學們詳細介紹了消息適配器這一概念，包括什么是消息、什么是適配器，以及最后的什么是 RabbitMQ 消息適配器這一概念。在介紹完相關概念之后，又為同學們概述了 RabbitMQ 中經常使用的 MessageListenerAdapter 消息適配器的基礎使用，以及初始化方法。

通過基礎概念與基礎使用相結合的方式，旨在希望同學們可以通過本節(jié)的學習對 RabbitMQ 中的消息適配器這一概念有一個簡單清楚的認識，以及了解一些消息適配器的基礎使用方法，這樣我們在下節(jié)才會很好地掌握消息適配器中常用方法的使用。