[發(fā)明專利]一種消息傳輸方法和裝置有效
| 申請?zhí)枺?/td> | 201711472720.8 | 申請日: | 2017-12-29 |
| 公開(公告)號: | CN109995801B | 公開(公告)日: | 2022-11-08 |
| 發(fā)明(設(shè)計)人: | 程曉明 | 申請(專利權(quán))人: | 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司 |
| 主分類號: | H04L67/568 | 分類號: | H04L67/568;H04L67/146;G06F9/54 |
| 代理公司: | 中原信達(dá)知識產(chǎn)權(quán)代理有限責(zé)任公司 11219 | 代理人: | 張一軍;楊曉偉 |
| 地址: | 100195 北京市海淀區(qū)杏石口路6*** | 國省代碼: | 北京;11 |
| 權(quán)利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關(guān)鍵詞: | 一種 消息 傳輸 方法 裝置 | ||
1.一種消息傳輸方法,其特征在于,包括:
消息隊列接收來自消費(fèi)者的多個消費(fèi)標(biāo)識;其中,所述消費(fèi)標(biāo)識包括消息類型;
所述消息隊列確認(rèn)存在與所述消費(fèi)標(biāo)識相對應(yīng)的存儲隊列時,獲取與所述消息類型相同的消息,然后將所述消息存入所述存儲隊列中;
所述消息隊列輸出所述存儲隊列中的消息;其中,當(dāng)各所述消費(fèi)標(biāo)識均相同時將所述消息隨機(jī)輸出至與所述存儲隊列相對應(yīng)的消費(fèi)者中的一個;當(dāng)各所述消費(fèi)標(biāo)識存在不同時將各所述存儲隊列中的消息分別輸出至與各所述存儲隊列相對應(yīng)的消費(fèi)者;
其中,所述確認(rèn)存在與所述消費(fèi)標(biāo)識相對應(yīng)的存儲隊列時,獲取與所述消息類型相同的消息,然后將所述消息存入所述存儲隊列中,包括:
確認(rèn)各所述消費(fèi)標(biāo)識均相同并且存在與所述消費(fèi)標(biāo)識相對應(yīng)的存儲隊列時,從存儲器獲取與所述消息類型相同的消息,然后將所述消息存入所述存儲隊列中;
確認(rèn)各所述消費(fèi)標(biāo)識存在不同并且存在與各所述消費(fèi)標(biāo)識相對應(yīng)的存儲隊列時,從存儲器分別獲取與各所述消息類型相同的消息,然后將所述消息分別存入各所述存儲隊列中。
2.根據(jù)權(quán)利要求1所述的方法,其特征在于,所述輸出所述存儲隊列中的消息的步驟之后,還包括:確認(rèn)與所述消費(fèi)標(biāo)識相對應(yīng)的存儲隊列沒有消費(fèi)者連接時,銷毀所述存儲隊列。
3.一種消息傳輸裝置,其特征在于,由消息隊列執(zhí)行,包括:
接收模塊,用于接收來自消費(fèi)者的多個消費(fèi)標(biāo)識;其中,所述消費(fèi)標(biāo)識包括消息類型;
存儲模塊,用于確認(rèn)存在與所述消費(fèi)標(biāo)識相對應(yīng)的存儲隊列時,獲取與所述消息類型相同的消息,然后將所述消息存入所述存儲隊列中;
輸出模塊,用于輸出所述存儲隊列中的消息;其中,當(dāng)各所述消費(fèi)標(biāo)識均相同時將所述消息隨機(jī)輸出至與所述存儲隊列相對應(yīng)的消費(fèi)者中的一個;當(dāng)各所述消費(fèi)標(biāo)識存在不同時將各所述存儲隊列中的消息分別輸出至與各所述存儲隊列相對應(yīng)的消費(fèi)者;
其中,所述確認(rèn)存在與所述消費(fèi)標(biāo)識相對應(yīng)的存儲隊列時,獲取與所述消息類型相同的消息,然后將所述消息存入所述存儲隊列中,包括:
確認(rèn)各所述消費(fèi)標(biāo)識均相同并且存在與所述消費(fèi)標(biāo)識相對應(yīng)的存儲隊列時,從存儲器獲取與所述消息類型相同的消息,然后將所述消息存入所述存儲隊列中;
確認(rèn)各所述消費(fèi)標(biāo)識存在不同并且存在與各所述消費(fèi)標(biāo)識相對應(yīng)的存儲隊列時,從存儲器分別獲取與各所述消息類型相同的消息,然后將所述消息分別存入各所述存儲隊列中。
4.根據(jù)權(quán)利要求3所述的裝置,其特征在于,所述裝置還包括:銷毀模塊,用于確認(rèn)與所述消費(fèi)標(biāo)識相對應(yīng)的存儲隊列沒有消費(fèi)者連接時,銷毀所述存儲隊列。
5.一種電子設(shè)備,其特征在于,包括:
一個或多個處理器;
存儲裝置,用于存儲一個或多個程序,
當(dāng)所述一個或多個程序被所述一個或多個處理器執(zhí)行,使得所述一個或多個處理器實(shí)現(xiàn)如權(quán)利要求1或2所述的方法。
6.一種計算機(jī)可讀介質(zhì),其上存儲有計算機(jī)程序,其特征在于,所述程序被處理器執(zhí)行時實(shí)現(xiàn)如權(quán)利要求1或2所述的方法。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息,商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司,未經(jīng)北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司許可,擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作,請聯(lián)系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/201711472720.8/1.html,轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。





