NSH-PHP基于HTTP的高送達率異步通知服務

NSH-PHP（Notification service based on HTTP）是一個基于 HTTP 的高送達率異步通知服務。

使用場景

• 支付成功通知服務
• 多業務之間的高送達率類異步通知服務
• ...

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

安裝

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

啟動服務

1. 打開config.php配置redis以及通知策略
2. 執行php worker.php啟動通知服務

發布任務

內置了一個通過http post的方式提交任務的進程，只需要執行?php http_api.php?即可通過post的方式發布通知任務，另外您也可以根據自身情況通過其他方式發布任務，例如直接寫redis

注意，每發布一個任務，最好規定一個唯一標識，參考http_api.php里面的uuid參數，方便做任務追蹤分析。也可以加入其它篩選條目方便做數據篩選分析。能很方便的實現統計分析來自不同客戶的的任務處理情況

curl post http://127.0.0.1:2345

url:http://xxx.com/path/to?foo=bar  通知地址
payload:somestring... 通知內容
tactic:A 通知策略
time:15968576857 初次發起通知的時間 不填則默認當前時間

配置項說明

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

上面的配置項通常需要結合服務器自身硬件配置和帶寬大小等等，若一個服務器無法完成通知服務，可以多開幾個服務器運行此服務

運維監控

系統默認是將通知日志記錄在日志文件里面，您可以通過簡單的配置（見common.php里面的logger方法，monolog）將日志記錄到elastic，redis，mysql...等數十個平臺進行運維監控