一、定義 定義一個操作中演算法的框架,而將一些步驟延遲到子類中。模板方法模式使得子類不改變一個演算法的結構即可重定義該演算法的特定步驟。模板方法是一種類行為型模式 二、描述 模板方法模式結構比較簡單,其核心是抽象類和其中的模板方法的設計,包含以下兩個角色: 1、AbstractClass(抽象類):在抽象 ...
背景
考慮到現有業務很多依賴於MQ的方式進行,這種方式需要依賴於MQ,發送消息到mq和消費mq消息時需要瞭解mq消息結構進行相應處理;
對於後續對同樣的事件做其他處理的人如不能提前瞭解到已有相應消息發到了mq就得再發一次消息到mq等。
圖1.1 消息中間件
現需要考慮在不依賴於Mq的形式下如何更優雅地實現非同步任務處理!!!
一.消息任務
1.1 現有輪詢方式
輪詢:針對每一個業務記錄一張輪詢中間表,通過輪詢掃描消費。
優點:
1. 時間性把控粒度高。
2. 每個業務彼此分離,互不幹涉。
缺點:
1. 每次創建業務都要建立一張屬於自己的輪詢表,也要建立一個新的輪詢配置。
2. 資源消耗大。
3. 研發效率低。
1.2優化方式
模擬RabbitMq的ACK方式建立一張共性表解決通用性業務的消息體存儲,共性化業務通用一個輪詢。
模擬RabbitMq的ACK模式,使用輪詢的方式替代mq的消息發送機制。制定專屬表欄位Table_Name模擬RabbitMq的RoutingKey。
每個業務處理通過Table_Name方式實現介面進行派發處理。每個實現了輪詢邏輯派發介面的類即可以認為是一個隊列。
以這種方式可以有效的實現消息的非同步處理。
優點:
1. 代碼規範化,每個服務中心只需要建立集中的一個輪詢業務;
2. 符合開閉原則,每增加一個輪詢處理只要多實現一個介面類即可;
3.可以減少資料庫資源的消耗;
4.減少無用代碼的增加,提高開發效率。
缺點:
1.由於數據量的增加,輪詢壓力增大,對特殊業務的輪詢時間性無法針對性的把控,需要建立特殊業務輪詢處理(增加輪詢)。
二.演變模型
2.1演化方向:模型由圖1.2 ——》 圖1.3
圖1.2 RabbitMQ
圖1.3 定時任務模擬圖
三.ACK模式
3.1什麼是ack模式?
RabbitMQ 的 ACK 模式是指消息確認機制,即消費者消費消息後需要向 RabbitMQ 伺服器發送一個 ACK(acknowledgement)信號來告訴伺服器該消息已經被處理。
ACK 模式主要有以下兩種:
1.自動確認模式(autoAck)
在自動確認模式下,消費者在收到消息後會立即向RabbitMQ 伺服器發送一個 ACK 信號,表示該消息已經被消費。
這種模式適用於對於消息的可靠性要求不高的場景,比如日誌處理等。
2.手動確認模式(manualAck)
手動確認模式下,消費者需要在處理完消息後,主動向RabbitMQ 伺服器發送 ACK 信號。
如果消費者沒有發送 ACK 信號,RabbitMQ 認為該消息沒有被正確處理,並將該消息重新分發給其他消費者。
此外,在手動確認模式下,如果消費者在處理消息時出現異常,可以通過拒絕消息(NACK)來告訴 RabbitMQ 伺服器該消息不能被處理,
此時 RabbitMQ 將會將該消息重新分發給其他消費者或保存到死信隊列中。
四.表結構
4.1建立合適的表結構
1. Uid,table_name,msg,remark,ack
2. Hisid,Uid,table_name,msg,remark,ack (歷史表,用於記錄處理過的消息)
(表名稱和欄位名稱可根據業務自行命名,以上數據結構供參考,可自行根據業務外拓欄位)
五.消息體
1.規範化msg的輸入形式。可以走切麵或者監聽的方式非同步記錄。寫一個公用方法寫入(特殊業務可調用該方法寫入)。
2.規範化Table_Name欄位:採用駝峰名稱,代表哪個表寫進來的數據。
3.規範化ack,預設設置為0;消費完成,寫入2表(歷史表)。
如有特殊要處理的,可以增加業務邏輯通過ack模式處理,這裡ack預設值為0;
預設輪詢處理失敗一次ack自增1 。通用輪詢方法只掃ack預設為0或者1的。
Ack不等於0,1的,通過二次輪詢,第二個特殊輪詢業務處理。(減少通用輪詢的壓力,避免造成輪詢卡單。消息消費延緩等問題)。
如有特殊業務申請對應輪詢:需要申請ack預設值處理。比如特殊業務1,ack值設置100。(0-9不建議,給預設通用輪詢留下可用空間;
每次申請的特殊輪詢ack預設在原先基礎最大值上增加100,每次建立輪詢通過這個方案執行的ack都要走申請,避免ack重覆)。
六.實現類圖
方案一:
圖1.4 類圖
方案二:
圖1.5 類圖
以上類圖開發自行根據習慣可自行選用哪種模式。
如有更好的方式請留言指教,以上供參考。