[發(fā)明專利]消息中繼、交互方法及相應(yīng)的裝置、設(shè)備、介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202110043491.8
• 申請(qǐng)日: 2021-01-13
• 公開(kāi)（公告）號(hào): CN112804329A
• 公開(kāi)（公告）日: 2021-05-14
• 發(fā)明（設(shè)計(jì)）人: 蔡鵬
• 申請(qǐng)（專利權(quán)）人: 廣州華多網(wǎng)絡(luò)科技有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08;H04L29/06;G06F16/953;G06F9/54
• 代理公司: 廣州利能知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 44673
• 代理人: 王增鑫

本申請(qǐng)公開(kāi)一種消息中繼、交互方法及相應(yīng)的裝置、設(shè)備、介質(zhì)，所述方法包括：從供中臺(tái)調(diào)用的第一發(fā)送接口獲取其發(fā)送給目標(biāo)前臺(tái)的第一消息，存儲(chǔ)所述第一消息；查找所述目標(biāo)前臺(tái)在本機(jī)預(yù)注冊(cè)的服務(wù)接口，將所述第一消息推送至該服務(wù)接口，在第一消息被目標(biāo)前臺(tái)消費(fèi)后標(biāo)記該第一消息已被消費(fèi)；從供前臺(tái)調(diào)用的第二發(fā)送接口獲取任意前臺(tái)發(fā)送給中臺(tái)的第二消息，解析出相對(duì)應(yīng)的消息來(lái)源所屬的來(lái)源前臺(tái)；將第二消息關(guān)聯(lián)該來(lái)源前臺(tái)推送至所述中臺(tái)，以供該中臺(tái)消費(fèi)該第二消息并標(biāo)記其已被消費(fèi)。本申請(qǐng)網(wǎng)關(guān)實(shí)現(xiàn)前臺(tái)與中臺(tái)之間的消息交互，為中臺(tái)及前臺(tái)提供高適應(yīng)性及輕量化的信息中繼服務(wù)能力。

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

本申請(qǐng)屬于互聯(lián)網(wǎng)技術(shù)領(lǐng)域，具體涉及一種中間組件條件匹配執(zhí)行方法，及其相應(yīng)的裝置、電子設(shè)備、非易失性存儲(chǔ)介質(zhì)。

背景技術(shù)

在電商平臺(tái)的發(fā)展過(guò)程中，大中臺(tái)小前臺(tái)的設(shè)計(jì)理念逐漸成為主流，為了解決一些業(yè)務(wù)場(chǎng)景，例如用戶積分變更，需要使用到消息中間件的異步通知機(jī)制，目前常用的解決方案是：前臺(tái)、中臺(tái)共用一個(gè)消息服務(wù)，然后消息通知方注冊(cè)消息生產(chǎn)者，消息被通知方注冊(cè)消息消費(fèi)者，從而完成消息通信。由此帶來(lái)的問(wèn)題是，中臺(tái)與前臺(tái)需要各自維護(hù)用于維持雙方通信所需的消息生產(chǎn)者和消息消費(fèi)者，而一個(gè)中臺(tái)往往同時(shí)對(duì)接多個(gè)前臺(tái)，如果中臺(tái)需要通知前臺(tái)，那么每個(gè)前臺(tái)消息生產(chǎn)者，中臺(tái)都需要維護(hù)一個(gè)消息消費(fèi)者，反之亦然，這種實(shí)現(xiàn)方案的缺點(diǎn)有：

首先，中臺(tái)與前臺(tái)共用同一個(gè)消息服務(wù)，這對(duì)中臺(tái)及前臺(tái)的網(wǎng)絡(luò)條件要求比較高，且一個(gè)中臺(tái)如果需要接收前臺(tái)消息，需要維護(hù)多個(gè)消息消費(fèi)者，這對(duì)中臺(tái)的應(yīng)用系統(tǒng)壓力很大。

其次，若每個(gè)前臺(tái)都需要跟中臺(tái)單獨(dú)對(duì)接，開(kāi)發(fā)及維護(hù)成本會(huì)隨著前臺(tái)的數(shù)量逐步提高。

再者，因?yàn)橄⒅虚g件無(wú)鑒權(quán)模塊，各個(gè)前臺(tái)之間的數(shù)據(jù)無(wú)法隔離，各個(gè)前臺(tái)及中臺(tái)的數(shù)據(jù)安全性無(wú)法保證。

針對(duì)現(xiàn)有技術(shù)中前臺(tái)與中臺(tái)消息交互所存在的各種問(wèn)題，有必要探索一些行之有效的解決方案。

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

鑒于現(xiàn)有技術(shù)所存在的不足，本申請(qǐng)的首要目的在于為網(wǎng)關(guān)系統(tǒng)提供一種消息中繼方法及其相應(yīng)的裝置、電子設(shè)備、非易失性存儲(chǔ)介質(zhì)。

本申請(qǐng)的另一目的在于適應(yīng)首要目的而為中臺(tái)系統(tǒng)提供一種消息交互方法及其相應(yīng)的裝置、電子設(shè)備、非易失性存儲(chǔ)介質(zhì)。

本申請(qǐng)的再一目的在于適應(yīng)首要目的而為前臺(tái)系統(tǒng)提供一種消息交互方法及其相應(yīng)的裝置、電子設(shè)備、非易失性存儲(chǔ)介質(zhì)。

為滿足本申請(qǐng)的各個(gè)目的，本申請(qǐng)采用如下技術(shù)方案：

適應(yīng)本申請(qǐng)的目的之一而提供的一種消息中繼方法，其包括如下步驟：

從供中臺(tái)調(diào)用的第一發(fā)送接口獲取其發(fā)送給目標(biāo)前臺(tái)的第一消息，存儲(chǔ)所述第一消息；

查找所述目標(biāo)前臺(tái)在本機(jī)預(yù)注冊(cè)的服務(wù)接口，將所述第一消息推送至該服務(wù)接口，在第一消息被目標(biāo)前臺(tái)消費(fèi)后標(biāo)記該第一消息已被消費(fèi)；

從供前臺(tái)調(diào)用的第二發(fā)送接口獲取任意前臺(tái)發(fā)送給中臺(tái)的第二消息，解析出相對(duì)應(yīng)的消息來(lái)源所屬的來(lái)源前臺(tái)；

將第二消息關(guān)聯(lián)該來(lái)源前臺(tái)推送至所述中臺(tái)，以供該中臺(tái)消費(fèi)該第二消息并標(biāo)記其已被消費(fèi)。

進(jìn)一步的實(shí)施例中，還包括如下步驟：

響應(yīng)任意前臺(tái)的未讀消息查詢請(qǐng)求，解析出該請(qǐng)求所屬的來(lái)源前臺(tái)；

查詢與該來(lái)源前臺(tái)相對(duì)應(yīng)的非已被消費(fèi)的所述第一消息，推送給該來(lái)源前臺(tái)；

在該來(lái)源前臺(tái)返回表示調(diào)用成功的通知后，標(biāo)記被推送的所述第一消息為已被消費(fèi)。

進(jìn)一步的實(shí)施例中，其包括如下步驟：