平時工作中經常用到queue,但只停於用而不知道原理。對於工作多年碼農所忌諱的事。
好。。這裡就拿典型的rabbitmq為研究物件(當然，工作中也一直使用著它)
今天就來說說訊息防丟失的事。
首先rabbitmq訊息防丟失有兩種手段。
1、事務
2、確認
事務型就不多說了。。類似於db的事務。。
確認型要設定那些點呢？
1、exchange(交換器)、queue(佇列)、msg(訊息)都必需設定為持久化
2、consumer(消費方) 設定為手動確認。即autoack設定為false。 然後開啟乙個監聽ack（確認成功）, nack（確認失敗）的**方法。根據自身業務進行再處理。
那麼這時rabbitmq伺服器而言，訊息分為兩類，
第一類，等待投給consumer的訊息
第二類，已投給consumer，但還未收到消費者確認訊號的訊息。
如果 rabbitmq 一直沒有收到消費者的確認訊號，並且消費此訊息的消費者己經斷開連線，則 rabbitmq會安排該訊息重新進入佇列，
等待投遞給下乙個消費者，當然也有可 能還是原來的那個消費者。
3、producter（生產方）開啟確認模式（confirm）用來確認msg是否正確到達rabbitmq. 開啟乙個監聽ack（確認成功）, nack（確認失敗）的**方法。根據自身業務進行再處理。
關於python和rabbitmq的那點事兒
rabbitmq是乙個訊息中介軟體，在之前的zmq介紹中有略帶提過。由於zmq的硬傷 無法方便儲存 監控中間過程 故而工作中一直都是使用的 兔子 從1.7.0到現在的2.6.1版本 個人嘗試過的 rabbitmq有著許多令人欣喜 驚嘆的變化 或者說是進步 先來簡單介紹下當前版本 兔子 的閃光點 1....
關於rabbitmq持久化及訊息確認總結
重啟rabbitmq服務通過兩個命令來實現 rabbitmqctl stop 停止rabbitmq rabbitmq server restart 重啟rabbitmq 檢視rabbitmq佇列資訊 rabbitmqctl list queues 持久化佇列資訊 durable，persistent...
RabbitMQ中的訊息確認ACK機制
我們將訊息持久化後，假如消費端出現異常，rabbitmq伺服器會將訊息快取到記憶體，當生產者傳送一直傳送訊息而消費者都沒有正常消費時訊息就會將這些訊息全部儲存在記憶體，當我們的訊息過多時，就可能導致rabbitmq伺服器記憶體洩漏，解決辦法 1.開啟ack確認機制，2.消費端設定重試機制 預設是三次...