消息發(fā)送模式實戰(zhàn)之直接模式與主題模式

1. 前言

Hello，大家好。在前面幾章中，我們重點介紹了 RabbitMQ 的所有基礎知識內容，這些基礎知識內容是入門 RabbitMQ 的關鍵，是后續(xù)用好 RabbitMQ 的基礎。

那么，從本章開始呢，作為本套課程的最后一章內容，考慮到同學們的工作應用場景，所以，本章會為同學們介紹一些關于 RabbitMQ 實戰(zhàn)方向的內容，包括但不限于對我們工作中常用功能的優(yōu)化，以及對程序環(huán)境的優(yōu)化。

本小節(jié)作為 RabbitMQ 實戰(zhàn)章節(jié)的開篇小節(jié)，會首先為同學們介紹之前我們講過的，消息發(fā)送模式系列的實戰(zhàn)內容，老師會通過概念加代碼的形式來進行講解。

本節(jié)主要內容：

• 直接模式與主題模式基礎概念回顧；

• 直接模式與主題模式代碼實操。

2.直接模式與主題模式基礎概念回顧

從本小節(jié)開始，老師會首先為同學們介紹消息發(fā)送模式的實戰(zhàn)部分內容，本節(jié)會介紹消息發(fā)送模式之直接模式與主題模式的實戰(zhàn)內容，在我們正式開始使用代碼進行實戰(zhàn)之前，讓我們先來回顧一下消息發(fā)送模式之間接模式與主題模式的基礎概念。

2.1 直接模式基礎概念回顧

定義：

直接模式，即直接發(fā)送消息模式，指的是將消息直接發(fā)送給消費者。

描述：

直接模式允許將多個隊列綁定到一個交換機上，在生產(chǎn)者發(fā)送消息給交換機時，需要攜帶一個 key ，而這個 key 一般被稱為 routing key 或者 binding key，所以直接模式有時也被稱為路由模式。

Tips: RabbitMQ 一般將這個 key 叫做 binding key，但是在實際情況中，出于字面意思，習慣性地將 key 叫做 routing key

直接模式總共分為兩種業(yè)務場景，我們先來看第一種業(yè)務場景，一般被叫做’單 key 綁定’，如下圖所示：

我們再來看直接模式的最后一個業(yè)務場景，多重 key 綁定，如下圖所示：

在圖中我們可以看到，Q1、Q2 兩個隊列，分別綁定到了 routing key 均為 black 的 direct 交換機上，即名稱相同的一個 key 綁定到了多個隊列上面，這種現(xiàn)象被稱為多重 key 綁定。

在多重 key 綁定下，生產(chǎn)者生產(chǎn)的消息均會被發(fā)送到相同 key 值所綁定的隊列上面，這里需要同學們注意。

2.2 主題模式基礎概念回顧

定義：

主題模式，也被稱為通配符模式，官網(wǎng)一般稱為主題模式，即交換機與消息隊列所綁定的 key 值可以像匹配通配符的方式，來匹配消息隊列，到底什么意思呢，我們往下看。

描述：

主題模式對 routing key 的匹配規(guī)則做了改進，上述其他四種模式中有涉及 key 匹配的地方都是完全匹配，即名稱必須相等時才能把 key 匹配上，而對于主題模式，則不需要這樣。

主題模式將 key 值中的每個單詞或者關鍵詞，使用英文狀態(tài)下的 . 符號進行間隔，如上圖所示。

我們這里只是對直接消息發(fā)送模式，和主題消息發(fā)送模式的基礎概念進行了一個簡單的回顧，如果有同學忘了這些基礎概念，可以回過頭去 《RabbitMQ 消息發(fā)送模式詳解》 這一小節(jié)復習。

3 直接模式與主題模式代碼實操

3.1 直接模式代碼實操

在上述基礎概念中，我們對直接消息發(fā)送模式的兩種基礎業(yè)務場景做了介紹，下面會分別用代碼實現(xiàn)這兩種業(yè)務場景，實現(xiàn)代碼如下所示(以下均為消費者代碼，生產(chǎn)者請自行實現(xiàn))：

實現(xiàn)代碼：

// 直接模式第一種業(yè)務場景
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("192.168.0.1");
connectionFactory.setPort(5672);
connectionFactory.setUsername("guest");
connectionFactory.setPassword("guest");
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel();
channel.queueBind(QUEUE_ONE, EXCHANGE_NAME, "Routing Key");
channel.close();
connection.close();

代碼解釋：

第 1-5 行，我們使用了 RabbitMQ 的 ConnectionFactory 連接工廠，來初始化了一些獲取 RabbitMQ 連接的必要參數(shù)；

第 6 行，我們從 RabbitMQ 的連接工廠中，獲取到了一個 RabbitMQ Conneciton 連接實例；

第 7 行，我們通過 RabbitMQ 連接實例，創(chuàng)建了一個 channel 通道，為之后的消息通信提供媒介；

第 8 行，我們將創(chuàng)建出來的 channel 通道與我們的隊列相綁定，并單獨指定了一個名為 Routing Key 的 key 值。

第 9-10 行，在處理完通道與連接實例之后，我們分別調用了 close 方法，將建立的通信連接和通道進行關閉，以節(jié)省資源開銷。

以上代碼是我們實現(xiàn)的直接模式的，第一種業(yè)務場景，即單 key 綁定的業(yè)務場景，因為我們在 queueBind 方法中，為一個隊列指定了一個單一的 key 值。接下來讓我們看一下第二種業(yè)務場景的實現(xiàn)：

實現(xiàn)代碼：

// 直接模式第二種業(yè)務場景
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("192.168.0.1");
connectionFactory.setPort(5672);
connectionFactory.setUsername("guest");
connectionFactory.setPassword("guest");
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel();
channel.queueBind(QUEUE_ONE, EXCHANGE_NAME, "Routing Key");
channel.queueBind(QUEUE_TWO, EXCHANGE_NAME, "Routing Key");
channel.close();
connection.close();

代碼解釋：

第 1-7 行，代碼和第一種業(yè)務場景相似，這里不再贅述；

第 8-9 行，我們分別使用 channel 的 queueBind 方法來為兩個不同的隊列，聲明了同樣的 Routing Key 值。

第 10-11 行，代碼和第一種業(yè)務場景相似，這里不再贅述；

這里我們重點看第 8-9 行代碼，我們?yōu)閮蓚€不同的消息隊里指定了同一個 Routing Key 的值，那么再有消息過來時，同一條消息就會發(fā)送到這兩條隊列中，這就是第二種業(yè)務場景，即多重 key 綁定業(yè)務場景。

3.2 主題模式代碼實操

我們來看主體模式的代碼實現(xiàn)：

實現(xiàn)代碼：

ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("192.168.0.1");
connectionFactory.setPort(5672);
connectionFactory.setUsername("guest");
connectionFactory.setPassword("guest");
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel();
channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "key.*");
channel.close();
connection.close();

代碼解釋：

第 1-7 行，代碼和第一種業(yè)務場景相似，這里不再贅述；

第 8 行，我們使用 channel 的 queueBind 方法來將消息隊列和通道進行綁定，并聲明了名為 key.* 的 Routing Key 值。

第 10-11 行，代碼和第一種業(yè)務場景相似，這里不再贅述；

當我們設置了 key.* 的 Routing Key 值之后，我們的消息就會根據(jù)這個規(guī)則進行匹配的分發(fā)，這就是主題模式。

Tips:
1. 我們在實現(xiàn)直接消息發(fā)送模式的時候，一定要注意我們的業(yè)務場景，key 值的設定一定要符合實際情況；
2. 我們在實現(xiàn)主體消息發(fā)送模式的時候，要注意我們 key 值的一個匹配規(guī)則，要根據(jù)實際需要進行設置，不要隨意設置。

4. 小結

本小節(jié)為同學們詳細介紹了 RabbitMQ 消息發(fā)送模式之直接模式與主題模式的代碼實操等內容，包括直接模式與主題模式基礎概念等內容的回顧，以及直接模式常見的兩種業(yè)務場景的代碼實現(xiàn)、主題模式的代碼實現(xiàn)，同學們需要理清代碼實現(xiàn)的思路和步驟。