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

在審

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

1.一種消息處理方法，其特征在于，包括：

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

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

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

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

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

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

2.如權(quán)利要求1所述的方法，其特征在于，在所述將請(qǐng)求消息發(fā)送至消息服務(wù)端之前，還包括：

所述第一消息端在所述消息服務(wù)端創(chuàng)建請(qǐng)求消息的第一訂閱主題及請(qǐng)求消息的響應(yīng)消息的第二訂閱主題；

所述第一消息端通過(guò)服務(wù)注冊(cè)中心確定所述第二訂閱主題下的隊(duì)列信息；

所述第一消息端從所述第二訂閱主題下的隊(duì)列信息中確定所述響應(yīng)消息的響應(yīng)隊(duì)列信息；所述響應(yīng)隊(duì)列信息作為所述第二訂閱主題的第二存儲(chǔ)區(qū)。

3.如權(quán)利要求2所述的方法，其特征在于，所述第一消息端從所述第二訂閱主題下的隊(duì)列信息中確定所述響應(yīng)消息的響應(yīng)隊(duì)列信息，包括：

所述第一消息端根據(jù)自身的應(yīng)用實(shí)例的個(gè)數(shù)和所述第二訂閱主題下的隊(duì)列信息中的隊(duì)列數(shù)量，按照平均分配的方式，確定每個(gè)應(yīng)用實(shí)例的響應(yīng)隊(duì)列信息；所述響應(yīng)隊(duì)列信息用于存儲(chǔ)所述應(yīng)用實(shí)例產(chǎn)生的請(qǐng)求消息對(duì)應(yīng)的響應(yīng)消息。

4.如權(quán)利要求1所述的方法，其特征在于，所述第二消息端通過(guò)所述第一訂閱機(jī)制，從所述消息服務(wù)端獲取所述請(qǐng)求消息，包括：

所述第二消息端生成所述第一訂閱主題對(duì)應(yīng)的消息拉取請(qǐng)求；

所述第二消息端通過(guò)所述第一訂閱機(jī)制將所述消息拉取請(qǐng)求發(fā)送給所述消息服務(wù)端；所述消息拉取請(qǐng)求用于指示所述消息服務(wù)端基于所述第一訂閱主題從所述第一存儲(chǔ)區(qū)中確定出所述請(qǐng)求消息。

5.如權(quán)利要求1所述的方法，其特征在于，所述第二消息端對(duì)所述請(qǐng)求消息進(jìn)行處理得到響應(yīng)消息，包括：

所述第二消息端基于所述請(qǐng)求消息，對(duì)與所述請(qǐng)求消息對(duì)應(yīng)的業(yè)務(wù)進(jìn)行處理，并在確定所述業(yè)務(wù)處理完成后，基于所述業(yè)務(wù)已處理完成的消息以及所述請(qǐng)求消息對(duì)應(yīng)的第二訂閱主題，生成所述響應(yīng)消息。

6.如權(quán)利要求1所述的方法，其特征在于，在所述將所述請(qǐng)求消息存儲(chǔ)至所述第一訂閱主題的第一存儲(chǔ)區(qū)之后，還包括：

所述消息服務(wù)端通過(guò)回放線程確定出所述第一存儲(chǔ)區(qū)中各待解析消息的位置；所述各待解析消息為所述第一存儲(chǔ)區(qū)中待解析的各請(qǐng)求消息；

所述消息服務(wù)端基于所述各待解析消息的位置，對(duì)所述各待解析消息進(jìn)行解析處理，得到所述各待解析消息的消息偏移量，并將所述各待解析消息的消息偏移量存儲(chǔ)至所述第一訂閱主題的偏移量緩存隊(duì)列中；所述消息偏移量用于所述消息服務(wù)端根據(jù)所述第二消息端發(fā)送的消息拉取請(qǐng)求對(duì)應(yīng)的消息偏移量從所述第一存儲(chǔ)區(qū)中查詢出對(duì)應(yīng)的請(qǐng)求消息。