[發(fā)明專利]一種消息傳輸方法、裝置、電子設(shè)備、及計(jì)算機(jī)存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202211199714.0
• 申請(qǐng)日: 2022-09-29
• 公開(kāi)（公告）號(hào): CN115495266A
• 公開(kāi)（公告）日: 2022-12-20
• 發(fā)明（設(shè)計(jì)）人: 郭峰
• 申請(qǐng)（專利權(quán)）人: 中國(guó)銀行股份有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;G06F11/14;G06F16/2455;G06F16/25
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司 11227
• 代理人: 崔清楊

本申請(qǐng)公開(kāi)了一種消息傳輸方法、裝置、電子設(shè)備、及計(jì)算機(jī)存儲(chǔ)介質(zhì)，可應(yīng)用于大數(shù)據(jù)領(lǐng)域或金融領(lǐng)域。該方法包括在接收到前端應(yīng)用發(fā)送的待傳輸消息時(shí)，將待傳輸消息進(jìn)行存儲(chǔ)；基于待傳輸消息攜帶的需求，將待傳輸消息轉(zhuǎn)換成目標(biāo)消息；在確定目標(biāo)消息與待傳輸消息存在一致性時(shí)，將目標(biāo)消息發(fā)送給目標(biāo)應(yīng)用，目標(biāo)應(yīng)用是基于待傳輸消息攜帶的請(qǐng)求確定的。在本方案中，通過(guò)將CMQ和MQ兩者之間消息并發(fā)優(yōu)化，轉(zhuǎn)換傳輸高效的機(jī)制方法，以在CMQ和MQ之間實(shí)現(xiàn)消息傳輸，以解決CMQ和MQ之間消息并發(fā)不一致問(wèn)題，進(jìn)而避免由于消息收發(fā)并發(fā)數(shù)不一致導(dǎo)致的消息阻塞。

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

本發(fā)明涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種消息傳輸方法、裝置、電子設(shè)備、及計(jì)算機(jī)存儲(chǔ)介質(zhì)。

背景技術(shù)

由于目前基于騰訊云發(fā)布的CMQ消息傳輸隊(duì)列，在銀行金融業(yè)中還未廣泛應(yīng)用，由于該框架架構(gòu)不僅安全性好、數(shù)據(jù)不易丟失、可回溯、消息并發(fā)大等優(yōu)點(diǎn)，越來(lái)越被企業(yè)和公司應(yīng)用，但是由于目前好多消息傳輸還是基于IBM開(kāi)源的rabbitMQ架構(gòu)，如果實(shí)現(xiàn)兩者之間互相消息傳輸，鑒于兩者之間并發(fā)量，消息類型等有差異性，傳輸過(guò)程導(dǎo)致交易量不一致，容易導(dǎo)致消息阻塞，交易丟失甚至可能導(dǎo)致系統(tǒng)宕機(jī)。

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

有鑒于此，本發(fā)明實(shí)施例提供一種消息傳輸方法、裝置、電子設(shè)備、及計(jì)算機(jī)存儲(chǔ)介質(zhì)，以解決現(xiàn)有技術(shù)中消息阻塞，交易丟失甚至可能導(dǎo)致系統(tǒng)宕機(jī)的問(wèn)題。

為實(shí)現(xiàn)上述目的，本發(fā)明實(shí)施例提供如下技術(shù)方案：

本發(fā)明實(shí)施例第一方面示出了一種消息傳輸方法，應(yīng)用于中轉(zhuǎn)處理器，所述方法包括：

在接收到前端應(yīng)用發(fā)送的待傳輸消息時(shí)，將所述待傳輸消息進(jìn)行存儲(chǔ)；

若確定所述待傳輸消息為CMQ類型的消息，基于所述待傳輸消息攜帶的需求，將所述待傳輸消息轉(zhuǎn)換成目標(biāo)消息；

在確定所述目標(biāo)消息與所述待傳輸消息存在一致性時(shí)，將所述目標(biāo)消息發(fā)送給目標(biāo)應(yīng)用，所述目標(biāo)應(yīng)用是基于所述待傳輸消息攜帶的請(qǐng)求確定的。

可選的，還包括：

將所述目標(biāo)消息進(jìn)行備份，并存儲(chǔ)；

對(duì)所述存儲(chǔ)的目標(biāo)消息進(jìn)行打標(biāo)標(biāo)注，以便后續(xù)進(jìn)行數(shù)據(jù)回溯。

可選的，還包括：

在接收到前端應(yīng)用發(fā)送的待傳輸消息之前，對(duì)前端應(yīng)用發(fā)送的待傳輸消息進(jìn)行監(jiān)控。

可選的，所述方法還包括：

若確定所述待傳輸消息為MQ類型的消息，基于所述待傳輸消息攜帶的需求，將所述待傳輸消息轉(zhuǎn)換成目標(biāo)消息；

在確定所述目標(biāo)消息與所述待傳輸消息存在一致性時(shí)，將所述目標(biāo)消息發(fā)送給目標(biāo)應(yīng)用，所述目標(biāo)應(yīng)用是基于所述待傳輸消息攜帶的請(qǐng)求確定的。

本發(fā)明實(shí)施例第二方面示出了一種消息傳輸裝置，應(yīng)用于中轉(zhuǎn)處理器，所述裝置包括：

存儲(chǔ)單元，用于在接收到前端應(yīng)用發(fā)送的待傳輸消息時(shí)，將所述待傳輸消息進(jìn)行存儲(chǔ)；

處理單元，用于若確定所述待傳輸消息為CMQ類型的消息，基于所述待傳輸消息攜帶的需求，將所述待傳輸消息轉(zhuǎn)換成目標(biāo)消息；在確定所述目標(biāo)消息與所述待傳輸消息存在一致性時(shí)，將所述目標(biāo)消息發(fā)送給目標(biāo)應(yīng)用，所述目標(biāo)應(yīng)用是基于所述待傳輸消息攜帶的請(qǐng)求確定的。

可選的，還包括：

備份單元，用于將所述目標(biāo)消息進(jìn)行備份，并存儲(chǔ)；對(duì)所述存儲(chǔ)的目標(biāo)消息進(jìn)行打標(biāo)標(biāo)注，以便后續(xù)進(jìn)行數(shù)據(jù)回溯。

可選的，還包括：

監(jiān)控單元，用于在接收到前端應(yīng)用發(fā)送的待傳輸消息之前，對(duì)前端應(yīng)用發(fā)送的待傳輸消息進(jìn)行監(jiān)控。