消息隊(duì)列

消息隊(duì)列這個(gè)概念其實(shí)在我之前的文章：手把手教姐姐寫(xiě)消息隊(duì)列，自己動(dòng)手用go寫(xiě)一個(gè)簡(jiǎn)易版的消息隊(duì)列，有興趣的小伙伴們可以看一下這篇文章?；貧w正題，我們?cè)賮?lái)介紹一下什么是消息隊(duì)列。

消息隊(duì)列，一般我們會(huì)簡(jiǎn)稱它為MQ(Message Queue)。他是由兩個(gè)單詞組成，我們應(yīng)該對(duì)隊(duì)列(Queue)很熟悉吧。隊(duì)列是一種先進(jìn)先出的數(shù)據(jù)結(jié)構(gòu)。再配合上消息，消息隊(duì)列可以簡(jiǎn)單理解為：把要傳輸?shù)臄?shù)據(jù)放在隊(duì)列中。使用較多的消息隊(duì)列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ。這里我們就不具體講解消息隊(duì)列實(shí)現(xiàn)細(xì)節(jié)，這不是本文的主題，只知道概念就可以了。了解了什么是消息隊(duì)列，我們一起來(lái)看看他在什么場(chǎng)景使用。

場(chǎng)景

消息隊(duì)列中間件是分布式系統(tǒng)中重要的組件，主要解決應(yīng)用耦合，異步消息，流量削鋒等問(wèn)題。這里舉一個(gè)消息隊(duì)列的使用場(chǎng)景：日志處理。

日志處理是指將消息隊(duì)列用在日志處理中，比如Kafka的應(yīng)用，解決大量日志傳輸?shù)膯?wèn)題。架構(gòu)簡(jiǎn)化如下：

• 日志采集客戶端，負(fù)責(zé)日志數(shù)據(jù)采集，定時(shí)寫(xiě)入     Kfaka隊(duì)列。
• Kfaka消息隊(duì)列，負(fù)責(zé)日志數(shù)據(jù)的接收，存儲(chǔ)和轉(zhuǎn)發(fā)。
• 日志處理應(yīng)用，訂閱并消費(fèi)kafka隊(duì)列中日志數(shù)據(jù)。

任務(wù)隊(duì)列

既然消息隊(duì)列稱為MQ，那么任務(wù)隊(duì)列我們就可以叫其TQ(Task Message)。任務(wù)隊(duì)列可以簡(jiǎn)單理解為：把要執(zhí)行的任務(wù)放在隊(duì)列中。使用較多的任務(wù)隊(duì)列有machiney、Celery、goWorker、YTask。每一個(gè)任務(wù)隊(duì)列都有自己的特點(diǎn)，這里就不細(xì)講了。我寫(xiě)了一篇machinery入門(mén)教程，并且翻譯了一篇machinery中文文檔，有需要的公眾號(hào)自取。具體任務(wù)隊(duì)列的細(xì)節(jié)就不講了。這不是本文的主題，下面我們看一看任務(wù)隊(duì)列的使用場(chǎng)景。

場(chǎng)景

任務(wù)隊(duì)列是用來(lái)執(zhí)行一個(gè)耗時(shí)任務(wù)。大家可能都使用過(guò)馬爸爸的花唄，每當(dāng)我們還款時(shí)，就會(huì)增加自己的芝麻信用分。這就可以用到任務(wù)隊(duì)列來(lái)計(jì)算用戶的積分和等級(jí)了。架構(gòu)簡(jiǎn)化如下：

• 用戶還款，當(dāng)用戶還款成功時(shí)，發(fā)送一個(gè)計(jì)算用戶積分計(jì)算的任務(wù)到任務(wù)隊(duì)列。

• 任務(wù)隊(duì)列，可以是mq，也可是redis，用來(lái)存儲(chǔ)任務(wù)。

• 任務(wù)執(zhí)行者，任務(wù)的執(zhí)行者，監(jiān)聽(tīng)任務(wù)隊(duì)列，當(dāng)任務(wù)隊(duì)列中有任務(wù)時(shí)，便會(huì)執(zhí)行。

區(qū)別

消息隊(duì)列和任務(wù)隊(duì)列，我覺(jué)得最大的不同就是理念的不同：任務(wù)隊(duì)列傳遞的是"任務(wù)"，消息隊(duì)列傳遞的是"消息"。任務(wù)隊(duì)列可以說(shuō)是消息隊(duì)列的二次開(kāi)發(fā)。

通過(guò)上面兩個(gè)場(chǎng)景例子，我們可以總結(jié)一下兩者區(qū)別：

• 消息隊(duì)列更側(cè)重于消息的吞吐、處理，具有有處理海量信息的能力。另外利用消息隊(duì)列的生產(chǎn)者和消費(fèi)者的概念，也可以實(shí)現(xiàn)任務(wù)隊(duì)列的功能，但是還需要進(jìn)行額外的開(kāi)發(fā)處理。
• 任務(wù)隊(duì)列則提供了執(zhí)行任務(wù)所需的功能，比如任務(wù)的重試，結(jié)果的返回，任務(wù)狀態(tài)記錄等。雖然也有并發(fā)的處理能力，但一般不適用于高吞吐量快速消費(fèi)的場(chǎng)景。其實(shí)任務(wù)隊(duì)列和遠(yuǎn)程函數(shù)調(diào)用很像，不過(guò)和rpc調(diào)用不同，他的調(diào)用不是網(wǎng)絡(luò)請(qǐng)求的方式，而是通過(guò)利用消息隊(duì)列傳遞任務(wù)信息。