[發(fā)明專利]一種結(jié)合workerman的計(jì)劃任務(wù)消息隊(duì)列php實(shí)現(xiàn)方法

在審

• 申請?zhí)枺?/td>: 202110356732.4
• 申請日: 2021-04-01
• 公開（公告）號: CN113051089A
• 公開（公告）日: 2021-06-29
• 發(fā)明（設(shè)計(jì)）人: 王小合
• 申請（專利權(quán)）人: 深圳市特游網(wǎng)文化技術(shù)有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 深圳市查策知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 44527
• 代理人: 曾令安

1.一種結(jié)合workerman的計(jì)劃任務(wù)消息隊(duì)列php實(shí)現(xiàn)方法，其特征在于：所述結(jié)合workerman的計(jì)劃任務(wù)消息隊(duì)列php的實(shí)現(xiàn)方法，包括以下步驟：

Step1：引入workerman提供后端進(jìn)程服務(wù)及定時(shí)器服務(wù)；

Step2：編寫“生產(chǎn)者”邏輯代碼，創(chuàng)建“計(jì)劃集合”、“計(jì)劃隊(duì)列”和“任務(wù)隊(duì)列”；

Step3：編寫“調(diào)度者”邏輯代碼，創(chuàng)建調(diào)度者定時(shí)器；

Step4：編寫“消費(fèi)者”邏輯代碼，創(chuàng)建消費(fèi)者定時(shí)器；

Step5：消費(fèi)者定時(shí)器中引入workerman http異步組件，實(shí)現(xiàn)遠(yuǎn)程任務(wù)調(diào)度；

Step6：編寫“任務(wù)失敗重試”、“任務(wù)計(jì)劃清除”等功能；

Step7：實(shí)現(xiàn)結(jié)合workerman的計(jì)劃任務(wù)消息隊(duì)列php。

2.根據(jù)權(quán)利要求1所述的一種結(jié)合workerman的計(jì)劃任務(wù)消息隊(duì)列php實(shí)現(xiàn)方法，其特征在于，所述消息隊(duì)列服務(wù)由“計(jì)劃消息集合”、“計(jì)劃消息隊(duì)列”和“任務(wù)消息隊(duì)列”二種數(shù)據(jù)結(jié)構(gòu)組合實(shí)現(xiàn)。

3.根據(jù)權(quán)利要求1所述的一種結(jié)合workerman的計(jì)劃任務(wù)消息隊(duì)列php實(shí)現(xiàn)方法，其特征在于，所述系統(tǒng)主要由4部分組成，分別包括生產(chǎn)者、調(diào)度者、消費(fèi)者和消息隊(duì)列。

4.根據(jù)權(quán)利要求3所述的一種結(jié)合workerman的計(jì)劃任務(wù)消息隊(duì)列php實(shí)現(xiàn)方法，其特征在于，所述Step2中，生產(chǎn)者：客戶端發(fā)送消息，延時(shí)消息推送到“計(jì)劃集合”及“計(jì)劃隊(duì)列”，實(shí)時(shí)消息則發(fā)送到“任務(wù)隊(duì)列”。

5.根據(jù)權(quán)利要求4所述的一種結(jié)合workerman的計(jì)劃任務(wù)消息隊(duì)列php實(shí)現(xiàn)方法，其特征在于，所述Step3中，調(diào)度者：由workerman定時(shí)器1循環(huán)檢測“計(jì)劃集合”中消息時(shí)間，判斷是否將對應(yīng)“計(jì)劃隊(duì)列”消息壓入“任務(wù)隊(duì)列”。

6.根據(jù)權(quán)利要求5所述的一種結(jié)合workerman的計(jì)劃任務(wù)消息隊(duì)列php實(shí)現(xiàn)方法，其特征在于，所述Step4中，消費(fèi)者：由workerman定時(shí)器2循環(huán)檢測“任務(wù)隊(duì)列”，并循環(huán)彈出“任務(wù)”內(nèi)容，執(zhí)行任務(wù)(業(yè)務(wù)邏輯)處理。

7.根據(jù)權(quán)利要求6所述的一種結(jié)合workerman的計(jì)劃任務(wù)消息隊(duì)列php實(shí)現(xiàn)方法，其特征在于，所述Step7中消息隊(duì)列是用于存儲(chǔ)消息的容器，本方案以redis實(shí)現(xiàn)作為消息存儲(chǔ)容器。