高併發架構是成為架構師的必修課，而消息隊列，則是王冠上最閃亮的那顆明珠！能否駕馭消息隊列這款高併發神器，亦成為架構師的試金石。本文將從隊列本質、技術選型兩個方面，給大家整理下個人心得，希望能對大家有所幫助。
一、前言
MQ全稱為Messages Queue ,消息隊列是應用程序和應用程序之間的通信方法
為什麼使用MQ？
在項目中，可將一些無需耗時的操作提取出來，進行異步操作，而這種異步處理方式大大的姐生了服務器的請求響應時間，從而提高了系統的吞吐量。
常見應用場景
開發中消息列隊通常有以下應用場景
1.任務異步處理
將不需要同步處理的斌且好使長的操作由消息隊列通知消息接收方進行異步處理。提高了應用的響應時間
2.應用程序解耦合
MQ相當於一箇中介，生產放通過MQ與消費方交互，它將應用程序進行解耦合。
二、隊列本質
當下成熟的消息隊列產品非常多，各種豐富的特性讓人眼花繚亂，難以抉擇。穿透現象先看本質，消息隊列其實就是一個第三方應用程序，管理著一塊兒內存空間，能快速存取數據，具備先進先出特性。只是跟系統架構設計相結合，產生了神奇的特效，請看下圖：
基於消息隊列的異步架構圖
消息隊列的好處 ：
1、流量削峰： 高併發的核心問題就是請求集中在同一時間，服務器來不及處理，而有了消息隊列，就可以將請求的數據打包放入，然後由後端處理器異步處理，降低高峰期的併發處理壓力，用時間換空間
2、高可用性： 90%系統的不可用都是因為數據庫，而在異步化架構裡，就算數據庫掛掉、甚至處理器掛掉，均不影響系統的可用性，客戶端可以繼續響應請求，只是將請求堆積在消息隊列即可
3、高擴展性： 異步化架構裡，客戶端和處理器是通過消息來交互的，只要保證消息格式不變，可以隨意獨立演化擴展。
三、技術選型
男怕入錯行，女怕嫁錯郎，技術選型很迷茫！網上也有各種關於技術選型分析的文章，更容易讓人產生混亂之感，下面我結合下個人開發實踐經歷，以及精選測試後的有效數據，給大家做下分析和推薦，僅一家之言！
1、kafka
官網：kafka.apache.org/
所有開源的MQ中吞吐量最強的，天然支持集群，消息堆積能力非常強悍。
Apache下的子項目，使用scala語言實現的一個高性能分佈式Publish/Subscribe消息隊列系統。無論在數據可靠性、穩定性和功能特性等方面都可以滿足絕大多數場景的需求，而且擁有著極致性能。
特點：
- 快速持久化：通過磁盤順序讀寫與零拷貝機制，可以在0(1)的系統開銷下進行消息持久化
- 高吞吐：在一臺普通的服務器上即可以達到10W/s的吞吐速率。
- 高堆積：支持topoc下消費者較長時間離線，消息堆積量大
- 完全的分佈式系統：Brocker、Producer、Consumer都原生自動支持分佈式，依賴zookeeper自動實現複雜均衡
- 支持Hadoop數據並行加載：對於像Hadoop的一樣的日誌數據和離線分系統，但又要求實時處理的限制，這是一個可行的解決方案。
但是其致命傷在於Kafka是為了性能選擇了異步批量發送模式，導致 延時太高，無法滿足在線業務場景，常用於日誌數據分析等場景 ！
2、RocketMQ
官網：rocketmq.apache.org/
RocketMQ國產阿里的，經過雙十一的檢驗。也非常強悍，基於java語言寫的
RocketMQ的前身是Metaq,當Metaq3.0發佈時，產品名稱改為RocketMQ。RocketMQ是一款分佈式、隊列模型的消息中間件，作為優秀的國產消息隊列，近年來越來越多的被國內眾多大廠使用。
特點：
- 能夠保證嚴格的消息順序
- 提供豐富的消息拉取模式
- 高效的訂閱水平擴展能力
- 實時的消息訂閱機制
- 支持事務消息
- 億級消息堆積能力
3、ActiveMQ
官網：activemq.apache.org/
最老牌的開源消息隊列，想當年是開源消息隊列首選，不過眼下已進入老年期，社區不活躍了。
無論是功能還是性能，ActiveMQ 都已經與現代的消息隊列存在明顯的差距，它存在的意義在於兼容那些還在用老系統，比如2013年我給廣東電信做外包項目時接入的還是ActiveMQ！
特點：
- 支持來自Java，C，C ++，C＃，Ruby，Perl，Python，PHP的各種跨語言客戶端和協議
- 完全支持JMS客戶端和Message Broker中的企業集成模式
- 支持許多高級功能，如消息組，虛擬目標，通配符和複合目標
- 完全支持JMS 1.1和J2EE 1.4，支持瞬態，持久，事務和XA消息
- Spring支持，以便ActiveMQ可以輕鬆嵌入到Spring應用程序中，並使用Spring的XML配置機制進行配置
- 專為高性能集群，客戶端 - 服務器，基於對等的通信而設計
- CXF和Axis支持，以便ActiveMQ可以輕鬆地放入這些Web服務堆棧中以提供可靠的消息傳遞
- 可以用作內存JMS提供程序，非常適合單元測試JMS
- 支持可插拔傳輸協議，例如in-VM，TCP，SSL，NIO，UDP，多播，JGroups和JXTA傳輸
- 使用JDBC和高性能日誌支持非常快速的持久性
4、RabbitMQ
官網：www.rabbitmq.com/
特點是Messaging that just works，“開箱即用的消息隊列”。也就是說，RabbitMQ 是一個相當輕量級的消息隊列， 非常容易部署和使用。
使用Erlang編寫的一個開源的消息隊列，本身支持很多的協議：AMQP,XMPP,SMTP,STOMP,它是一種應用程序之間的湧信方法，在分佈式系統開發中應用非常廣乏，正是如此使它變得非常重量級，更適合於企業級的開發。
同時實現了Broker架構，核心思想是生產者不會將消息直接發送給隊列，消息在發送給客戶端時先在中心隊列排隊。對路由，負載均衡、數據持久化都有很好的支持。多用於進行企業級的ESB整合。
特點：
- 異步消息傳遞：支持多種消息協議，消息隊列，傳送確認，靈活的路由到隊列，多種交換類型；
- 支持幾乎所有最受歡迎的編程語言：Java，C，C ++，C＃，Ruby，Perl，Python，PHP等等；
- 可以部署為高可用性和吞吐量的集群; 跨多個可用區域和區域進行聯合；
- 可插入的身份驗證，授權，支持TLS和LDAP。；
- 提供了一個易用的用戶界面，使得用戶可以監控和管理消息 Broker 的許多方面；
- 提供了許多插件，來從多方面進行擴展，也可以編寫自己的插件。
RabbitMQ提供了6種模式：
- 簡單模式
- work工作模式
- publish/Subscribe發佈與訂閱模式
- Routing路由模式
- Topics主題模式
- RPC遠調用模式（遠程調用，不太算MQ）
四、最後
今天就寫到這，我打算把MQ中的各個技術選型從入門到項目中的實戰用法全部一級一級分享給大家，一是防止自己以後忘記可以回來翻翻看，二是分享給大家有興趣的朋友可以一起學習。
熟悉MQ的朋友，可能看下來解決寫的東西很簡單，但是畢竟也有很多人實際工作中並沒有用過MQ，自己可能也沒有了解過，對於沒有了解過的朋友來說，我覺得入個門還是挺不錯的。
