[發(fā)明專利]一種通過(guò)消息代理隊(duì)列進(jìn)行多環(huán)境消息對(duì)接的系統(tǒng)和方法

在審

• 申請(qǐng)?zhí)枺?/td>: 202210041711.8
• 申請(qǐng)日: 2022-01-14
• 公開(kāi)（公告）號(hào): CN116483590A
• 公開(kāi)（公告）日: 2023-07-25
• 發(fā)明（設(shè)計(jì)）人: 孫闊
• 申請(qǐng)（專利權(quán)）人: 大家養(yǎng)老保險(xiǎn)股份有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 中國(guó)專利代理(香港)有限公司 72001
• 代理人: 黃濤;陳嵐

1.一種創(chuàng)建消息隊(duì)列代理的方法，所述消息隊(duì)列代理能夠在第一服務(wù)的多個(gè)運(yùn)行環(huán)境和第二服務(wù)的一個(gè)或多個(gè)運(yùn)行環(huán)境之間實(shí)現(xiàn)消息對(duì)接，其中產(chǎn)生消息的運(yùn)行環(huán)境稱為生產(chǎn)者，接收消息的運(yùn)行環(huán)境稱為消費(fèi)者，所述方法包括：

獲得透?jìng)鲄?shù)、環(huán)境/系統(tǒng)編碼以及消息隊(duì)列地址和名稱以實(shí)現(xiàn)生產(chǎn)者配置，其中所述透?jìng)鲄?shù)包括消息分發(fā)數(shù)據(jù)集，通過(guò)對(duì)所述透?jìng)鲄?shù)進(jìn)行解析能夠確定消息要去往哪個(gè)服務(wù)的哪個(gè)環(huán)境，所述環(huán)境/系統(tǒng)編碼標(biāo)識(shí)產(chǎn)生所述消息的服務(wù)和運(yùn)行環(huán)境，并且所述消息隊(duì)列地址和名稱標(biāo)識(shí)所述消息要到達(dá)的消息隊(duì)列；

基于所述生產(chǎn)者配置生成與運(yùn)行環(huán)境一一對(duì)應(yīng)的環(huán)境交換機(jī)用于從生產(chǎn)者消息隊(duì)列讀取消息；

使用所述透?jìng)鲄?shù)、所述環(huán)境/系統(tǒng)編碼以及所述消息隊(duì)列地址和名稱實(shí)現(xiàn)消費(fèi)者配置；

基于所述消費(fèi)者配置生成與運(yùn)行環(huán)境一一對(duì)應(yīng)的環(huán)境消息隊(duì)列用于向?qū)?yīng)的服務(wù)的運(yùn)行環(huán)境提供消息；以及

配置所述環(huán)境交換機(jī)中的消息和所述環(huán)境消息隊(duì)列之間的消息對(duì)接映射關(guān)系，所述消息映射關(guān)系中包括基于透射參數(shù)的判定。

2.根據(jù)權(quán)利要求1所述的方法，其中所述運(yùn)行環(huán)境選自開(kāi)發(fā)環(huán)境、測(cè)試環(huán)境、灰度環(huán)境和生產(chǎn)環(huán)境。

3.根據(jù)權(quán)利要求1或2所述的方法，還包括所述環(huán)境交換機(jī)根據(jù)所述透?jìng)鲄?shù)并基于所述消息對(duì)接映射關(guān)系而將對(duì)應(yīng)的消息分配到對(duì)應(yīng)的環(huán)境消息隊(duì)列。

4.根據(jù)權(quán)利要求1或2所述的方法，其中所述透?jìng)鲄?shù)可以為空。

5.一種消息隊(duì)列代理裝置，所述消息隊(duì)列代理裝置被配置為在第一服務(wù)的多個(gè)運(yùn)行環(huán)境和第二服務(wù)的一個(gè)或多個(gè)運(yùn)行環(huán)境之間實(shí)現(xiàn)消息對(duì)接，其中產(chǎn)生消息的運(yùn)行環(huán)境稱為生產(chǎn)者，接收消息的運(yùn)行環(huán)境稱為消費(fèi)者，所述裝置包括：

生產(chǎn)者環(huán)境交換機(jī)，基于透?jìng)鲄?shù)、環(huán)境/系統(tǒng)編碼以及消息隊(duì)列地址和名稱而生成為與運(yùn)行環(huán)境一一對(duì)應(yīng)并且被配置為從對(duì)應(yīng)的生產(chǎn)者消息隊(duì)列讀取消息，其中所述透?jìng)鲄?shù)包括消息分發(fā)數(shù)據(jù)集，通過(guò)對(duì)所述透?jìng)鲄?shù)進(jìn)行解析能夠確定消息要去往哪個(gè)服務(wù)的哪個(gè)環(huán)境，所述環(huán)境/系統(tǒng)編碼標(biāo)識(shí)產(chǎn)生所述消息的服務(wù)和運(yùn)行環(huán)境，并且所述消息隊(duì)列地址和名稱標(biāo)識(shí)所述消息要到達(dá)的消息隊(duì)列；

消費(fèi)者環(huán)境隊(duì)列，基于透?jìng)鲄?shù)、環(huán)境/系統(tǒng)編碼以及消息隊(duì)列地址和名稱而生成為與運(yùn)行環(huán)境一一對(duì)應(yīng)且被配置為向?qū)?yīng)的服務(wù)的運(yùn)行環(huán)境提供消息；以及

生產(chǎn)消費(fèi)關(guān)系映射模塊，配置所述環(huán)境交換機(jī)中的消息和所述環(huán)境消息隊(duì)列之間的消息對(duì)接映射關(guān)系，所述消息映射關(guān)系中包括基于透射參數(shù)的判定。

6.根據(jù)權(quán)利要求5所述的消息隊(duì)列代理裝置，其中所述運(yùn)行環(huán)境選自開(kāi)發(fā)環(huán)境、測(cè)試環(huán)境、灰度環(huán)境和生產(chǎn)環(huán)境。

7.根據(jù)權(quán)利要求5或6所述的消息隊(duì)列代理裝置，其中所述環(huán)境交換機(jī)根據(jù)所述透?jìng)鲄?shù)并基于所述消息對(duì)接映射關(guān)系而將對(duì)應(yīng)的消息分配到對(duì)應(yīng)的環(huán)境消息隊(duì)列。

8.根據(jù)權(quán)利要求5或6所述的消息隊(duì)列代理裝置，其中所述透?jìng)鲄?shù)可以為空。

9.一種消息隊(duì)列代理系統(tǒng)，包括：

第一服務(wù)，至少包括第一運(yùn)行環(huán)境和第二運(yùn)行環(huán)境；

第二服務(wù)，至少包括第三運(yùn)行環(huán)境；以及

根據(jù)權(quán)利要求5-8中任一項(xiàng)所述的消息隊(duì)列代理裝置，用于實(shí)現(xiàn)第一、第二運(yùn)行環(huán)境和第三運(yùn)行環(huán)境之間的消息對(duì)接。

10.一種非暫時(shí)性計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其上存儲(chǔ)有計(jì)算機(jī)程序指令，所述計(jì)算機(jī)程序指令在由一個(gè)或多個(gè)處理器執(zhí)行時(shí)使得所述處理器實(shí)施權(quán)利要求1-4中任一項(xiàng)所述的方法。