[發(fā)明專利]消息處理方法、裝置、設(shè)備和存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202010355532.2
• 申請(qǐng)日: 2020-04-29
• 公開（公告）號(hào): CN111552907A
• 公開（公告）日: 2020-08-18
• 發(fā)明（設(shè)計(jì)）人: 王浩;肇文兵;周滋明;金鑫;李新;黎健
• 申請(qǐng)（專利權(quán)）人: 成都新致云服信息技術(shù)有限公司
• 主分類號(hào): G06F16/958
• 分類號(hào): G06F16/958
• 代理公司: 北京超凡宏宇專利代理事務(wù)所(特殊普通合伙) 11463
• 代理人: 鐘揚(yáng)飛

本申請(qǐng)?zhí)峁┮环N消息處理方法、裝置、設(shè)備和存儲(chǔ)介質(zhì)，方法包括：接收生產(chǎn)終端發(fā)送的消息請(qǐng)求，所述消息請(qǐng)求中包括消息體；解析所述消息請(qǐng)求，并根據(jù)解析結(jié)果，獲取對(duì)應(yīng)于所述消息請(qǐng)求的訂閱信息；根據(jù)所述訂閱信息，發(fā)送所述消息體至所述訂閱信息指定的消費(fèi)終端。本申請(qǐng)實(shí)現(xiàn)了在生產(chǎn)終端和消費(fèi)終端之間的消息自動(dòng)轉(zhuǎn)發(fā)功能，保障了消息傳遞的完整性。

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

本申請(qǐng)涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，具體而言，涉及一種消息處理方法、裝置、設(shè)備和存儲(chǔ)介質(zhì)。

背景技術(shù)

隨著信息技術(shù)的飛速發(fā)展，數(shù)據(jù)信息傳輸量日益增長(zhǎng)。消息解決方案集成程度越來(lái)越高，數(shù)據(jù)服務(wù)系統(tǒng)越來(lái)越龐大。膨脹的數(shù)據(jù)業(yè)務(wù)體系增加了服務(wù)器系統(tǒng)維護(hù)成本，也降低了系統(tǒng)執(zhí)行效率，隨之而來(lái)的還有一些性能和安全性問(wèn)題。為了解決上述問(wèn)題，提出了解耦方案。即將一個(gè)龐大的數(shù)據(jù)業(yè)務(wù)服務(wù)系統(tǒng)解耦成許多個(gè)數(shù)據(jù)服務(wù)器子系統(tǒng)，各個(gè)子系統(tǒng)之間爭(zhēng)取做到高內(nèi)聚低耦合。

由于不同的數(shù)據(jù)服務(wù)器一般會(huì)有不同的消息傳遞方式，因此服務(wù)器與服務(wù)器之間一般采用異步通訊的方式進(jìn)行消息傳遞。比如使用異步線程技術(shù)，通訊發(fā)起端組裝好報(bào)文和URI后，通過(guò)開啟異步線程實(shí)現(xiàn)RPC(Remote Procedure Call，遠(yuǎn)程過(guò)程調(diào)用)調(diào)用。

但是，單純運(yùn)用異步線程技術(shù)實(shí)現(xiàn)異步通訊，往往會(huì)存在線程丟失的情況，無(wú)法保障通訊的完整性。并且異步線程使得服務(wù)器與服務(wù)器之間關(guān)系緊密，很難做到相互解耦，不利于全局監(jiān)控通訊過(guò)程的安全性和健壯性。

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

本申請(qǐng)實(shí)施例的目的在于提供一種消息處理方法、裝置、設(shè)備和存儲(chǔ)介質(zhì)，用以實(shí)現(xiàn)對(duì)來(lái)自生產(chǎn)終端的消息請(qǐng)求進(jìn)行解析處理，并根據(jù)解析結(jié)果和用戶的訂閱信息，將消息體發(fā)送至指定的消費(fèi)終端。

本申請(qǐng)實(shí)施例第一方面提供了一種消息處理方法，包括：接收生產(chǎn)終端發(fā)送的消息請(qǐng)求，所述消息請(qǐng)求中包括消息體；解析所述消息請(qǐng)求，并根據(jù)解析結(jié)果，獲取對(duì)應(yīng)于所述消息請(qǐng)求的訂閱信息；根據(jù)所述訂閱信息，發(fā)送所述消息體至所述訂閱信息指定的消費(fèi)終端。

于一實(shí)施例中，所述解析所述消息請(qǐng)求，并根據(jù)解析結(jié)果，獲取對(duì)應(yīng)于所述消息請(qǐng)求的訂閱信息，包括：從所述消息請(qǐng)求中解析出消息體和消息通道信息；根據(jù)所述消息通道信息，在數(shù)據(jù)庫(kù)中查找所述消息體的所述訂閱信息。

于一實(shí)施例中，所述訂閱信息包括：所述消費(fèi)終端的地址信息；所述根據(jù)所述訂閱信息，發(fā)送所述消息體至所述訂閱信息指定的消費(fèi)終端，包括：根據(jù)所述消費(fèi)終端的所述地址信息，生成所述消息體的消費(fèi)路由信息；根據(jù)消費(fèi)路由信息，發(fā)送所述消息體至所述消費(fèi)終端。

于一實(shí)施例中，在所述解析所述消息請(qǐng)求，并根據(jù)解析結(jié)果，獲取對(duì)應(yīng)于所述消息請(qǐng)求的訂閱信息之前，還包括：驗(yàn)證所述消息請(qǐng)求是否符合預(yù)設(shè)條件；當(dāng)所述消息請(qǐng)求符合所述預(yù)設(shè)條件時(shí)，執(zhí)行所述解析所述消息請(qǐng)求，并根據(jù)解析結(jié)果，獲取對(duì)應(yīng)于所述消息請(qǐng)求的訂閱信息的步驟。

于一實(shí)施例中，在所述根據(jù)所述訂閱信息，發(fā)送所述消息體至所述訂閱信息指定的消費(fèi)終端之后，還包括：檢測(cè)是否在預(yù)設(shè)時(shí)間段內(nèi)接收到所述消費(fèi)終端發(fā)送的確收信息；若在預(yù)設(shè)時(shí)間段內(nèi)，未接收到所述確收信息，以預(yù)設(shè)次數(shù)重新發(fā)送所述消息體至所述消費(fèi)終端，若仍未接收到所述確收信息，則輸出所述消息體為無(wú)效信息。

本申請(qǐng)實(shí)施例第二方面提供了一種消息處理裝置，包括：接收模塊，用于接收生產(chǎn)終端發(fā)送的消息請(qǐng)求，所述消息請(qǐng)求中包括消息體；解析模塊，用于解析所述消息請(qǐng)求，并根據(jù)解析結(jié)果，獲取對(duì)應(yīng)于所述消息請(qǐng)求的訂閱信息；發(fā)送模塊，用于根據(jù)所述訂閱信息，發(fā)送所述消息體至所述訂閱信息指定的消費(fèi)終端。

于一實(shí)施例中，所述解析模塊用于：從所述消息請(qǐng)求中解析出消息體和消息通道信息；根據(jù)所述消息通道信息，在數(shù)據(jù)庫(kù)中查找所述消息體的所述訂閱信息。