參考：https://www.cnblogs.com/JAYIT/p/10579888.html
目前對消息隊列并不了解其原理，本篇文章主要是通過慕課網學習歸納的一些筆記，為後續學習打下基礎。
衆所周知在對網站設計的時候，會遇到給使用者“群發短信”，“訂單系統有大量的日志”，“秒殺設計”等，伺服器沒法處理這種瞬間迸發的壓力，這種情況要保證系統正常有效的使用，就需要“消息隊列”的幫助。本篇主要通過消息隊列的思路進行學習。
主要了解如下知識：
1、隊列是個什麼東西，他能幹什麼？
2、對列的應用場景有哪些？
3、如何使用隊列對業務進行解偶？
4、如何使用Redis隊列來消除高壓力？
5、專業的對列系統RabbitMQ如何使用？
歸納如下主要内容
@消息隊列的概念，原理和場景
@解耦案例：隊列處理訂單系統和配送系統
@流量削峰案例：Redis的List類型實作秒殺
@RabbitMQ：更專業的消息系統實作方案
一、認識消息隊列
1.1 消息對列概念
從本質上說消息對列就是一個隊列結構的中間件，也就是說消息放入這個中間件之後就可以直接傳回，并不需要系統立即處理，而另外會有一個程式讀取這些資料，并按順序進行逐次處理。
也就是說當你遇到一個并發特别大并且耗時特别長同時還不需要立即傳回處理結果，使用消息隊列可以解決這類問題。
1.2 核心結構
由一個業務系統進行入隊，把消息逐次插入到消息隊列中，插入成功之後直接傳回成功的結果，後續會有一個消息處理系統，這個系統會把消息系統中的記錄逐次進行取出并進行處理，完成一個出隊的流程。
1.3 應用場景
資料備援：比如訂單系統，後續需要嚴格的進行資料轉換和記錄，消息隊列可以把這些資料持久化的存儲在隊列中，然後有訂單，後續處理程式進行擷取，後續處理完之後在把這條記錄進行删除來保證每一條記錄都能夠處理完成。
系統解耦：使用消息系統之後，入隊系統和出隊系統是分開的，也就說隻要一天崩潰了，不會影響另外一台系統正常運轉。
流量削峰：例如秒殺和搶購，我們可以配合緩存來使用消息隊列，能夠有效的頂住瞬間通路量，防止伺服器承受不住導緻崩潰。
異步通信：消息本身使用入隊之後可以直接傳回。
擴充性：例如訂單隊列，不僅可以處理訂單，還可以給其他業務使用。
排序保證：有些場景需要按照産品的順序進行處理比如單進單出進而保證資料按照一定的順序處理，使用消息隊列是可以的。
以上都是消息隊列常見的使用場景，當然消息隊列隻是一個中間件，可以配合其他産品進行使用。
1.4 常見隊列實作優缺點
隊列媒體
1、資料庫，例如mysql（可靠性高，易實作，速度慢）
2、緩存， 例如redis （速度快，單個消息報包過大時效率低）
3、消息系統，例如rabbitMq （專業性強，可靠，學習成本高）
消息處理觸發機制
1、死循環方式讀取：易實作，故障時無法及時恢複；（比較适合做秒殺，比較集中，運維集中維護）
2、定時任務：壓力均分，有處理上限；目前比較流行的處理觸發機制。（唯一的缺點是間隔和資料需要注意，不要等上一個任務沒有完成下一個任務又開始了）
3、守護程序：類似于php-fpm 和php-cg,需要shell基礎
二、解藕案例：隊列處理“訂單系統”和“配送系統”
簡單說一下程式解耦：程式解耦就是避免出現你老婆和你媽同時掉到水裡先去救誰的問題（偷笑ing）
對于訂單流程，我們可以設計兩個系統，一個是“訂單系統” 另外一個是 “配送系統”， 在網購的時候我們應該都見過，當我送出了一個訂單之後，我在背景可以看到我的貨物正在配送中。這個時候就要參與進來一個“配送系統”。
如果我們在做架構的時候把 “訂單系統” 和 “配送系統” 設計在一起的話就會出現一些問題，首先對于訂單系統來說，因為系統的壓力會比較大，但是 "配送系統" 沒必要為這些壓力做一些即時的反應。
第二個我們也不希望在訂單系統出現故障之後導緻配送系統也出現故障，這個時候就會同時影響到兩個系統的正常運轉。是以我們希望把這兩個系統進行解耦。這兩系統分開之後我們可以通過一個中間的 “隊清單” 進行這兩個系統的溝通。
2.1 架構設計
1、首先訂單系統會接收使用者的訂單，然後進行訂單的處理。
2、然後會把這些訂單資訊寫到隊清單中，這個隊清單是溝通這兩個系統的關鍵。
3、由配送系統定時執行的一個程式來讀取隊清單進行處理。
4、配送系統處理之後，會把已處理的記錄進行标記。
2.2 程式流程
三、流量削峰案例：Redis 的 list 類型實作秒殺
redis 基于記憶體，它的速度會非常快，redis 對資料庫有一個非常好的補充作用因為它是可持久化的，redis會周期性的把資料寫到硬碟裡，是以它不用擔心斷電的問題，從這方面說它比另一款緩存 memcache 更有優勢些，另外 redis 提供五種資料類型（字元串，雙向連結清單，哈希，集合，有序集合）
一般情況下，做秒殺案例，搶購，瞬間高比你高發，需要排隊 的案例中 redis是一個很好的選擇。
3.1 redis資料類型中的 list 類型
redis 的list 是一個雙向連結清單，可以從頭部或者尾部追加資料。
* LPUSH/LPUSHX :将值插入到（/存在的）清單頭部
* RPUSH/RPUSHX: 将值插入到（/存在的）清單尾部
* LPOP : 移除并擷取清單的第一個元素
* RPOP: 移除并擷取清單的最後一個元素
* LTRIM: 保留指定區間内的元素
* LLEN: 擷取清單長度
* LSET: 通過索引設定清單元素的值
* LINDEX: 通過索引擷取清單中的元素
* LRANGE: 擷取清單指定範圍内的元素
3.2 架構設計
一個簡單結構秒殺的程式設計。
1、首先記錄是哪一個使用者參與了秒殺同時記錄他的時間。
2、将使用者的id存到redis清單中，讓它排隊。如果規定隻有前10個使用者可以參與成功，如果清單中的個數已經夠了就不會讓它繼續追加資料。這樣redis的清單長度就隻會是10個
3、最後在慢慢的将redis中的資料寫入到資料庫中，以減少資料的壓力
3.3 代碼級設計
1、當使用者開始秒殺時，将秒殺程式的請求寫入Redis (uid, time_stamp)中。
2、假使規定隻有10人可以秒殺成功，檢查 Redis 已經存放資料的長度，超出上限直接丢棄說明秒殺完成。
3、最後在死循環處理存入Redis中的10條資料，然後在慢慢的取資料并存入到mysql資料庫中。
在秒殺這一塊對于資料庫的壓力特别的大，如果我們沒有這樣的設計，會造成mysql的寫入瓶頸。我們通過Redis的一個對列list，然後把秒殺的請求放入到Redis裡面， 最後通過入庫程式，把資料慢慢的寫入到資料庫，這樣的話就可以實作流量的均衡，對mysql不會造成太大的壓力。
四、RabbitMQ
這裡講解一些RabbitMQ的使用，首先我們之前講秒殺案例的時候提到了鎖的機制，防止其他程式處理同一條記錄，如果我們的系統架構非常的複雜，有多個程式實時的讀取一個隊列，或者我有多個發送程式，同時來操作一個或多個隊列，甚至我還想這些程式分布在不同的機器上，這種情況下用redis隊列就有些力不從心了。這種時候怎麼辦呢，我們就需要來引入一些更專業的消息隊列系統，這些系統可以更好的來解決問題。
4.1 RabbitMQ的架構和原理
特點：完整的實作了AMQP,叢集簡化，持久化，跨平台
RabbitMQS使用
1、RabbitMQ安裝 （rabbitmq-server, php-amqplib）
2、生産者向消息通道發送消息
3、消費者處理消息
工作隊列
思想：由生産者發送給消息系統，消息系統把任務封裝成消息隊列之後，然後供多個消費者使用同一個隊列
這不僅解決了生産者和消費者之間的解耦，還可以實作了消費者和任務的共享，減緩了伺服器的壓力。
五、總結
以上主要學習消息隊列的概念，原理，場景。解耦案例以及削峰案例，以及了解RabbitMQ的簡單使用方法。
六、問題
redis 和消息伺服器 選擇的最大差別是什麼。
我的了解是Redis 是一個一個處理請求，redis屬于單線程，它和消息伺服器 IO 的實作方式不同，一個是同步一個是異步，而redis使用的是同步阻塞，而消息伺服器使用的是異步非阻塞。