NSH-PHP基于HTTP的高送達(dá)率異步通知服務(wù)

NSH-PHP（Notification service based on HTTP）是一個(gè)基于 HTTP 的高送達(dá)率異步通知服務(wù)。

使用場(chǎng)景

• 支付成功通知服務(wù)
• 多業(yè)務(wù)之間的高送達(dá)率類異步通知服務(wù)
• ...

比如A要將某個(gè)消息通知到B，但是又不想在通知的過程中對(duì)A的業(yè)務(wù)執(zhí)行造成阻塞，那么就可以將通知任務(wù)打包給專門的通知服務(wù)處理中心，由該中心執(zhí)行消息通知服務(wù)

安裝

1. 下載程序
2. composer install完成依賴安裝

啟動(dòng)服務(wù)

1. 打開config.php配置redis以及通知策略
2. 執(zhí)行php worker.php啟動(dòng)通知服務(wù)

發(fā)布任務(wù)

內(nèi)置了一個(gè)通過http post的方式提交任務(wù)的進(jìn)程，只需要執(zhí)行?php http_api.php?即可通過post的方式發(fā)布通知任務(wù)，另外您也可以根據(jù)自身情況通過其他方式發(fā)布任務(wù)，例如直接寫redis

注意，每發(fā)布一個(gè)任務(wù)，最好規(guī)定一個(gè)唯一標(biāo)識(shí)，參考http_api.php里面的uuid參數(shù)，方便做任務(wù)追蹤分析。也可以加入其它篩選條目方便做數(shù)據(jù)篩選分析。能很方便的實(shí)現(xiàn)統(tǒng)計(jì)分析來自不同客戶的的任務(wù)處理情況

curl post http://127.0.0.1:2345

url:http://xxx.com/path/to?foo=bar  通知地址
payload:somestring... 通知內(nèi)容
tactic:A 通知策略
time:15968576857 初次發(fā)起通知的時(shí)間 不填則默認(rèn)當(dāng)前時(shí)間

配置項(xiàng)說明

• fail_interval：通知失敗后再次發(fā)起通知的間隔秒數(shù)
• max_times：最大通知次數(shù)，失敗次數(shù)到達(dá)此次數(shù)則認(rèn)為目標(biāo)失活，會(huì)丟棄該條目的通知服務(wù)
• notify_rates：通知頻率，數(shù)組第一個(gè)表示當(dāng)前時(shí)間點(diǎn)的通知頻率，第二個(gè)表示當(dāng)前時(shí)間點(diǎn)上一秒的通知頻率，以此類推，通常當(dāng)前時(shí)間點(diǎn)就能把任務(wù)通知完畢，若任務(wù)較多，在當(dāng)前時(shí)間的任務(wù)未全部執(zhí)行，剩下的任務(wù)會(huì)跌落到上一個(gè)時(shí)間點(diǎn)，一般3-5個(gè)時(shí)間點(diǎn)比較合理
• clear_rate：若上面的所有時(shí)間點(diǎn)都沒有將任務(wù)執(zhí)行完畢，還有一個(gè)兜底的進(jìn)程，做清理工作，此處就是兜底進(jìn)程的執(zhí)行頻率
• clear_start：兜底進(jìn)程的清理時(shí)間點(diǎn)，通常是當(dāng)前時(shí)間的前面10分鐘基本能滿足需求，視具體情況而定，比如系統(tǒng)停止了一個(gè)小時(shí)，那么兜底時(shí)間最好填寫系統(tǒng)停止時(shí)間之前

上面的配置項(xiàng)通常需要結(jié)合服務(wù)器自身硬件配置和帶寬大小等等，若一個(gè)服務(wù)器無法完成通知服務(wù)，可以多開幾個(gè)服務(wù)器運(yùn)行此服務(wù)

運(yùn)維監(jiān)控

系統(tǒng)默認(rèn)是將通知日志記錄在日志文件里面，您可以通過簡(jiǎn)單的配置（見common.php里面的logger方法，monolog）將日志記錄到elastic，redis，mysql...等數(shù)十個(gè)平臺(tái)進(jìn)行運(yùn)維監(jiān)控