對(duì)異步通知的定位,是作為核心業(yè)務(wù)的一種補(bǔ)充,應(yīng)該盡量與核心業(yè)務(wù)解耦。
采用的解耦方式為“事件+監(jiān)聽(tīng)器”。一些主流的php web框架,如laravel、yii2對(duì)“事件+監(jiān)聽(tīng)器”的支持是“開(kāi)箱即用”的,只需寫(xiě)少量的代碼(通常是增加一些配置項(xiàng))即可。
這里描述的設(shè)計(jì)思想是“解耦”,是和語(yǔ)言無(wú)關(guān)的,屬于“設(shè)計(jì)模式”的范疇。
概念
事件
業(yè)務(wù)系統(tǒng)在某個(gè)時(shí)機(jī)觸發(fā)事件,例如訂單發(fā)貨了,這時(shí)需要觸發(fā)一個(gè)“訂單已發(fā)貨”事件。事件攜帶了與異步通知相關(guān)的數(shù)據(jù),如用戶信息、訂單信息等,這些數(shù)據(jù)用于創(chuàng)建異步通知任務(wù)。
監(jiān)聽(tīng)器
監(jiān)聽(tīng)器負(fù)責(zé)捕捉事件并創(chuàng)建相關(guān)的異步通知任務(wù)。
異步通知任務(wù)
異步通知任務(wù)應(yīng)有以下的屬性
- 接收人
- 通知內(nèi)容
- 發(fā)送時(shí)間
- 發(fā)送狀態(tài)
異步通知任務(wù)應(yīng)帶有“鎖”機(jī)制,在并發(fā)場(chǎng)景下也可保證同一個(gè)通知不會(huì)被多次發(fā)送給用戶。
異步通知的發(fā)送時(shí)間應(yīng)是可配置的,以應(yīng)對(duì)需求的變化。
過(guò)濾器
過(guò)濾器用于攔截不需要發(fā)送的通知。
有一種場(chǎng)景:用戶注冊(cè)后n天內(nèi)不下單則發(fā)送召回通知。這種場(chǎng)景需要在用戶注冊(cè)時(shí)觸發(fā)事件,監(jiān)聽(tīng)器捕獲并創(chuàng)建發(fā)送時(shí)間為n天后的通知任務(wù)。如果用戶在n天內(nèi)下單了,則這個(gè)通知就不應(yīng)該發(fā)送。
這個(gè)通知對(duì)應(yīng)的過(guò)濾器就應(yīng)該檢查從通知的創(chuàng)建時(shí)間到發(fā)送時(shí)間內(nèi),用戶有沒(méi)有下單。
實(shí)現(xiàn)
工廠+配置+后臺(tái)進(jìn)程
配置
配置包括以下內(nèi)容
- 事件對(duì)應(yīng)的通知節(jié)點(diǎn)
- 通知節(jié)點(diǎn)的發(fā)送時(shí)間
工廠
工廠的職責(zé)
- 創(chuàng)建通知任務(wù)
- 實(shí)例化通知任務(wù)
后臺(tái)進(jìn)程
后臺(tái)進(jìn)程讀取待發(fā)送的通知,將通知發(fā)送給用戶,并更新通知發(fā)送狀態(tài)
擴(kuò)展
當(dāng)新需求到來(lái)時(shí),如當(dāng)用戶關(guān)注的商品降價(jià)時(shí)發(fā)送一條通知,只需在業(yè)務(wù)代碼中觸發(fā)一個(gè)“商品降價(jià)事件”,增加相關(guān)的配置和通知節(jié)點(diǎn),即可滿足需求。
不足
容易看出,這種設(shè)計(jì)思想會(huì)導(dǎo)致業(yè)務(wù)中的事件越來(lái)越多。但為了不侵入核心業(yè)務(wù)代碼,是否可以容忍這個(gè)不足之處?