RabbitMQ 即一個消息隊列，主要是用來實現應用程序的異步和解耦，同時也能起到消息緩衝，消息分發的做用。 apache
消息中間件在互聯網公司的使用中愈來愈多，剛纔還看到新聞阿里將RocketMQ捐獻給了apache，固然了今天的主角仍是講RabbitMQ。消息中間件最主要的做用是解耦，中間件最標準的用法是生產者生產消息傳送到隊列，消費者從隊列中拿取消息並處理，生產者不用關心是誰來消費，消費者不用關心誰在生產消息，從而達到解耦的目的。在分佈式的系統中，消息隊列也會被用在不少其它的方面，好比：分佈式事務的支持，RPC的調用等等。 安全
之前一直使用的是ActiveMQ，在實際的生產使用中也出現了一些小問題，在網絡查閱了不少的資料後，決定嘗試使用RabbitMQ來替換ActiveMQ，RabbitMQ的高可用性、高性能、靈活性等一些特色吸引了咱們，查閱了一些資料整理出此文。 服務器
RabbitMQ介紹 網絡
RabbitMQ是實現AMQP（高級消息隊列協議）的消息中間件的一種，最初起源於金融系統，用於在分佈式系統中存儲轉發消息，在易用性、擴展性、高可用性等方面表現不俗。RabbitMQ主要是爲了實現系統之間的雙向解耦而實現的。當生產者大量產生數據時，消費者沒法快速消費，那麼須要一箇中間層。保存這個數據。 異步
AMQP，即Advanced Message Queuing Protocol，高級消息隊列協議，是應用層協議的一個開放標準，爲面向消息的中間件設計。消息中間件主要用於組件之間的解耦，消息的發送者無需知道消息使用者的存在，反之亦然。AMQP的主要特徵是面向消息、隊列、路由（包括點對點和發佈/訂閱）、可靠性、安全。 socket
RabbitMQ是一個開源的AMQP實現，服務器端用Erlang語言編寫，支持多種客戶端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX。用於在分佈式系統中存儲轉發消息，在易用性、擴展性、高可用性等方面表現不俗。 tcp
相關概念 分佈式
一般咱們談到隊列服務, 會有三個概念： 發消息者、隊列、收消息者，RabbitMQ 在這個基本概念之上, 多作了一層抽象, 在發消息者和 隊列之間, 加入了交換器 (Exchange). 這樣發消息者和隊列就沒有直接聯繫, 轉而變成發消息者把消息給交換器, 交換器根據調度策略再把消息再給隊列。 性能
-
左側 P 表明 生產者，也就是往 RabbitMQ 發消息的程序。
-
中間便是 RabbitMQ，其中包括了 交換機 和 隊列。
-
右側 C 表明 消費者，也就是往 RabbitMQ 拿消息的程序。
那麼，其中比較重要的概念有 4 個，分別爲：虛擬主機，交換機，隊列，和綁定。 ui
-
虛擬主機：一個虛擬主機持有一組交換機、隊列和綁定。爲何須要多個虛擬主機呢？很簡單，RabbitMQ當中，用戶只能在虛擬主機的粒度進行權限控制。 所以，若是須要禁止A組訪問B組的交換機/隊列/綁定，必須爲A和B分別建立一個虛擬主機。每個RabbitMQ服務器都有一個默認的虛擬主機"/"。
-
交換機：Exchange 用於轉發消息，可是它不會作存儲 ，若是沒有 Queue bind 到 Exchange 的話，它會直接丟棄掉 Producer 發送過來的消息。
這裏有一個比較重要的概念：路由鍵 。消息到交換機的時候，交互機會轉發到對應的隊列中，那麼究竟轉發到哪一個隊列，就要根據該路由鍵。 -
綁定：也就是交換機須要和隊列相綁定，這其中如上圖所示，是多對多的關係。
交換機(Exchange)
交換機的功能主要是接收消息而且轉發到綁定的隊列，交換機不存儲消息，在啓用ack模式後，交換機找不到隊列會返回錯誤。交換機有四種類型：Direct, topic, Headers and Fanout
-
Direct：direct 類型的行爲是"先匹配, 再投送". 即在綁定時設定一個 routing_key, 消息的routing_key 匹配時, 纔會被交換器投送到綁定的隊列中去.
-
Topic：按規則轉發消息（最靈活）
-
Headers：設置header attribute參數類型的交換機
-
Fanout：轉發消息到全部綁定隊列
-
Direct Exchange
Direct Exchange是RabbitMQ默認的交換機模式，也是最簡單的模式，根據key全文匹配去尋找隊列。
第一個 X - Q1 就有一個 binding key，名字爲 orange； X - Q2 就有 2 個 binding key，名字爲 black 和 green。當消息中的 路由鍵 和 這個 binding key 對應上的時候，那麼就知道了該消息去到哪個隊列中。
Ps：爲何 X 到 Q2 要有 black，green，2個 binding key呢，一個不就好了嗎？ - 這個主要是由於可能又有 Q3，而Q3只接受 black 的信息，而Q2不只接受black 的信息，還接受 green 的信息。
Topic Exchange
Topic Exchange 轉發消息主要是根據通配符。 在這種交換機下，隊列和交換機的綁定會定義一種路由模式，那麼，通配符就要在這種路由模式和路由鍵之間匹配後交換機才能轉發消息。
在這種交換機模式下：
-
路由鍵必須是一串字符，用句號（.） 隔開，好比說 agreements.us，或者 agreements.eu.stockholm 等。
-
路由模式必須包含一個 星號（*），主要用於匹配路由鍵指定位置的一個單詞，好比說，一個路由模式是這樣子：agreements..b.*，那麼就只能匹配路由鍵是這樣子的：第一個單詞是 agreements，第四個單詞是 b。 井號（#）就表示至關於一個或者多個單詞，例如一個匹配模式是agreements.eu.berlin.#，那麼，以agreements.eu.berlin開頭的路由鍵都是能夠的。
具體代碼發送的時候仍是同樣，第一個參數表示交換機，第二個參數表示routing key，第三個參數即消息。以下：
rabbitTemplate.convertAndSend("testTopicExchange","key1.a.c.key2", " this is RabbitMQ!");
topic 和 direct 相似, 只是匹配上支持了"模式", 在"點分"的 routing_key 形式中, 可使用兩個通配符:
-
*表示一個詞.
-
#表示零個或多個詞.
Headers Exchange
headers 也是根據規則匹配, 相較於 direct 和 topic 固定地使用 routing_key , headers 則是一個自定義匹配規則的類型.
在隊列與交換器綁定時, 會設定一組鍵值對規則, 消息中也包括一組鍵值對( headers 屬性), 當這些鍵值對有一對, 或所有匹配時, 消息被投送到對應隊列.
Fanout Exchange
Fanout Exchange 消息廣播的模式，無論路由鍵或者是路由模式，會把消息發給綁定給它的所有隊列，若是配置了routing_key會被忽略。
這裏還有幾個概念：
鏈接（Connections）：指的是一條TCP鏈接，下圖表示當前rabbitmq上有6條tcp鏈接
頻道（Channels）：通常在創建tcp鏈接而且用戶登陸成功後，會在該鏈接上開頻道
socket = amqp_tcp_socket_new(conn);//tcp鏈接初始化，包括內存池分配等
status = amqp_socket_open(socket, hostname, port);
amqp_login(conn, "ot", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "ot", "1");
amqp_channel_open(conn, 1);