短連接給用戶推消息方案

fantasmic 2023-08-08

問題描述

用戶請求接口開啟推送任務(wù)，服務(wù)端收到后回調(diào)用戶地址推送消息（不用長連接）
用戶請求接口停止推送任務(wù)，服務(wù)端收到后停止回調(diào)用戶地址
用戶有幾十上百，是用定時(shí)器還是其他方法呢？
如果用定時(shí)器停止時(shí)如果和定時(shí)器不在同個(gè)進(jìn)程只憑定時(shí)器ID能否刪除定時(shí)器？

為此你搜索到了哪些方案及不適用的原因

暫無

 822  2 0

2個(gè)回答

efnic 2023-08-08

這種方式不適合用定時(shí)器；
安裝webman的隊(duì)列和異步HTTP客戶端；把需要回調(diào)的任務(wù)投入隊(duì)列，由隊(duì)列去消費(fèi) 回調(diào)用戶地址；
當(dāng)用戶停止推送任務(wù)時(shí)，停止向隊(duì)列投遞任務(wù)，停止回調(diào)用戶地址；

暫無評論

chaz6chez 2023-08-08

推薦消費(fèi)隊(duì)列；redis、redis-stream、rabbitmq都可以；

開啟關(guān)閉接口會(huì)將數(shù)據(jù)庫或者配置中某個(gè)key改為開啟或者關(guān)閉；
生產(chǎn)者發(fā)布前判斷該key是否開啟，開啟的話投入隊(duì)列；
消費(fèi)者消費(fèi)前判斷該key是否開啟，關(guān)閉的話，則跳過消費(fèi)邏輯，將消息ack；

fantasmic 2023-08-09

開啟任務(wù)后用循環(huán)推送嗎。如果停止任務(wù)怎么將循環(huán)停止
efnic 2023-08-09

是用隊(duì)列http://www.wtbis.cn/plugin/12
消費(fèi)者去消費(fèi)隊(duì)列（回調(diào)用戶地址）
fantasmic 2023-08-09

看了下有個(gè)疑問，多個(gè)用戶的消息只能在一個(gè)隊(duì)列下消費(fèi)嗎？（指的是動(dòng)態(tài)隊(duì)列的消費(fèi)）
fantasmic 2023-08-09

提示
消費(fèi)進(jìn)程可以同時(shí)消費(fèi)多種不同的隊(duì)列，新增隊(duì)列不需要修改process.php中的配置，新增隊(duì)列消費(fèi)者時(shí)只需要在app/queue/redis下新增對應(yīng)的Consumer類即可，并用類屬性$queue指定要消費(fèi)的隊(duì)列名

文檔的消費(fèi)多種隊(duì)列是事先寫死的，我想要投遞時(shí)A、B、C...隊(duì)列，消費(fèi)時(shí)消費(fèi)對應(yīng)的隊(duì)列
chaz6chez 2023-08-09

http://www.wtbis.cn/plugin/69
http://www.wtbis.cn/plugin/67
可以看一下這兩個(gè)隊(duì)列
當(dāng)然http://www.wtbis.cn/plugin/67的2.0還是beta，暫時(shí)還沒做完整的測試用例
chaz6chez 2023-08-09

另外，你說的這個(gè)場景，和我的 http://www.wtbis.cn/plugin/102 這個(gè)插件中的HookServer場景是一樣的，你可以clone下來參考一下，我是通過隊(duì)列消費(fèi)來進(jìn)行處理的