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

1. 前言

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

本節(jié)主要內(nèi)容：

• 消息適配器基礎(chǔ)概念概述；

• 消息適配器基礎(chǔ)配置介紹。

2. 消息適配器基礎(chǔ)概念概述

基礎(chǔ)概念：

消息適配器，可能一說這個(gè)名詞，大家就感覺有點(diǎn)陌生，我們可以把消息適配器拆開來進(jìn)行理解。

首先，消息這一名詞就不用多說了，消息在我們的應(yīng)用程序中指的就是應(yīng)用程序中的數(shù)據(jù)，在 RabbitMQ 中，指的就是在 RabbitMQ 中流轉(zhuǎn)的消息，也就是說，我們應(yīng)用程序中的數(shù)據(jù)在 RabbitMQ 中就被稱為消息。

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

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

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

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

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

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

3. 消息適配器基礎(chǔ)配置介紹

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

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>

在將這兩個(gè)依賴進(jìn)行引入之后，我們就可以對(duì)消息適配器進(jìn)行配置了。

3.2 初始化消息適配器

在 Spring-AMQP 中，我們主要來介紹 MessageListenerAdapter 這一款消息適配器，因?yàn)檫@款消息適配器配置簡單，容易上手，初學(xué)者在學(xué)起來也易于理解。

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

初始化 MessageListenerAdapter 消息適配器

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

代碼實(shí)現(xiàn)：

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

代碼解釋：

1-2 行，我們使用了 new MessageListenerAdapter 的方式，來對(duì) MessageListenerAdapter 消息適配器進(jìn)行實(shí)例化，在實(shí)例化的同時(shí)，通過向 MessageListenerAdapter 消息適配器的構(gòu)造方法中傳入我們自定義的消息適配器的實(shí)現(xiàn)，來將 MessageListenerAdapter 消息適配器進(jìn)行初始化。

其中，MessageAdapter 是我們自定義的消息適配器的實(shí)現(xiàn)，這種方式有點(diǎn)類似我們的適配器設(shè)計(jì)模式，MessageListenerAdapter 消息適配器需要我們傳遞一個(gè)自定義的消息適配器的實(shí)現(xiàn)才能完成初始化操作。

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

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

4. 小結(jié)

本小節(jié)通過日常生活中的一個(gè)例子，為同學(xué)們?cè)敿?xì)介紹了消息適配器這一概念，包括什么是消息、什么是適配器，以及最后的什么是 RabbitMQ 消息適配器這一概念。在介紹完相關(guān)概念之后，又為同學(xué)們概述了 RabbitMQ 中經(jīng)常使用的 MessageListenerAdapter 消息適配器的基礎(chǔ)使用，以及初始化方法。

通過基礎(chǔ)概念與基礎(chǔ)使用相結(jié)合的方式，旨在希望同學(xué)們可以通過本節(jié)的學(xué)習(xí)對(duì) RabbitMQ 中的消息適配器這一概念有一個(gè)簡單清楚的認(rèn)識(shí)，以及了解一些消息適配器的基礎(chǔ)使用方法，這樣我們?cè)谙鹿?jié)才會(huì)很好地掌握消息適配器中常用方法的使用。