恢復內容開始 參考：https://www.cnblogs.com/vipstone/p/9275256.html RabbitMQ簡介 在介紹RabbitMQ之前實現要介紹一下MQ，MQ是什麼？ MQ全稱是Message Queue，可以理解為消息隊列的意思，簡單來說就是消息以管道的方式進行傳遞。 ...
------------恢復內容開始------------
參考：https://www.cnblogs.com/vipstone/p/9275256.html
RabbitMQ簡介
在介紹RabbitMQ之前實現要介紹一下MQ，MQ是什麼？
MQ全稱是Message Queue，可以理解為消息隊列的意思，簡單來說就是消息以管道的方式進行傳遞。
RabbitMQ是一個實現了AMQP（Advanced Message Queuing Protocol）高級消息隊列協議的消息隊列服務，用Erlang語言的。
使用場景
在我們秒殺搶購商品的時候，系統會提醒我們稍等排隊中，而不是像幾年前一樣頁面卡死或報錯給用戶。
像這種排隊結算就用到了消息隊列機制，放入通道裡面一個一個結算處理，而不是某個時間斷突然涌入大批量的查詢新增把資料庫給搞宕機，所以RabbitMQ本質上起到的作用就是削峰填谷，為業務保駕護航。
為什麼選擇RabbitMQ
現在的市面上有很多MQ可以選擇，比如ActiveMQ、ZeroMQ、Appche Qpid，那問題來了為什麼要選擇RabbitMQ？
- 除了Qpid，RabbitMQ是唯一一個實現了AMQP標準的消息伺服器；
- 可靠性，RabbitMQ的持久化支持，保證了消息的穩定性；
- 高併發，RabbitMQ使用了Erlang開發語言，Erlang是為電話交換機開發的語言，天生自帶高併發光環，和高可用特性；
- 集群部署簡單，正是應為Erlang使得RabbitMQ集群部署變的超級簡單；
- 社區活躍度高，根據網上資料來看，RabbitMQ也是首選；
工作機制
生產者、消費者和代理
在瞭解消息通訊之前首先要瞭解3個概念：生產者、消費者和代理。
生產者：消息的創建者，負責創建和推送數據到消息伺服器；
消費者：消息的接收方，用於處理數據和確認消息；
代理：就是RabbitMQ本身，用於扮演“快遞”的角色，本身不生產消息，只是扮演“快遞”的角色。
消息發送原理
首先你必須連接到RabbitMQ才能發佈和消費消息，那怎麼連接和發送消息的呢？
你的應用程式和Rabbit Server之間會創建一個TCP連接，一旦TCP打開，並通過了認證，認證就是你試圖連接Rabbit之前發送的Rabbit伺服器連接信息和用戶名和密碼，有點像程式連接資料庫，使用Java有兩種連接認證的方式，後面代碼會詳細介紹，一旦認證通過你的應用程式和Rabbit就創建了一條AMQP通道（Channel）。
通道是創建在“真實”TCP上的虛擬連接，AMQP命令都是通過通道發送出去的，每個通道都會有一個唯一的ID，不論是發佈消息，訂閱隊列或者介紹消息都是通過通道完成的。
為什麼不通過TCP直接發送命令？
1. TCP的創建和銷毀，開銷大，創建需要三次握手，銷毀需要四次分手。
2. 如果不使用通道，那麼引用程式就會使用TCP的方式連接到rabbitmq，高峰時每秒成千上萬條連接會造成資源的巨大浪費(一條tcp消耗資源，成千上萬的tcp會非常消耗資源)，而且操作系統每秒處理TCP連接數量也是有限的，必定會造成性能瓶頸。
3.通道的原理是一條線程一條通道，多條線程多條通道共同使用一條TCP連接。一條TCP連接可以容納無限的通道，及時每秒造成成千上萬的請求也不會造成性能瓶頸。
你必須知道的Rabbit
想要真正的瞭解Rabbit有些名詞是你必須知道的。
包括：ConnectionFactory（連接管理器）、Channel（通道）、Exchange（交換器）、Queue（隊列）、RoutingKey（路由鍵）、BindingKey（綁定鍵）。
ConnectionFactory（連接管理器）：應用程式與Rabbit之間建立連接的管理器，程式代碼中使用；
Channel（通道）：消息推送使用的通道；
Exchange（交換器）：用於接受、分配消息；
Queue（隊列）：用於存儲生產者的消息；
RoutingKey（路由鍵）：用於把生成者的數據分配到交換器上；
BindingKey（綁定鍵）：用於把交換器的消息綁定到隊列上；
看到上面的解釋，最難理解的路由鍵和綁定鍵了，那麼他們具體怎麼發揮作用的，請看下圖：
消息持久化
Rabbit隊列和交換器有一個不可告人的秘密，就是預設情況下重啟伺服器會導致消息丟失，那麼怎麼保證Rabbit在重啟的時候不丟失呢？答案就是消息持久化。
當你把消息發送到Rabbit伺服器的時候，你需要選擇你是否要進行持久化，但這並不能保證Rabbit能從崩潰中恢復，想要Rabbit消息能恢復必須滿足3個條件：
- 投遞消息的時候durable設置為true，消息持久化，代碼：channel.queueDeclare(x, true, false, false, null)，參數2設置為true持久化；
- 設置投遞模式deliveryMode設置為2（持久），代碼：channel.basicPublish(x, x, MessageProperties.PERSISTENT_TEXT_PLAIN,x)，參數3設置為存儲純文本到磁碟；
- 消息已經到達持久化交換器上；
- 消息已經到達持久化的隊列；
持久化工作原理
Rabbit會將你的持久化消息寫入磁碟上的持久化日誌文件，等消息被消費之後，Rabbit會把這條消息標識為等待垃圾回收。
持久化的缺點
消息持久化的優點顯而易見，但缺點也很明顯，那就是性能，因為要寫入硬碟要比寫入記憶體性能較低很多，從而降低了伺服器的吞吐量，儘管使用SSD硬碟可以使事情得到緩解，但他仍然吸幹了Rabbit的性能，當消息成千上萬條要寫入磁碟的時候，性能是很低的。
所以使用者要根據自己的情況，選擇適合自己的方式。
虛擬主機
每個Rabbit都能創建很多vhost，我們稱之為虛擬主機，每個虛擬主機其實都是mini版的RabbitMQ，擁有自己的隊列，交換器和綁定，擁有自己的許可權機制。
vhost特性
-
RabbitMQ預設的vhost是“/”開箱即用；
-
多個vhost是隔離的，多個vhost無法通訊，並且不用擔心命名衝突（隊列和交換器和綁定），實現了多層分離；
-
創建用戶的時候必須指定vhost；
vhost操作（具體命令見下一章內容）
可以通過rabbitmqctl工具命令創建：
rabbitmqctl add_vhost[vhost_name]
刪除vhost：
rabbitmqctl delete_vhost[vhost_name]
查看所有的vhost：
rabbitmqctl list_vhosts
