[發(fā)明專(zhuān)利]一種消息查詢方法及消息接收端

在審

• 申請(qǐng)?zhí)枺?/td>: 202010622026.5
• 申請(qǐng)日: 2020-06-30
• 公開(kāi)（公告）號(hào): CN111786750A
• 公開(kāi)（公告）日: 2020-10-16
• 發(fā)明（設(shè)計(jì)）人: 江鶴;江旻;楊楊;王大飛;文海榮;楊正華
• 申請(qǐng)（專(zhuān)利權(quán)）人: 深圳前海微眾銀行股份有限公司
• 主分類(lèi)號(hào): H04L1/18
• 分類(lèi)號(hào): H04L1/18
• 代理公司: 北京同達(dá)信恒知識(shí)產(chǎn)權(quán)代理有限公司 11291
• 代理人: 彭燕

本發(fā)明實(shí)施例涉及金融科技(Fintech)領(lǐng)域，公開(kāi)一種消息查詢方法及消息接收端，消息接收端接收消息處理端發(fā)送的查詢請(qǐng)求；查詢請(qǐng)求用于從消息接收端獲取待處理消息；消息接收端從第一記錄和第二記錄中確定出待處理消息；第一記錄用于實(shí)時(shí)記載消息接收端從消息發(fā)送端接收到的消息；第二記錄用于記載消息發(fā)送端發(fā)送的在統(tǒng)計(jì)時(shí)段內(nèi)狀態(tài)發(fā)生變化的消息；消息接收端將待處理消息發(fā)送給消息處理端。該方案通過(guò)將消息發(fā)送端發(fā)送的消息做成第一記錄和第二記錄兩種性質(zhì)的記錄，從而對(duì)查詢請(qǐng)求所要求的待處理消息，根據(jù)該待處理消息在兩種性質(zhì)的記錄中狀態(tài)，將所確定出的待處理消息反饋至消息處理端，從而保障了時(shí)效性要求不高時(shí)數(shù)據(jù)的最終一致性。

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

本發(fā)明實(shí)施例涉及金融科技(Fintech)領(lǐng)域，尤其涉及一種消息查詢方法及消息接收端。

背景技術(shù)

隨著計(jì)算機(jī)技術(shù)的發(fā)展，越來(lái)越多的技術(shù)(例如：大數(shù)據(jù)、云計(jì)算或區(qū)塊鏈)應(yīng)用在金融領(lǐng)域，傳統(tǒng)金融業(yè)正在逐步向金融科技轉(zhuǎn)變，大數(shù)據(jù)技術(shù)也不例外。但由于金融、支付行業(yè)的安全性、實(shí)時(shí)性要求，也對(duì)大數(shù)據(jù)技術(shù)提出了更高的要求。

目前，在收、發(fā)消息的過(guò)程中，主要通過(guò)應(yīng)用ACK機(jī)制，保證消息可以準(zhǔn)確地自消息發(fā)送端傳遞至消息接收端，且被消息接收端成功消費(fèi)。ACK機(jī)制即一種回執(zhí)機(jī)制，消息接收端向消息發(fā)送端發(fā)送ACK包，消息發(fā)送端通過(guò)正確的ACK包確保消息接收端對(duì)自己發(fā)送的消息成功消費(fèi)。

然而，以上的ACK機(jī)制，對(duì)于一些只要求可以保證數(shù)據(jù)的最終一致性，而對(duì)于時(shí)效性要求不高的場(chǎng)景，消息接收端的具有一定的實(shí)現(xiàn)成本。

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

本發(fā)明實(shí)施例提供一種消息查詢方法及消息接收端，用以實(shí)現(xiàn)以一種較低的維護(hù)消息接收端成本，仍可對(duì)數(shù)據(jù)的最終一致性進(jìn)行保證的目標(biāo)。

第一方面，本發(fā)明實(shí)施例提供一種消息查詢方法，該方法包括：消息接收端接收消息處理端發(fā)送的查詢請(qǐng)求；所述查詢請(qǐng)求用于從所述消息接收端獲取待處理消息；所述消息接收端從第一記錄和第二記錄中確定出所述待處理消息；所述第一記錄用于實(shí)時(shí)記載所述消息接收端從消息發(fā)送端接收到的消息；所述第二記錄用于記載所述消息發(fā)送端發(fā)送的在統(tǒng)計(jì)時(shí)段內(nèi)狀態(tài)發(fā)生變化的消息；所述消息接收端將所述待處理消息發(fā)送給所述消息處理端。

基于該方案，在消息接收端接收到查詢請(qǐng)求后，通過(guò)從本地的第一記錄和第二記錄中確定出對(duì)應(yīng)于查詢請(qǐng)求所要求的待處理消息，并將其發(fā)送給消息處理端。該方案中，通過(guò)將消息發(fā)送端發(fā)送的消息做成兩種性質(zhì)的記錄，一種是消息接收端在實(shí)時(shí)接收到消息后進(jìn)行存儲(chǔ)，一種是批量對(duì)來(lái)自消息發(fā)送端的消息進(jìn)行存儲(chǔ)，從而對(duì)查詢請(qǐng)求所要求的待處理消息，根據(jù)該待處理消息在兩種性質(zhì)的記錄中狀態(tài)，將所確定出的待處理消息反饋至消息處理端，從而保障了時(shí)效性要求不高時(shí)數(shù)據(jù)的最終一致性。

在一種可能的實(shí)現(xiàn)方法中，所述消息接收端從第一記錄和第二記錄中確定出所述待處理消息，包括：若所述第一記錄和所述第二記錄中均包括同一標(biāo)識(shí)的消息，則將更新時(shí)間最新的所述標(biāo)識(shí)的消息確定為所述待處理消息；和/或?qū)H在所述第二記錄中包括的消息確定為所述待處理消息。

基于該方案，由于第一記錄是消息接收端在實(shí)時(shí)接收到消息后進(jìn)行存儲(chǔ)而形成，第二記錄是對(duì)于一定的統(tǒng)計(jì)時(shí)段內(nèi)消息發(fā)送端所發(fā)送的消息的統(tǒng)計(jì)，則在查詢待處理消息時(shí)，對(duì)于同一標(biāo)識(shí)的消息，如果該消息在兩種性質(zhì)的記錄中均存在，則將更新時(shí)間最新的記錄中消息作為待處理消息；如果該消息未能及時(shí)由消息接收端進(jìn)行存儲(chǔ)，從而將以第二記錄中的消息為準(zhǔn)。通過(guò)這種方式，保證了所查詢的待處理消息的是準(zhǔn)確的。

在一種可能的實(shí)現(xiàn)方法中，所述第二記錄通過(guò)如下方式確定：從所述消息發(fā)送端獲取第一發(fā)送記錄和第二發(fā)送記錄；所述第一發(fā)送記錄中記錄有第一時(shí)刻之前發(fā)送的消息；所述第二發(fā)送記錄中記錄有第二時(shí)刻之前發(fā)送的消息；所述第二時(shí)刻晚于所述第一時(shí)刻；針對(duì)同一標(biāo)識(shí)的消息，從所述第一發(fā)送記錄和所述第二發(fā)送記錄中確定出狀態(tài)發(fā)生變化的消息。