[發(fā)明專利]分布式消息服務(wù)系統(tǒng)、方法、設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)

有效

• 申請(qǐng)?zhí)枺?/td>: 201910342370.6
• 申請(qǐng)日: 2019-04-26
• 公開(kāi)（公告）號(hào): CN110138753B
• 公開(kāi)（公告）日: 2021-07-23
• 發(fā)明（設(shè)計(jì)）人: 黃涌銘;黃錚;賴林光;劉爽
• 申請(qǐng)（專利權(quán)）人: 中國(guó)工商銀行股份有限公司
• 主分類號(hào): H04L29/06
• 分類號(hào): H04L29/06;H04L29/08;H04L12/24
• 代理公司: 北京三友知識(shí)產(chǎn)權(quán)代理有限公司 11127
• 代理人: 王天堯

本發(fā)明實(shí)施例提供了一種分布式消息服務(wù)系統(tǒng)、方法、設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，該系統(tǒng)包括：消息引擎集群?jiǎn)卧ú煌愋偷拈_(kāi)源消息引擎的服務(wù)器；接口裝置對(duì)消息引擎集群?jiǎn)卧兴虚_(kāi)源消息引擎的原生接口進(jìn)行統(tǒng)一封裝，生成統(tǒng)一的訪問(wèn)入口，接收訪問(wèn)的業(yè)務(wù)應(yīng)用系統(tǒng)的請(qǐng)求；路由裝置，從接口裝置接收請(qǐng)求，從請(qǐng)求中獲取業(yè)務(wù)應(yīng)用系統(tǒng)的驗(yàn)證數(shù)據(jù)和消息服務(wù)的場(chǎng)景信息，根據(jù)獲取的驗(yàn)證數(shù)據(jù)和數(shù)據(jù)存儲(chǔ)裝置已存的業(yè)務(wù)應(yīng)用系統(tǒng)的驗(yàn)證信息對(duì)訪問(wèn)的業(yè)務(wù)應(yīng)用系統(tǒng)驗(yàn)證成功時(shí)，根據(jù)獲取的消息服務(wù)的場(chǎng)景信息和數(shù)據(jù)存儲(chǔ)裝置已存的消息引擎的配置信息確定滿足請(qǐng)求的消息引擎，通過(guò)確定出的消息引擎的服務(wù)器與訪問(wèn)的業(yè)務(wù)應(yīng)用系統(tǒng)建立連接，并提供消息服務(wù)。

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

本發(fā)明涉及分布式技術(shù)領(lǐng)域，特別涉及一種分布式消息服務(wù)系統(tǒng)、方法、設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)。

背景技術(shù)

隨著業(yè)務(wù)服務(wù)產(chǎn)品的不斷變化和用戶使用情況的變化，目前普遍使用分布式架構(gòu)來(lái)支持應(yīng)用系統(tǒng)能力高頻高并發(fā)，而在這種架構(gòu)下進(jìn)一步需要應(yīng)用系統(tǒng)之間和應(yīng)用系統(tǒng)內(nèi)部的交互處理方式逐步從同步模式走向異步模式，因此消息中間件(MOM)就成為了一種普遍的選擇。

在消息中間件中，通常有一個(gè)名為Broker的節(jié)點(diǎn)(消息服務(wù)器)，消息的發(fā)送者將消息發(fā)送至Broker上，Broker將消息存放在若干隊(duì)列中，在合適的時(shí)間再將消息轉(zhuǎn)發(fā)給接收者。這種模式不同于傳統(tǒng)意義上的同步模式，在同步模式中，應(yīng)用需要互相知道對(duì)方的接口形式和地址，在多次對(duì)話后才能進(jìn)行正式的數(shù)據(jù)交互。而通過(guò)消息中間件，各個(gè)模塊只需要調(diào)用相同的接口，即可進(jìn)行數(shù)據(jù)傳輸。模塊之間則通過(guò)傳遞消息來(lái)激活對(duì)方的事件，完成相應(yīng)的操作。

消息中間件能在不同平臺(tái)之間通信，它常被用來(lái)屏蔽掉各種平臺(tái)及協(xié)議之間的特性，實(shí)現(xiàn)應(yīng)用程序之間的協(xié)同，其優(yōu)點(diǎn)在于能夠在客戶和服務(wù)器之間提供同步和異步的連接，并且在任何時(shí)刻都可以將消息進(jìn)行傳送或者存儲(chǔ)轉(zhuǎn)發(fā)，這也是它比遠(yuǎn)程過(guò)程調(diào)用更進(jìn)一步的原因。

目前，消息中間件領(lǐng)域已經(jīng)有較為成熟的幾款開(kāi)源產(chǎn)品，如Apache下的ActiveMQ、Kafka、RocketMQ，以及hornetQ，RabbitMQ，ZeroMQ等等也被普遍使用，此外也有商業(yè)化的IBM MQ，ironMQ等產(chǎn)品可供用戶選擇。這些不同的產(chǎn)品之間，所使用的協(xié)議和規(guī)范不同，如ActiveMQ，HornetMQ使用JMS規(guī)范，RabbitMQ使用AMQP，Kafka、RocketMQ使用自己設(shè)計(jì)的規(guī)范等。由于各個(gè)產(chǎn)品的功能不同，適用場(chǎng)景不同，產(chǎn)品所提供的API接口和接口的使用方法也不盡相同。對(duì)于用戶而言，很多情況下根據(jù)不同業(yè)務(wù)場(chǎng)景需要引入多種開(kāi)源產(chǎn)品，這就要求用戶了解所有的產(chǎn)品而后根據(jù)這些產(chǎn)品進(jìn)行參數(shù)調(diào)優(yōu)和接口學(xué)習(xí)，才能進(jìn)行最終的開(kāi)發(fā)。對(duì)于不同場(chǎng)景的應(yīng)用，甚至在同一個(gè)應(yīng)用中不同場(chǎng)景的程序模塊之間，所用到的消息中間件產(chǎn)品也可能不盡相同，這就對(duì)開(kāi)發(fā)人員所需要花費(fèi)的學(xué)習(xí)成本有了進(jìn)一步的要求，用戶在軟件的使用上需要付出較高的學(xué)習(xí)成本。

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

本發(fā)明實(shí)施例提供了一種分布式消息服務(wù)系統(tǒng)，以解決現(xiàn)有技術(shù)中直接使用各類消息中間件時(shí)需要用戶學(xué)習(xí)各類消息中間件而導(dǎo)致的學(xué)習(xí)成本高、開(kāi)發(fā)成本高的技術(shù)問(wèn)題。該系統(tǒng)包括：

接口裝置、路由裝置、數(shù)據(jù)存儲(chǔ)裝置以及消息引擎裝置，其中，

所述消息引擎裝置包括：

消息引擎集群?jiǎn)卧鱿⒁婕簡(jiǎn)卧ú煌愋偷拈_(kāi)源消息引擎的服務(wù)器；

所述數(shù)據(jù)存儲(chǔ)裝置，用于存儲(chǔ)業(yè)務(wù)應(yīng)用系統(tǒng)的驗(yàn)證信息以及消息引擎的配置信息；

所述接口裝置，用于對(duì)所述消息引擎集群?jiǎn)卧兴虚_(kāi)源消息引擎的原生接口進(jìn)行統(tǒng)一封裝，生成統(tǒng)一的訪問(wèn)入口，所述訪問(wèn)入口供各業(yè)務(wù)應(yīng)用系統(tǒng)訪問(wèn)，接收訪問(wèn)的業(yè)務(wù)應(yīng)用系統(tǒng)的請(qǐng)求；