MQ全稱為Message Queue,訊息佇列是一種應用程式對應用程式的通訊方式.應用程式通過讀寫初入佇列的訊息(針對應用層序的資料)來通訊,而無需朱勇連線來連線他們.訊息傳遞指的是程式之間通過在訊息中傳送資料進行通訊,而不是通過 直接呼叫彼此來通訊.直接呼叫通常是用於注入遠端過程呼叫的技術,排隊指的是應用程式通過佇列來通訊,佇列的使用出去了接受和傳送引用程式同時執行的要求.

 MQ的特點

    MQ是消費-生產者模型的一個典型的代表,一端往訊息佇列中不斷的寫入訊息,而另一端則可以讀取或者訂閱佇列中的訊息MQ和JMS類似.但是不同的是JMS是java訊息中介軟體服務的一個標準API定義.而MQ則是遵循了AMQP協議的具體實現和產品

使用場景

    在專案中,將一些無需及時返回且耗時的操作提取出來,進行了非同步處理,而這種非同步處理的方式大大節省了伺服器請求響應時間,從而提高了系統的吞吐量.

    在實際開發中訊息佇列一般用來應對資料庫的高併發,當資料庫的更新操作達到資料庫的峰值後會產生資料庫宕機的現象,引入訊息佇列後可以解決"資料庫的更新併發壓力",從而導致資料庫在高併發的情況下沒有宕機的風險.可以讓後臺資料庫的安全得到保障,讓後臺的整個架構效能至少提高30%.

    因為資料庫的處理有一定的峰值,使用佇列平衡這樣的關係,理論上訊息佇列的佇列是無限的.

1.1.1 安裝rabbitMQ

rabbitMQ執行環境:

1. 關閉防火牆

2. 新建資料夾 mkdir rabbitmq

說明:安裝rabbitMQ

1.1.1 匯入配置檔案

說明:

將rabbitMQ中的配置檔案拷貝後修改

/usr/share/doc/rabbitmq-server-3.6.1/rabbitmq.config.example.將檔名稱改為

rabbitmq.config.之後修改第

將修改後的檔案匯入/etc/rabbitmq/

1. 編輯rabbitMQ

1. 啟動rabbitMQ

service rabbitmq-server start  啟動

service rabbitmq-server stop   停止

service rabbitmq-server restart 重啟

1. rabbitMQ的埠號

A.15672 rabbitMQ控制檯埠 guest使用者名稱和密碼

B.5672  客戶端連線rabbitMQ的埠

1.1.1 控制檯說明

.檢視

1. Channels

說明:它是連結rabbitMQ的唯一通道.

2. Exchanges

交換機:可以讓訊息發往指定的佇列中

3. queues

佇列.在訊息佇列中可以有無數個佇列.

如果控制檯出現訊息沒有被消費unacked不為0.這時佇列阻塞.需要將佇列手動刪除

1.1.1 使用者許可權設定

1. 定義使用者

1. 定義虛擬主機

說明:自己維護的佇列的全部內容.包含路由/交換機/佇列

命名:/jt

1. 為使用者分片虛擬主機

最終結果: