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