[發(fā)明專利]延遲消息推送方法、裝置、計(jì)算機(jī)設(shè)備及存儲介質(zhì)有效
| 申請?zhí)枺?/td> | 201810138032.6 | 申請日: | 2018-02-10 |
| 公開(公告)號: | CN108388479B | 公開(公告)日: | 2021-09-24 |
| 發(fā)明(設(shè)計(jì))人: | 周之浩 | 申請(專利權(quán))人: | 深圳壹賬通智能科技有限公司 |
| 主分類號: | G06F9/54 | 分類號: | G06F9/54 |
| 代理公司: | 深圳眾鼎專利商標(biāo)代理事務(wù)所(普通合伙) 44325 | 代理人: | 陽開亮 |
| 地址: | 518000 廣東省深圳市前海深港合作區(qū)前*** | 國省代碼: | 廣東;44 |
| 權(quán)利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關(guān)鍵詞: | 延遲 消息 推送 方法 裝置 計(jì)算機(jī) 設(shè)備 存儲 介質(zhì) | ||
本發(fā)明公開一種延遲消息推送方法、裝置、計(jì)算機(jī)設(shè)備及存儲介質(zhì)。該延遲消息推送方法包括:獲取待推送消息,所述待推送消息包括消息類型和消息模板;基于所述消息類型,將所述待推送消息緩存在與所述消息類型相對應(yīng)的目標(biāo)消息中間件上;根據(jù)所述消息模板確定所述待推送消息是否為延遲消息,若所述待推送消息為所述延遲消息,則將所述待推送消息緩存在所述目標(biāo)消息中間件上創(chuàng)建的延遲隊(duì)列上;采用監(jiān)聽線程輪詢監(jiān)聽所述延遲隊(duì)列,并對所述延遲隊(duì)列中緩存的待推送消息進(jìn)行推送處理。該延遲消息推送方法可有效提高延遲消息推送處理的效率,降低存儲空間的壓力,并保證消息處理的時(shí)效性。
技術(shù)領(lǐng)域
本發(fā)明涉及信息處理領(lǐng)域,尤其涉及一種延遲消息推送方法、裝置、計(jì)算機(jī)設(shè)備及存儲介質(zhì)。
背景技術(shù)
當(dāng)前消息推送平臺向特定用戶發(fā)送消息時(shí),可以發(fā)送實(shí)時(shí)消息也可以發(fā)送延遲消息。其中,實(shí)時(shí)消息是指消息形成之后即可被發(fā)送給特定用戶,以使特定用戶可實(shí)時(shí)獲取到的消息;相應(yīng)地,延遲消息是指消息形成之后,若處于免打擾時(shí)間段內(nèi)則暫停發(fā)送,直到處于非免打擾時(shí)間之后才發(fā)送,使得特定用戶獲取的消息。當(dāng)前延遲消息的發(fā)送完全依賴于數(shù)據(jù)庫,當(dāng)延遲消息處于免打擾時(shí)間段內(nèi),則需將該延遲消息存儲在數(shù)據(jù)庫中,數(shù)據(jù)庫集群中的每一機(jī)器都會起一個(gè)線程去搶占數(shù)據(jù)庫中的延遲消息并逐條處理,對數(shù)據(jù)庫的存儲空間造成巨大壓力,且增加線程資源的消耗。而且,隨著時(shí)間的推移,數(shù)據(jù)庫中的延遲消息不斷增加,導(dǎo)致對數(shù)據(jù)庫的存儲空間需求不斷增加,還需增加人工定期清理延遲消息,以完成數(shù)據(jù)庫中存儲空間的回收工作,導(dǎo)致成本增加。
發(fā)明內(nèi)容
本發(fā)明實(shí)施例提供一種延遲消息推送方法、裝置、計(jì)算機(jī)設(shè)備及存儲介質(zhì),以解決當(dāng)前延遲消息推送過程造成線程資源消耗較大的問題。
第一方面,本發(fā)明實(shí)施例提供一種延遲消息推送方法,包括:
獲取待推送消息,所述待推送消息包括消息類型和消息模板;
基于所述消息類型,將所述待推送消息緩存在與所述消息類型相對應(yīng)的目標(biāo)消息中間件上;
根據(jù)所述消息模板確定所述待推送消息是否為延遲消息,若所述待推送消息為所述延遲消息,則將所述待推送消息緩存在所述目標(biāo)消息中間件上創(chuàng)建的延遲隊(duì)列上;
采用監(jiān)聽線程輪詢監(jiān)聽所述延遲隊(duì)列,并對所述延遲隊(duì)列中緩存的待推送消息進(jìn)行推送處理。
第二方面,本發(fā)明實(shí)施例提供一種延遲消息推送裝置,包括:
消息獲取模塊,用于獲取待推送消息,所述待推送消息包括消息類型和消息模板;
消息緩存模板,用于基于所述消息類型,將所述待推送消息緩存在與所述消息類型相對應(yīng)的目標(biāo)消息中間件上;
延遲判斷處理模塊,用于根據(jù)所述消息模板確定所述待推送消息是否為延遲消息,若所述待推送消息為所述延遲消息,則將所述待推送消息緩存在所述目標(biāo)消息中間件上創(chuàng)建的延遲隊(duì)列上;
監(jiān)聽處理模塊,用于采用監(jiān)聽線程輪詢監(jiān)聽所述延遲隊(duì)列,并對所述延遲隊(duì)列中緩存的待推送消息進(jìn)行推送處理。
第三方面,本發(fā)明實(shí)施例提供一種計(jì)算機(jī)設(shè)備,包括存儲器、處理器以及存儲在所述存儲器中并可在所述處理器上運(yùn)行的計(jì)算機(jī)程序,所述處理器執(zhí)行所述計(jì)算機(jī)程序時(shí)實(shí)現(xiàn)如所述延遲消息推送方法的步驟。
第四方面,本發(fā)明實(shí)施例提供一種計(jì)算機(jī)可讀存儲介質(zhì),所述計(jì)算機(jī)可讀存儲介質(zhì)存儲有計(jì)算機(jī)程序,所述計(jì)算機(jī)程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)所述延遲消息推送方法的步驟。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息,商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于深圳壹賬通智能科技有限公司,未經(jīng)深圳壹賬通智能科技有限公司許可,擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作,請聯(lián)系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/201810138032.6/2.html,轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。





