RabbitMQ是一個由erlang開發的AMQP(Advanved Message Queue)的開源實作。
場景說明：使用者注冊後，需要發注冊郵件和注冊短信,傳統的做法有兩種1.串行的方式;2.并行的方式
(2)并行方式:将注冊資訊寫入資料庫後,發送郵件的同時,發送短信,以上三個任務完成後,傳回給用戶端,并行的方式能提高處理的時間。
假設三個業務節點分别使用50ms,串行方式使用時間150ms,并行使用時間100ms。雖然并性已經提高的處理時間,但是,前面說過,郵件和短信對我正常的使用網站沒有任何影響，用戶端沒有必要等着其發送完成才顯示注冊成功,英愛是寫入資料庫後就傳回.
(3)消息隊列
引入消息隊列後，把發送郵件,短信不是必須的業務邏輯異步處理
由此可以看出,引入消息隊列後，使用者的響應時間就等于寫入資料庫的時間+寫入消息隊列的時間(可以忽略不計),引入消息隊列後處理後,響應時間是串行的3倍,是并行的2倍。
場景：雙11是購物狂節,使用者下單後,訂單系統需要通知庫存系統,傳統的做法就是訂單系統調用庫存系統的接口.
這種做法有一個缺點:
當庫存系統出現故障時,訂單就會失敗。(這樣馬雲将少賺好多好多錢^ ^)
訂單系統和庫存系統高耦合.
引入消息隊列
訂單系統:使用者下單後,訂單系統完成持久化處理,将消息寫入消息隊列,傳回使用者訂單下單成功。
庫存系統:訂閱下單的消息,擷取下單消息,進行庫操作。
就算庫存系統出現故障,消息隊列也能保證消息的可靠投遞,不會導緻消息丢失(馬雲這下高興了).
流量削峰一般在秒殺活動中應用廣泛
場景:秒殺活動，一般會因為流量過大，導緻應用挂掉,為了解決這個問題，一般在應用前端加入消息隊列。
作用:
1.可以控制活動人數，超過此一定閥值的訂單直接丢棄(我為什麼秒殺一次都沒有成功過呢^^)
2.可以緩解短時間的高流量壓垮應用(應用程式按自己的最大處理能力擷取訂單)
1.使用者的請求,伺服器收到之後,首先寫入消息隊列,加入消息隊列長度超過最大值,則直接抛棄使用者請求或跳轉到錯誤頁面.
2.秒殺業務根據消息隊列中的請求資訊，再做後續處理.
幾個概念說明:
Broker:它提供一種傳輸服務,它的角色就是維護一條從生産者到消費者的路線，保證資料能按照指定的方式進行傳輸,
Exchange：消息交換機,它指定消息按什麼規則,路由到哪個隊列。
Queue:消息的載體,每個消息都會被投到一個或多個隊列。
Binding:綁定，它的作用就是把exchange和queue按照路由規則綁定起來.
Routing Key:路由關鍵字,exchange根據這個關鍵字進行消息投遞。
vhost:虛拟主機,一個broker裡可以有多個vhost，用作不同使用者的權限分離。
Producer:消息生産者,就是投遞消息的程式.
Consumer:消息消費者,就是接受消息的程式.
Channel:消息通道,在用戶端的每個連接配接裡,可建立多個channel.
RabbbitMQ的分發機制非常适合擴充,而且它是專門為并發程式設計的,如果現在load加重,那麼隻需要建立更多的Consumer來進行任務處理。
為了保證資料不被丢失,RabbitMQ支援消息确認機制,為了保證資料能被正确處理而不僅僅是被Consumer收到,那麼我們不能采用no-ack，而應該是在處理完資料之後發送ack.
在處理完資料之後發送ack,就是告訴RabbitMQ資料已經被接收,處理完成,RabbitMQ可以安全的删除它了.
如果Consumer退出了但是沒有發送ack,那麼RabbitMQ就會把這個Message發送到下一個Consumer，這樣就保證在Consumer異常退出情況下資料也不會丢失.
RabbitMQ它沒有用到逾時機制.RabbitMQ僅僅通過Consumer的連接配接中斷來确認該Message并沒有正确處理，也就是說RabbitMQ給了Consumer足夠長的時間做資料處理。
如果忘記ack,那麼當Consumer退出時,Mesage會重新分發,然後RabbitMQ會占用越來越多的記憶體.
要持久化隊列queue的持久化需要在聲明時指定durable=True;
這裡要注意,隊列的名字一定要是Broker中不存在的,不然不能改變此隊列的任何屬性.
隊列和交換機有一個建立時候指定的标志durable,durable的唯一含義就是具有這個标志的隊列和交換機會在重新開機之後重建立立,它不表示說在隊列中的消息會在重新開機後恢複
消息持久化包括3部分
1. exchange持久化,在聲明時指定durable => true
2.queue持久化,在聲明時指定durable => true
3.消息持久化,在投遞時指定delivery_mode => 2(1是非持久化).
如果exchange和queue都是持久化的,那麼它們之間的binding也是持久化的,如果exchange和queue兩者之間有一個持久化，一個非持久化,則不允許建立綁定.
注意：一旦建立了隊列和交換機,就不能修改其标志了,例如,建立了一個non-durable的隊列,然後想把它改變成durable的,唯一的辦法就是删除這個隊列然後重制建立。
你可能也注意到了,分發機制不是那麼優雅,預設狀态下,RabbitMQ将第n個Message分發給第n個Consumer。n是取餘後的,它不管Consumer是否還有unacked Message，隻是按照這個預設的機制進行分發.
那麼如果有個Consumer工作比較重,那麼就會導緻有的Consumer基本沒事可做,有的Consumer卻毫無休息的機會,那麼,Rabbit是如何處理這種問題呢?
通過basic.qos方法設定prefetch_count=1，這樣RabbitMQ就會使得每個Consumer在同一個時間點最多處理一個Message，換句話說,在接收到該Consumer的ack前,它不會将新的Message分發給它
注意，這種方法可能會導緻queue滿。當然，這種情況下你可能需要添加更多的Consumer，或者建立更多的virtualHost來細化你的設計。
先來溫習以下交換機路由的幾種類型:
Direct Exchange:直接比對,通過Exchange名稱+RountingKey來發送與接收消息.
Fanout Exchange:廣播訂閱,向所有的消費者釋出消息,但是隻有消費者将隊列綁定到該路由器才能收到消息,忽略Routing Key.
Topic Exchange：主題比對訂閱,這裡的主題指的是RoutingKey,RoutingKey可以采用通配符,如:*或#，RoutingKey命名采用.來分隔多個詞,隻有消息這将隊列綁定到該路由器且指定RoutingKey符合比對規則時才能收到消息;
Headers Exchange:消息頭訂閱,消息釋出前,為消息定義一個或多個鍵值對的消息頭,然後消費者接收消息同時需要定義類似的鍵值對請求頭:(如:x-mactch=all或者x_match=any)，隻有請求頭與消息頭比對,才能接收消息,忽略RoutingKey.
預設的exchange:如果用空字元串去聲明一個exchange，那麼系統就會使用”amq.direct”這個exchange，我們建立一個queue時,預設的都會有一個和建立queue同名的routingKey綁定到這個預設的exchange上去
因為在第一個參數選擇了預設的exchange，而我們申明的隊列叫TaskQueue，是以預設的，它在建立一個也叫TaskQueue的routingKey，并綁定在預設的exchange上，導緻了我們可以在第二個參數routingKey中寫TaskQueue，這樣它就會找到定義的同名的queue，并把消息放進去。
如果有兩個接收程式都是用了同一個的queue和相同的routingKey去綁定direct exchange的話，分發的行為是負載均衡的，也就是說第一個是程式1收到，第二個是程式2收到，以此類推。
如果有兩個接收程式用了各自的queue，但使用相同的routingKey去綁定direct exchange的話，分發的行為是複制的，也就是說每個程式都會收到這個消息的副本。行為相當于fanout類型的exchange。
下面詳細來說:
綁定其實就是關聯了exchange和queue，或者這麼說:queue對exchange的内容感興趣,exchange要把它的Message deliver到queue。
Exchange和兩個隊列綁定在一起,Q1的bindingkey是orange，Q2的binding key是black和green.
當Producer publish key是orange時,exchange會把它放到Q1上,如果是black或green就會到Q2上,其餘的Message被丢棄.
多個queue綁定同一個key也是可以的,對于下圖的例子,Q1和Q2都綁定了black,對于routing key是black的Message，會被deliver到Q1和Q2，其餘的Message都會被丢棄.
對于Message的routing_key是有限制的，不能使任意的。格式是以點号“.”分割的字元表。比如：”stock.usd.nyse”, “nyse.vmw”, “quick.orange.rabbit”。你可以放任意的key在routing_key中，當然最長不能超過255 bytes。
對于routing_key，有兩個特殊字元
*(星号)代表任意一個單詞
#(hash)0個或多個單詞
Producer發送消息時需要設定routing_key，routing_key包含三個單詞和連個點号o,第一個key描述了celerity(靈巧),第二個是color(色彩),第三個是物種:
在這裡我們建立了兩個綁定： Q1 的binding key 是”.orange.“； Q2 是 “..rabbit” 和 “lazy.#”：
Q1感興趣所有orange顔色的動物
Q2感興趣所有rabbits和所有的lazy的.
例子:rounting_key 為 “quick.orange.rabbit”将會發送到Q1和Q2中
rounting_key 為”lazy.orange.rabbit.hujj.ddd”會被投遞到Q2中,#比對0個或多個單詞。
RabbitMQ使用ProtoBuf序列化消息,它可作為RabbitMQ的Message的資料格式進行傳輸,由于是結構化的資料,這樣就極大的友善了Consumer的資料高效處理,當然也可以使用XML，與XML相比,ProtoBuf有以下優勢:
1.簡單
2.size小了3-10倍
3.速度快了20-100倍
4.易于程式設計
6.減少了語義的歧義.
，ProtoBuf具有速度和空間的優勢，使得它現在應用非常廣泛
本文轉自 huangzp168 51CTO部落格，原文連結：http://blog.51cto.com/huangzp/1946058，如需轉載請自行聯系原作者