[發(fā)明專利]消息處理方法、裝置、控制器及系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 201611229762.4
• 申請(qǐng)日: 2016-12-27
• 公開(kāi)（公告）號(hào): CN106776077A
• 公開(kāi)（公告）日: 2017-05-31
• 發(fā)明（設(shè)計(jì)）人: 陸黎川;王永軍;李林臻;喬鶴松;裴晶瑞;郭峰;呂崢;張玉;李阿飛;蘇暉;許焱
• 申請(qǐng)（專利權(quán)）人: 中國(guó)民生銀行股份有限公司
• 主分類(lèi)號(hào): G06F9/54
• 分類(lèi)號(hào): G06F9/54
• 代理公司: 北京同立鈞成知識(shí)產(chǎn)權(quán)代理有限公司11205
• 代理人: 楊文娟,劉芳

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

本發(fā)明涉及消息處理技術(shù)領(lǐng)域，尤其涉及一種消息處理方法、裝置、控制器及系統(tǒng)。

背景技術(shù)

不同消息系統(tǒng)間的消息處理和轉(zhuǎn)發(fā)可通過(guò)消息中間件實(shí)現(xiàn)。通過(guò)消息中間件進(jìn)行消息處理，實(shí)際是對(duì)消息進(jìn)行直存直取，也就是每從消息源系統(tǒng)接收到一個(gè)消息便將其轉(zhuǎn)發(fā)至對(duì)應(yīng)的目標(biāo)消息系統(tǒng)中。

然而不同目標(biāo)消息系統(tǒng)需實(shí)現(xiàn)不同的業(yè)務(wù)功能，僅采用消息中間件，便難以實(shí)現(xiàn)對(duì)多種目標(biāo)消息系統(tǒng)對(duì)應(yīng)的業(yè)務(wù)需求。為實(shí)現(xiàn)滿足不同的業(yè)務(wù)需求，可通過(guò)集中式消息服務(wù)實(shí)現(xiàn)消息的統(tǒng)一處理和轉(zhuǎn)發(fā)，通過(guò)定義多種不同業(yè)務(wù)對(duì)應(yīng)的規(guī)則執(zhí)行。在該集中式消息服務(wù)處理過(guò)程中，每條消息需經(jīng)過(guò)所有業(yè)務(wù)對(duì)應(yīng)的規(guī)則。

隨著應(yīng)用數(shù)量的線性增長(zhǎng)，針對(duì)各應(yīng)用的消息量也大量增加，通過(guò)集中式消息服務(wù)進(jìn)行消息處理的性能難以得到有效提高，從而使得消息處理的復(fù)雜度較高。

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

本發(fā)明提供一種消息處理方法、裝置、控制器及系統(tǒng)，以降低消息處理的復(fù)雜度。

本發(fā)明提供一種消息處理方法，包括：

接收消息源系統(tǒng)發(fā)送的源消息；

從預(yù)設(shè)的消息隊(duì)列集群中確定所述源消息對(duì)應(yīng)的第一類(lèi)規(guī)則隊(duì)列；

根據(jù)所述源消息對(duì)應(yīng)的第一類(lèi)規(guī)則隊(duì)列中的至少一個(gè)第一類(lèi)規(guī)則依次對(duì)所述源消息進(jìn)行處理；

從所述消息隊(duì)列集群中確定所述處理后的消息對(duì)應(yīng)的第二類(lèi)規(guī)則隊(duì)列；所述第一類(lèi)規(guī)則隊(duì)列和所述第二規(guī)則隊(duì)列為不同類(lèi)型的規(guī)則隊(duì)列；

根據(jù)所述處理后的消息對(duì)應(yīng)的第二類(lèi)規(guī)則隊(duì)列中的至少一個(gè)第二類(lèi)規(guī)則依次對(duì)所述處理后的消息進(jìn)行處理，得到目標(biāo)消息；

將所述目標(biāo)消息發(fā)送至消息目標(biāo)系統(tǒng)。

本發(fā)明還提供一種消息處理裝置，包括：

接收模塊，用于接收消息源系統(tǒng)發(fā)送的源消息；

第一確定模塊，用于從預(yù)設(shè)的消息隊(duì)列集群中確定所述源消息對(duì)應(yīng)的第一類(lèi)規(guī)則隊(duì)列；

第一處理模塊，用于根據(jù)所述源消息對(duì)應(yīng)的第一類(lèi)規(guī)則隊(duì)列中的至少一個(gè)第一類(lèi)規(guī)則依次對(duì)所述源消息進(jìn)行處理；

第二確定模塊，用于從所述消息隊(duì)列集群中確定所述處理后的消息對(duì)應(yīng)的第二類(lèi)規(guī)則隊(duì)列；

第二處理模塊，用于根據(jù)所述處理后的消息對(duì)應(yīng)的第二類(lèi)規(guī)則隊(duì)列中的至少一個(gè)第二類(lèi)規(guī)則依次對(duì)所述處理后的消息進(jìn)行處理，得到目標(biāo)消息；

發(fā)送模塊，用于將所述目標(biāo)消息發(fā)送至消息目標(biāo)系統(tǒng)。

本發(fā)明還提供一種控制器，包括：存儲(chǔ)器和處理器；所述存儲(chǔ)器與所述處理器連接；

所述存儲(chǔ)器用于存儲(chǔ)程序指令；

所述處理器，用于調(diào)度所述存儲(chǔ)器中的所述程序指令，用以執(zhí)行上述所述的消息處理方法。

本發(fā)明還提供一種消息處理系統(tǒng)，包括：消息源系統(tǒng)、控制器和消息目標(biāo)系統(tǒng)；其中，所述消息源系統(tǒng)與所述控制器連接，所述控制器還與所述消息目標(biāo)系統(tǒng)連接；

所述消息源系統(tǒng)用于向所述控制器發(fā)送源消息；

所述控制器，用于從預(yù)設(shè)的消息隊(duì)列集群中確定所述源消息對(duì)應(yīng)的第一類(lèi)規(guī)則隊(duì)列；根據(jù)所述源消息對(duì)應(yīng)的場(chǎng)景規(guī)則隊(duì)列中的至少一個(gè)第一類(lèi)規(guī)則依次對(duì)所述源消息進(jìn)行處理；從所述消息隊(duì)列集群中確定所述處理后的消息對(duì)應(yīng)的第二類(lèi)規(guī)則隊(duì)列；根據(jù)所述處理后的消息對(duì)應(yīng)的第二類(lèi)規(guī)則隊(duì)列中的至少一個(gè)第二類(lèi)規(guī)則依次對(duì)所述處理后的消息進(jìn)行處理，得到目標(biāo)消息；并將所述目標(biāo)消息發(fā)送至消息目標(biāo)系統(tǒng)。

本發(fā)明提供的消息處理方法、裝置、控制器及系統(tǒng)，可在接收到消息源系統(tǒng)發(fā)送的源消息后，可從預(yù)設(shè)的消息隊(duì)列集群中確定該源消息對(duì)應(yīng)的第一類(lèi)規(guī)則隊(duì)列，并根據(jù)該源消息對(duì)應(yīng)的第一類(lèi)規(guī)則隊(duì)列中的至少一個(gè)第一類(lèi)規(guī)則依次對(duì)該源消息進(jìn)行處理；從該消息隊(duì)列集群中確定該處理后的消息對(duì)應(yīng)的第二類(lèi)規(guī)則隊(duì)列，根據(jù)該處理后的消息對(duì)應(yīng)的第二類(lèi)規(guī)則隊(duì)列中的至少一個(gè)第二類(lèi)規(guī)則依次對(duì)該處理后的消息進(jìn)行處理，得到目標(biāo)消息；繼而將該目標(biāo)消息發(fā)送至消息目標(biāo)系統(tǒng)。該消息處理方法中，針對(duì)每個(gè)源消息，只需根據(jù)該源消息對(duì)應(yīng)的第一類(lèi)規(guī)則隊(duì)列中的規(guī)則進(jìn)行處理，并根據(jù)確定的該處理后的消息對(duì)應(yīng)的第二類(lèi)規(guī)則隊(duì)列中的規(guī)則進(jìn)行處理，而無(wú)需經(jīng)過(guò)所有的業(yè)務(wù)規(guī)則進(jìn)行處理，從而減小了消息處理的復(fù)雜度。

附圖說(shuō)明

圖1為本發(fā)明的一種消息處理系統(tǒng)的結(jié)構(gòu)示意圖；

圖2為本發(fā)明提供的一種消息處理方法的流程圖；

圖3為本發(fā)明提供的一種消息處理方法的流程圖；

圖4為本發(fā)明提供的一種消息處理裝置的結(jié)構(gòu)示意圖；

圖5為本發(fā)明提供的一種控制器的結(jié)構(gòu)示意圖；

圖6為本發(fā)明提供的另一種消息處理系統(tǒng)的結(jié)構(gòu)圖。

具體實(shí)施方式