**:
1、生產者進行新增,20s後不進行消費,發現訊息從正常的佇列進入了死信佇列;
2、生產者進行新增,消費者進行消費;
3、設定死信佇列要根據具體的業務場景去應用,一般應用在當正常業務處理時出現異常時,將訊息拒絕則會進入到死信佇列中,有助於統計異常資料並做後續處理;
三、利用jemeter進行壓力測試:
1、向正常佇列中壓入1000條訊息,生產者不消費,過20s後發現進入死信佇列;
2、向正常佇列中壓入1000條訊息,消費者一直在消費,看20s後消費者能消費多少條訊息;
【總結】
1、對程式進行非同步處理後可以緩解一方產生塊另一方消費慢的問題;
2、可以實現延遲處理的功效:資料上來後先進入正常的queue中(根據業務設定相應的失效時間【延遲時間】)進入死信佇列,消費者消費死信佇列中的資料;注:正常queue沒有消費者,死信queue有消費者;
3、給客戶的體驗感好了,非同步處理後,不需要等待同步的結果;
MQ的應用場景
場景說明 使用者註冊後,需要發註冊郵件和註冊簡訊來告知使用者註冊成功,傳統的做法有兩種 1.序列的方式 2.並行的方式 場景 雙11是購物狂節,使用者下單後,訂單系統需要通知庫存系統,傳統的做法就是訂單系統呼叫庫存系統的介面.這種做法有乙個缺點 當庫存系統出現故障時,訂單就會失敗。訂單系統和庫存系統...
訊息佇列(MQ)簡介與應用場景
一 官方描述 mq全稱為message queue,訊息佇列 mq 是一種應用程式對應用程式的通訊方法。應用程式通過讀寫出入佇列的訊息 針對應用程式的資料 來通訊,而無需專用連線來鏈結它們。訊息傳遞指的是程式之間通過在訊息中傳送資料進行通訊,而不是通過直接呼叫彼此來通訊,直接呼叫通常是用於諸如遠端過...
訊息佇列應用場景
場景說明 使用者註冊後,需要發註冊郵件和註冊簡訊。傳統的做法有兩種1.序列的方式 2.並行方式。id iframe 0.05881618439392011 scrolling no 2 並行方式 將註冊資訊寫入資料庫成功後,傳送註冊郵件的同時,傳送註冊簡訊。以上三個任務完成後,返回給客戶端。與序列的...