延遲消息隊(duì)列實(shí)現(xiàn)方法以及系統(tǒng)
基本信息
| 申請(qǐng)?zhí)?/td> | CN201911295794.8 | 申請(qǐng)日 | - |
| 公開(kāi)（公告）號(hào) | CN111045806A | 公開(kāi)（公告）日 | 2020-04-21 |
| 申請(qǐng)公布號(hào) | CN111045806A | 申請(qǐng)公布日 | 2020-04-21 |
| 分類(lèi)號(hào) | G06F9/48 | 分類(lèi) | 計(jì)算；推算；計(jì)數(shù); |
| 發(fā)明人 | 佘萬(wàn)衛(wèi) | 申請(qǐng)（專(zhuān)利權(quán)）人 | 云南優(yōu)鳥(niǎo)科技有限公司 |
| 代理機(jī)構(gòu) | - | 代理人 | - |
| 地址 | 650000 云南省昆明市五華區(qū)北市區(qū)煙草二號(hào)路北段東側(cè)寧康園小區(qū)6幢4單元102室 | ||
| 法律狀態(tài) | - | ||
摘要
| 摘要 | 本發(fā)明公開(kāi)了一種延遲消息隊(duì)列實(shí)現(xiàn)方法以及系統(tǒng)，包括：S101、在緩存服務(wù)器上預(yù)先創(chuàng)建一有序集合；S102、業(yè)務(wù)流程發(fā)送延遲消息至延遲消息模塊，其中，所述延遲消息包括業(yè)務(wù)數(shù)據(jù)以及定時(shí)執(zhí)行時(shí)間；S103、所述延遲消息模塊將所述延遲消息保存至緩存服務(wù)器的有序集合中，所述緩存服務(wù)器根據(jù)時(shí)間戳進(jìn)行升序排序；S104、所述延遲消息模塊每隔一預(yù)定時(shí)間至所述緩存服務(wù)器上獲取與當(dāng)前時(shí)間的時(shí)間戳相等的業(yè)務(wù)數(shù)據(jù)；S105、若獲取到所述業(yè)務(wù)數(shù)據(jù)，則將獲取到的數(shù)據(jù)進(jìn)行處理，將處理后的業(yè)務(wù)數(shù)據(jù)發(fā)送至消息隊(duì)列中；S106、消息隊(duì)列收到消息后，將消息投遞至定時(shí)任務(wù)執(zhí)行模塊；S107、定時(shí)任務(wù)執(zhí)行模塊啟動(dòng)線程進(jìn)行定時(shí)任務(wù)的執(zhí)行。 |
