[發(fā)明專利]一種消息處理方法及系統(tǒng)

在審

• 申請?zhí)枺?/td>: 202011533464.0
• 申請日: 2020-12-23
• 公開（公告）號: CN112689248A
• 公開（公告）日: 2021-04-20
• 發(fā)明（設(shè)計(jì)）人: 詹學(xué)桂
• 申請（專利權(quán)）人: 深圳前海微眾銀行股份有限公司
• 主分類號: H04W4/12
• 分類號: H04W4/12;H04W4/06;H04L29/08
• 代理公司: 北京同達(dá)信恒知識產(chǎn)權(quán)代理有限公司 11291
• 代理人: 王春波

本發(fā)明實(shí)施例提供了一種消息處理方法及系統(tǒng)，該方法包括消息服務(wù)端根據(jù)請求消息中的第一訂閱主題，將第一消息端發(fā)送的請求消息存儲至第一訂閱主題的第一存儲區(qū)。第二消息端通過第一訂閱機(jī)制，從消息服務(wù)端獲取請求消息并進(jìn)行處理得到響應(yīng)消息，通過第二訂閱機(jī)制，將響應(yīng)消息發(fā)送至消息服務(wù)端。消息服務(wù)端將響應(yīng)消息存儲至第二訂閱主題的第二存儲區(qū)，第一消息端通過第二訂閱機(jī)制，從消息服務(wù)端獲取響應(yīng)消息。由于在消息服務(wù)端創(chuàng)建有接收并存儲響應(yīng)消息的第二存儲區(qū)，如此可以避免響應(yīng)消息的丟失，從而可以實(shí)現(xiàn)響應(yīng)消息的重放。此外，該方法可以避免對消息服務(wù)端在消息處理過程中所涉及的代碼進(jìn)行更改，如此可以便于后續(xù)業(yè)務(wù)及時(shí)有效地使用。

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

本發(fā)明實(shí)施例涉及金融科技(Fintech)領(lǐng)域，尤其涉及一種消息處理方法及系統(tǒng)。

背景技術(shù)

隨著計(jì)算機(jī)技術(shù)的發(fā)展，越來越多的技術(shù)應(yīng)用在金融領(lǐng)域，傳統(tǒng)金融業(yè)正在逐步向金融科技轉(zhuǎn)變，但由于金融行業(yè)的安全性、實(shí)時(shí)性要求，也對技術(shù)提出的更高的要求。

現(xiàn)有的消息處理方法主要是消息生產(chǎn)者Producer生產(chǎn)消息，并在該消息的消息頭上標(biāo)注REPLY_TO標(biāo)識和BROKER標(biāo)識。再將標(biāo)注后的消息傳輸?shù)较⒎?wù)端Broker，消息服務(wù)端將標(biāo)注后的消息存儲在topic中。消息消費(fèi)者可以根據(jù)訂閱需求從消息服務(wù)端的topic中拉取與訂閱需求對應(yīng)的標(biāo)注后的消息，并基于該標(biāo)注后的消息進(jìn)行業(yè)務(wù)處理，在業(yè)務(wù)處理完成后，將業(yè)務(wù)處理已完成的消息、REPLY_TO標(biāo)識和BROKER標(biāo)識組裝成應(yīng)答消息。然后基于BROKER標(biāo)識將應(yīng)答消息發(fā)送給對應(yīng)的消息服務(wù)端，消息服務(wù)端基于REPLY_TO標(biāo)識從內(nèi)存映射表中查詢出標(biāo)注后的消息對應(yīng)的SocketChannel，并通過SocketChannel直接將應(yīng)答消息回包給對應(yīng)的消息生產(chǎn)者。然而，這種處理方式需要對消息服務(wù)端做較多改動，不利于后續(xù)業(yè)務(wù)的使用；同時(shí)消息服務(wù)端沒有對應(yīng)答消息進(jìn)行存儲，導(dǎo)致應(yīng)答消息丟失的概率增加，并無法對應(yīng)答消息進(jìn)行重放。

綜上，目前亟需一種消息處理方法，用以避免響應(yīng)消息的丟失，從而實(shí)現(xiàn)響應(yīng)消息的重放。

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

本發(fā)明實(shí)施例提供了一種消息處理方法及系統(tǒng)，用以避免響應(yīng)消息的丟失，從而實(shí)現(xiàn)響應(yīng)消息的重放。

第一方面，本發(fā)明實(shí)施例提供了一種消息處理方法，包括：

第一消息端通過第一訂閱機(jī)制，將請求消息發(fā)送至消息服務(wù)端；所述第一訂閱機(jī)制中所述第一消息端為生產(chǎn)端，第二消息端為消費(fèi)端；

所述消息服務(wù)端根據(jù)所述請求消息中的第一訂閱主題，將所述請求消息存儲至所述第一訂閱主題的第一存儲區(qū)；

所述第二消息端通過所述第一訂閱機(jī)制，從所述消息服務(wù)端獲取所述請求消息并進(jìn)行處理得到響應(yīng)消息；所述響應(yīng)消息包括所述請求消息中的第二訂閱主題；

所述第二消息端通過第二訂閱機(jī)制，將所述響應(yīng)消息發(fā)送至所述消息服務(wù)端；所述第二訂閱機(jī)制中所述第一消息端為消費(fèi)端，所述第二消息端為生產(chǎn)端；

所述消息服務(wù)端將所述響應(yīng)消息存儲至所述第二訂閱主題的第二存儲區(qū)；

所述第一消息端通過所述第二訂閱機(jī)制，從所述消息服務(wù)端獲取所述響應(yīng)消息。