消息隊列

消息隊列這個概念其實在我之前的文章：手把手教姐姐寫消息隊列，自己動手用go寫一個簡易版的消息隊列，有興趣的小伙伴們可以看一下這篇文章。回歸正題，我們再來介紹一下什么是消息隊列。

消息隊列，一般我們會簡稱它為MQ(Message Queue)。他是由兩個單詞組成，我們應該對隊列(Queue)很熟悉吧。隊列是一種先進先出的數據結構。再配合上消息，消息隊列可以簡單理解為：把要傳輸的數據放在隊列中。使用較多的消息隊列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ。這里我們就不具體講解消息隊列實現細節，這不是本文的主題，只知道概念就可以了。了解了什么是消息隊列，我們一起來看看他在什么場景使用。

場景

消息隊列中間件是分布式系統中重要的組件，主要解決應用耦合，異步消息，流量削鋒等問題。這里舉一個消息隊列的使用場景：日志處理。

日志處理是指將消息隊列用在日志處理中，比如Kafka的應用，解決大量日志傳輸的問題。架構簡化如下：

• 日志采集客戶端，負責日志數據采集，定時寫入     Kfaka隊列。
• Kfaka消息隊列，負責日志數據的接收，存儲和轉發。
• 日志處理應用，訂閱并消費kafka隊列中日志數據。

任務隊列

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

場景

任務隊列是用來執行一個耗時任務。大家可能都使用過馬爸爸的花唄，每當我們還款時，就會增加自己的芝麻信用分。這就可以用到任務隊列來計算用戶的積分和等級了。架構簡化如下：

• 用戶還款，當用戶還款成功時，發送一個計算用戶積分計算的任務到任務隊列。

• 任務隊列，可以是mq，也可是redis，用來存儲任務。

• 任務執行者，任務的執行者，監聽任務隊列，當任務隊列中有任務時，便會執行。

區別

消息隊列和任務隊列，我覺得最大的不同就是理念的不同：任務隊列傳遞的是"任務"，消息隊列傳遞的是"消息"。任務隊列可以說是消息隊列的二次開發。

通過上面兩個場景例子，我們可以總結一下兩者區別：

• 消息隊列更側重于消息的吞吐、處理，具有有處理海量信息的能力。另外利用消息隊列的生產者和消費者的概念，也可以實現任務隊列的功能，但是還需要進行額外的開發處理。
• 任務隊列則提供了執行任務所需的功能，比如任務的重試，結果的返回，任務狀態記錄等。雖然也有并發的處理能力，但一般不適用于高吞吐量快速消費的場景。其實任務隊列和遠程函數調用很像，不過和rpc調用不同，他的調用不是網絡請求的方式，而是通過利用消息隊列傳遞任務信息。