rabbitmq的實(shí)戰(zhàn)應(yīng)用(ppt31頁(yè))-文庫(kù)吧資料
2025-03-03 21:41本頁(yè)面
【正文】 發(fā)送給消費(fèi)者消息數(shù)量，默認(rèn) 1，實(shí)踐采用 2 第二部分：部分應(yīng)用實(shí)踐 ? 復(fù)用 connection、復(fù)用 channel ? 如果需要可靠業(yè)務(wù)，需要支持持久化和 ack機(jī)制 – 兩臺(tái)虛擬機(jī)集群， QPS 5000次 /秒 ? 如果希望高吞吏，可以采取非持久化、 noack、自勱刪除機(jī)制 – 兩臺(tái)虛擬機(jī)集群測(cè)試， QPS 20k次 /秒 ? 穩(wěn)定性保障： – 生產(chǎn)者異常保障 – 消費(fèi)者異常保障 代碼實(shí)現(xiàn)需注意細(xì)節(jié) ? 生產(chǎn)者面對(duì) exchange，消費(fèi)者面對(duì) queue； ? 一個(gè) queue只有一個(gè)消費(fèi)者（可多個(gè)副本）進(jìn)行處理； ? 命名規(guī)劃： – exchange： ex_{bizobj}_{usecase}， 其中： ex為前綴， {bizobj}為業(yè)務(wù)對(duì)象（如 Car、 Dealer）， {usecase}為某個(gè)業(yè)務(wù)場(chǎng)景，示例： ex_car_promotion； – routekey：對(duì)應(yīng)亍 event（事件，某個(gè)業(yè)務(wù)勱作），如：置頂（ settop)、刷新 (refresh) – queue：為方便使用，建議對(duì)應(yīng)亍 event（采用 exchange + event），如： qu_{bizobj}_{usecase}_{event}，其中： ex為前綴，{bizobj}為業(yè)務(wù)對(duì)象（如 Car、 Dealer）， {usecase}為某個(gè)業(yè)務(wù)場(chǎng)景，示例： qu_car_promotion_settop； ? 串行或并行的業(yè)務(wù)方案： – 并行方案：一個(gè)事件發(fā)生后，多個(gè)消費(fèi)者相互間 沒有依賴關(guān)系 ，可由 exchange分發(fā)消息到多個(gè)隊(duì)列，由各隊(duì)列的消費(fèi)者并行進(jìn)行處理； – 串行方案：一個(gè)事件發(fā)生后，多個(gè)消費(fèi)間 有先后依賴關(guān)系 ，可以有先執(zhí)行的消費(fèi)者處理事件，處理完成后再次發(fā)送消息（此時(shí)為另外一個(gè) event）到 exchange，由后續(xù)的隊(duì)列進(jìn)行處理。 規(guī)劃 ? 根據(jù)不同的業(yè)務(wù)顆粒度規(guī)劃 – virtual host規(guī)劃：按平臺(tái)或系統(tǒng)規(guī)劃 – Exchange規(guī)劃：按系統(tǒng)規(guī)劃 – 隊(duì)列規(guī)劃：按模塊規(guī)劃 – MQ消費(fèi)規(guī)劃：按模塊規(guī)劃 規(guī)劃 案例：新車源營(yíng)銷 Si
環(huán)評(píng)公示相關(guān)推薦
鄂ICP備17016276號(hào)-1