[發(fā)明專(zhuān)利]一種消息傳輸方法及裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 201810239137.0
• 申請(qǐng)日: 2018-03-22
• 公開(kāi)（公告）號(hào): CN110297707A
• 公開(kāi)（公告）日: 2019-10-01
• 發(fā)明（設(shè)計(jì)）人: 王貴喜
• 申請(qǐng)（專(zhuān)利權(quán)）人: 香港樂(lè)蜜有限公司
• 主分類(lèi)號(hào): G06F9/50
• 分類(lèi)號(hào): G06F9/50;H04L29/08;H04L29/06;H04L12/58
• 代理公司: 北京市廣友專(zhuān)利事務(wù)所有限責(zé)任公司 11237
• 代理人: 祁獻(xiàn)民

本發(fā)明實(shí)施例公開(kāi)一種消息傳輸方法及裝置，涉及通信技術(shù)領(lǐng)域，能夠有效提高消息傳輸效率。所述消息傳輸方法包括：通過(guò)多級(jí)線程接收源設(shè)備發(fā)送的消息，所述多級(jí)線程包括調(diào)度線程、工作線程、業(yè)務(wù)線程池；其中，所述調(diào)度線程用于接收所述源設(shè)備發(fā)送的消息并對(duì)所述消息進(jìn)行調(diào)度，以分配給不同的所述工作線程處理；所述工作線程用于根據(jù)所述調(diào)度線程的調(diào)度對(duì)消息進(jìn)行處理，并將預(yù)計(jì)處理時(shí)長(zhǎng)大于預(yù)設(shè)時(shí)間閾值的消息交由所述業(yè)務(wù)線程池處理；所述業(yè)務(wù)線程池中包括至少兩個(gè)業(yè)務(wù)線程，用于處理所述工作線程交給的消息處理任務(wù)；將接收到的消息向?qū)?yīng)的目的設(shè)備推送。本發(fā)明可用于基于業(yè)務(wù)的消息傳輸中。

技術(shù)領(lǐng)域

本發(fā)明涉及通信技術(shù)領(lǐng)域，尤其涉及一種消息傳輸方法及裝置。

背景技術(shù)

在視頻直播系統(tǒng)中，通常每秒鐘消息量達(dá)到百萬(wàn)條以上，單直播間消息量最大近幾十萬(wàn)條。如果按傳統(tǒng)的消息發(fā)送方式對(duì)海量用戶同時(shí)進(jìn)行消息推送，將產(chǎn)生較大的延遲，難以滿足高實(shí)時(shí)、強(qiáng)互動(dòng)的直播應(yīng)用場(chǎng)景的需求。

發(fā)明內(nèi)容

有鑒于此，本發(fā)明實(shí)施例提供一種消息傳輸方法及裝置，能夠有效提高消息傳輸效率。

第一方面，本發(fā)明實(shí)施例提供一種消息傳輸方法，包括：通過(guò)多級(jí)線程接收源設(shè)備發(fā)送的消息，所述多級(jí)線程包括調(diào)度線程、工作線程、業(yè)務(wù)線程池；所述調(diào)度線程用于接收所述源設(shè)備發(fā)送的消息并對(duì)所述消息進(jìn)行調(diào)度，以分配給不同的所述工作線程處理；所述工作線程用于根據(jù)所述調(diào)度線程的調(diào)度對(duì)消息進(jìn)行處理，并將預(yù)計(jì)處理時(shí)長(zhǎng)大于預(yù)設(shè)時(shí)間閾值的消息交由所述業(yè)務(wù)線程池處理；所述業(yè)務(wù)線程池中包括至少兩個(gè)業(yè)務(wù)線程，用于處理所述工作線程交給的消息處理任務(wù)；將接收到的消息向?qū)?yīng)的目的設(shè)備推送。

結(jié)合第一方面，在第一方面的第一種實(shí)施方式中，所述預(yù)計(jì)處理時(shí)長(zhǎng)大于預(yù)設(shè)時(shí)間閾值的消息包括以下至少一種：讀寫(xiě)存儲(chǔ)介質(zhì)的消息、調(diào)用第三方接口的消息、限流操作消息。

結(jié)合第一方面，在第一方面的第二種實(shí)施方式中，所述消息包括單聊消息、群聊消息和直播間消息中的至少一種。

結(jié)合第一方面或第一方面的第一至第二中任一種實(shí)施方式，在第一方面的第三種實(shí)施方式中，所述通過(guò)多級(jí)線程接收源設(shè)備發(fā)送的消息包括：服務(wù)器的接入服務(wù)部通過(guò)多級(jí)線程從所述源設(shè)備接收消息；所述服務(wù)器的業(yè)務(wù)服務(wù)部通過(guò)多級(jí)線程從所述接入服務(wù)部接收消息。

結(jié)合第一方面的第三種實(shí)施方式，在第一方面的第四種實(shí)施方式中，所述接入服務(wù)部包括即時(shí)通信接入服務(wù)部和/或直播間接入服務(wù)部；所述業(yè)務(wù)服務(wù)部包括單聊業(yè)務(wù)服務(wù)部、群聊業(yè)務(wù)服務(wù)部和直播間業(yè)務(wù)服務(wù)部中的至少一種。

結(jié)合第一方面的第三種實(shí)施方式，在第一方面的第五種實(shí)施方式中，所述服務(wù)器的接入服務(wù)部和業(yè)務(wù)服務(wù)部之間通過(guò)至少兩條通信線程連接，其中，所述通信線程的類(lèi)型包括長(zhǎng)連接類(lèi)型和/或短連接類(lèi)型。

結(jié)合第一方面或第一方面的第一至第二中任一種實(shí)施方式，在第一方面的第六種實(shí)施方式中，所述目的設(shè)備的數(shù)量為一個(gè)或多個(gè)；當(dāng)所述目的設(shè)備的數(shù)量為多個(gè)時(shí)，所述將接收到的消息向?qū)?yīng)的目的設(shè)備推送包括：將所述目的設(shè)備分為至少兩個(gè)設(shè)備組，其中每個(gè)設(shè)備組通過(guò)一個(gè)線程輪流向該設(shè)備組中的各所述目的設(shè)備推送所述消息。

第二方面，本發(fā)明的實(shí)施例還提供一種消息傳輸裝置，包括：接收單元，用于通過(guò)多級(jí)線程接收源設(shè)備發(fā)送的消息，所述多級(jí)線程包括調(diào)度線程、工作線程、業(yè)務(wù)線程池；其中，所述調(diào)度線程用于接收所述源設(shè)備發(fā)送的消息并對(duì)所述消息進(jìn)行調(diào)度，以分配給不同的所述工作線程處理；所述工作線程用于根據(jù)所述調(diào)度線程的調(diào)度對(duì)消息進(jìn)行處理，并將預(yù)計(jì)處理時(shí)長(zhǎng)大于預(yù)設(shè)時(shí)間閾值的消息交由所述業(yè)務(wù)線程池處理；所述業(yè)務(wù)線程池中包括至少兩個(gè)業(yè)務(wù)線程，用于處理所述工作線程交給的消息處理任務(wù)；推送單元，用于將所述接收單元接收到的消息向?qū)?yīng)的目的設(shè)備推送。

結(jié)合第二方面，在第二方面的第一種實(shí)施方式中，所述預(yù)計(jì)處理時(shí)長(zhǎng)大于預(yù)設(shè)時(shí)間閾值的消息包括以下至少一種：讀寫(xiě)存儲(chǔ)介質(zhì)的消息、調(diào)用第三方接口的消息、限流操作消息。