消息隊(duì)列整體設(shè)計(jì)思路

主要是設(shè)計(jì)一個(gè)整體的消息被消費(fèi)的數(shù)據(jù)流。

這里會(huì)涉及到：消息生產(chǎn)Producer拳球、Broker(消息服務(wù)端)、消息消費(fèi)者Consumer。

file

1.Producer(消息生產(chǎn)者)：發(fā)送消息到Broker债蓝。

2.Broker(服務(wù)端)：Broker這個(gè)概念主要來自于Apache的ActiveMQ，特指消息隊(duì)列的服務(wù)端盛龄。

主要功能就是：把消息從發(fā)送端傳送到接收端饰迹，這里會(huì)涉及到消息的存儲(chǔ)、消息通訊機(jī)制等余舶。

3.Consumer(消息消費(fèi)者)：從消息隊(duì)列接收消息啊鸭，consumer回復(fù)消費(fèi)確認(rèn)。

Broker(消息隊(duì)列服務(wù)端)設(shè)計(jì)重點(diǎn)
1）消息的轉(zhuǎn)儲(chǔ)：在更合適的時(shí)間點(diǎn)投遞匿值，或者通過一系列手段輔助消息最終能送達(dá)消費(fèi)機(jī)赠制。

2）規(guī)范一種范式和通用的模式，以滿足解耦挟憔、最終一致性钟些、錯(cuò)峰等需求烟号。

3）其實(shí)簡單理解就是一個(gè)消息轉(zhuǎn)發(fā)器，把一次RPC做成兩次RPC政恍，發(fā)送者把消息投遞到broker汪拥，broker再將消息轉(zhuǎn)發(fā)一手到接收端。

總結(jié)起來就是兩次RPC加一次轉(zhuǎn)儲(chǔ)篙耗，如果要做消費(fèi)確認(rèn)迫筑，則是三次RPC。

為了實(shí)現(xiàn)上述消息隊(duì)列的基礎(chǔ)功能：

• 消息的傳輸
• 存儲(chǔ)
• 消費(fèi)

就需要涉及到如下三個(gè)方面的設(shè)計(jì)：

• 通信協(xié)議
• 存儲(chǔ)選擇
• 消費(fèi)關(guān)系維護(hù)

file

通訊協(xié)議

消息Message:既是信息的載體宗弯，消息發(fā)送者需要知道如何構(gòu)造消息铣焊，消息接收者需要知道如何解析消息，它們需要按照一種統(tǒng)一的格式描述消息罕伯，這種統(tǒng)一的格式稱之為消息協(xié)議曲伊。

傳統(tǒng)的通信協(xié)議標(biāo)準(zhǔn)有XMPP和AMQP協(xié)議等，現(xiàn)在更多的消息隊(duì)列從性能的角度出發(fā)使用自己設(shè)計(jì)實(shí)現(xiàn)的通信協(xié)議追他。

1.JMS
JMS（Java MessageService）實(shí)際上是指JMS API坟募。JMS是由Sun公司早期提出的消息標(biāo)準(zhǔn)，旨在為java應(yīng)用提供統(tǒng)一的消息操作邑狸，包括創(chuàng)建消息懈糯、發(fā)送消息、接收消息等单雾。

JMS通常包含如下一些角色：

file

JMS提供了兩種消息模型：

• 點(diǎn)對點(diǎn)
• 以及publish-subscribe（發(fā)布訂閱）模型赚哗。

當(dāng)采用點(diǎn)對點(diǎn)模型時(shí)，消息將發(fā)送到一個(gè)隊(duì)列硅堆，該隊(duì)列的消息只能被一個(gè)消費(fèi)者消費(fèi)屿储。

file

而采用發(fā)布訂閱模型時(shí)，消息可以被多個(gè)消費(fèi)者消費(fèi)渐逃。

在發(fā)布訂閱模型中够掠，生產(chǎn)者和消費(fèi)者完全獨(dú)立，不需要感知對方的存在茄菊。

2.AMQP

AMQP是 Advanced Message Queuing Protocol疯潭，即高級(jí)消息隊(duì)列協(xié)議。

AMQP不是一個(gè)具體的消息隊(duì)列實(shí)現(xiàn)面殖，而 是一個(gè)標(biāo)準(zhǔn)化的消息中間件協(xié)議竖哩。

目標(biāo)是讓不同語言，不同系統(tǒng)的應(yīng)用互相通信脊僚，并提供一個(gè)簡單統(tǒng)一的模型和編程接口相叁。 目前主流的ActiveMQ和RabbitMQ都支持AMQP協(xié)議。

AMQP是一種協(xié)議，更準(zhǔn)確的說是一種binary wire-level protocol（鏈接協(xié)議）钝荡。這是其和JMS的本質(zhì)差別，AMQP不從API層進(jìn)行限定舶衬，而是直接定義網(wǎng)絡(luò)交換的數(shù)據(jù)格式埠通。

JMS和AMQP比較

JMS: 只允許基于JAVA實(shí)現(xiàn)的消息平臺(tái)的之間進(jìn)行通信

AMQP: AMQP允許多種技術(shù)同時(shí)進(jìn)行協(xié)議通信

3.Kafka的通信協(xié)議

Kafka的Producer、Broker和Consumer之間采用的是一套自行設(shè)計(jì)的基于TCP層的協(xié)議逛犹。Kafka的這套協(xié)議完全是為了Kafka自身的業(yè)務(wù)需求而定制的端辱。

file

存儲(chǔ)選型

對于分布式系統(tǒng)，存儲(chǔ)的選擇有以下幾種

• 內(nèi)存
• 本地文件系統(tǒng)
• 分布式文件系統(tǒng)
• nosql
• DB

從速度上內(nèi)存顯然是最快的虽画，對于允許消息丟失舞蔽，消息堆積能力要求不高的場景(例如日志)，內(nèi)存會(huì)是比較好的選擇码撰。

DB則是最簡單的實(shí)現(xiàn)可靠存儲(chǔ)的方案渗柿，很適合用在可靠性要求很高，最終一致性的場景(例如交易消息)脖岛，對于不需要100%保證數(shù)據(jù)完整性的場景朵栖，要求性能和消息堆積的場景，hbase也是一個(gè)很好的選擇柴梆。

理論上陨溅，從速度來看，文件系統(tǒng)>分布式KV（持久化）>分布式文件系統(tǒng)>數(shù)據(jù)庫绍在，而可靠性卻截然相反门扇。

還是要從支持的業(yè)務(wù)場景出發(fā)作出最合理的選擇，如果你們的消息隊(duì)列是用來支持支付/交易等對可靠性要求非常高偿渡，但對性能和量的要求沒有這么高臼寄，而且沒有時(shí)間精力專門做文件存儲(chǔ)系統(tǒng)的研究，DB是最好的選擇溜宽。

對于不需要100%保證數(shù)據(jù)完整性的場景脯厨，要求性能和消息堆積的場景，hbase也是一個(gè)很好的選擇坑质，典型的比如 kafka的消息落地可以使用hadoop合武。

消費(fèi)關(guān)系處理

現(xiàn)在我們的消息隊(duì)列初步具備了轉(zhuǎn)儲(chǔ)消息的能力。

下面一個(gè)重要的事情就是解析發(fā)送接收關(guān)系涡扼，進(jìn)行正確的消息投遞了稼跳。

市面上的消息隊(duì)列定義了一堆讓人暈頭轉(zhuǎn)向的名詞，如JMS 規(guī)范中的Topic/Queue吃沪，Kafka里面的Topic/Partition/ConsumerGroup汤善，RabbitMQ里面的Exchange等等。

拋開現(xiàn)象看本質(zhì)，無外乎是單播與廣播的區(qū)別红淡。

所謂單播不狮，就是點(diǎn)到點(diǎn)；而廣播在旱，是一點(diǎn)對多點(diǎn)摇零。

為了實(shí)現(xiàn)廣播功能，我們必須要維護(hù)消費(fèi)關(guān)系桶蝎，通常消息隊(duì)列本身不維護(hù)消費(fèi)訂閱關(guān)系驻仅，可以利用zookeeper等成熟的系統(tǒng)維護(hù)消費(fèi)關(guān)系，在消費(fèi)關(guān)系發(fā)生變化時(shí)下發(fā)通知登渣。

消息隊(duì)列需要支持高級(jí)特性

除了上述的消息隊(duì)列基本功能以外噪服，消息隊(duì)列在某些特殊的場景還需要支持事務(wù)，消息重試等功能胜茧。

file

• 消息的順序
• 投遞可靠性保證
• 消息持久化
• 支持不同消息模型
• 多實(shí)例集群功能
• 事務(wù)特性等

以上就是如何設(shè)計(jì)一個(gè)消息隊(duì)列MQ的介紹粘优，由于篇幅關(guān)系，后續(xù)再詳解消息隊(duì)列需要支持的高級(jí)特性呻顽。

file

本文由博客一文多發(fā)平臺(tái) OpenWrite 發(fā)布敬飒！