[發(fā)明專利]偏向應(yīng)用的結(jié)構(gòu)優(yōu)化的分布式事件中心的方法及系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 202010066769.9
• 申請(qǐng)日: 2020-01-20
• 公開(kāi)（公告）號(hào): CN111324469A
• 公開(kāi)（公告）日: 2020-06-23
• 發(fā)明（設(shè)計(jì)）人: 李太友;張淑強(qiáng);陳桂剛;劉純;李大勤;郭昊;趙健軍;宋晨
• 申請(qǐng)（專利權(quán)）人: 天津美騰科技股份有限公司;天津中新智冠信息技術(shù)有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種偏向應(yīng)用的結(jié)構(gòu)優(yōu)化的分布式事件中心的方法，其特征在于，包括：

事件中心向事件源動(dòng)態(tài)同步事件定義數(shù)據(jù)及訂閱關(guān)系數(shù)據(jù)；

根據(jù)所述事件定義數(shù)據(jù)，所述事件源生成事件數(shù)據(jù)并發(fā)送所述事件數(shù)據(jù)至對(duì)應(yīng)的事件通道；

根據(jù)所述訂閱關(guān)系數(shù)據(jù)，所述事件通道接收所述事件數(shù)據(jù)并發(fā)送所述事件數(shù)據(jù)至事件消費(fèi)者；

所述事件中心通過(guò)動(dòng)態(tài)加載解析器技術(shù)動(dòng)態(tài)同步事件解析數(shù)據(jù)至所述事件消費(fèi)者。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，

事件定義數(shù)據(jù)包括靜態(tài)上下文數(shù)據(jù)；

動(dòng)態(tài)同步事件解析數(shù)據(jù)包括動(dòng)態(tài)上下文解析數(shù)據(jù)。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述事件中心通過(guò)動(dòng)態(tài)加載解析器技術(shù)動(dòng)態(tài)同步事件解析數(shù)據(jù)至所述事件消費(fèi)者，包括：

根據(jù)類加載機(jī)制，在事件中心驗(yàn)證并緩存類字節(jié)碼；

通過(guò)遠(yuǎn)程加載二進(jìn)制字節(jié)流的方式將所述類字節(jié)碼形成類。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，在根據(jù)所述事件定義數(shù)據(jù)，所述事件源生成事件數(shù)據(jù)并發(fā)送所述事件數(shù)據(jù)至對(duì)應(yīng)的事件通道之后，還包括：

所述事件源緩存所述訂閱關(guān)系數(shù)據(jù)。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述事件中心通過(guò)動(dòng)態(tài)加載解析器技術(shù)動(dòng)態(tài)同步事件解析數(shù)據(jù)至所述事件消費(fèi)者之后，還包括：

所述事件消費(fèi)者根據(jù)所述類及對(duì)象加載方式將收到的所述事件數(shù)據(jù)解析成對(duì)象，并進(jìn)行事件消費(fèi)處理。

6.根據(jù)權(quán)利要求1所述的方法，其特征在于，在所述根據(jù)所述訂閱關(guān)系數(shù)據(jù)，所述事件通道接收所述事件數(shù)據(jù)并發(fā)送所述事件數(shù)據(jù)至事件消費(fèi)者之前，還包括：

事件中心根據(jù)需要?jiǎng)討B(tài)創(chuàng)建或銷毀事件通道。

7.一種攜帶順序歷史數(shù)據(jù)的事件消息分發(fā)的系統(tǒng)，其特征在于，包括：

事件中心，用于向事件源動(dòng)態(tài)同步事件定義數(shù)據(jù)及訂閱關(guān)系數(shù)據(jù)；

事件源，用于根據(jù)所述事件定義數(shù)據(jù)，生成事件數(shù)據(jù)并發(fā)送所述事件數(shù)據(jù)至對(duì)應(yīng)的事件通道；

事件通道，用于根據(jù)所述訂閱關(guān)系數(shù)據(jù)，接收所述事件數(shù)據(jù)并發(fā)送所述事件數(shù)據(jù)至事件消費(fèi)者；

所述事件中心，還用于通過(guò)動(dòng)態(tài)加載解析器技術(shù)動(dòng)態(tài)同步事件解析數(shù)據(jù)至所述事件消費(fèi)者。

8.根據(jù)權(quán)利要求7所述的系統(tǒng)，其特征在于，所述事件中心包括：

緩存單元，用于根據(jù)類加載機(jī)制，在事件中心驗(yàn)證并緩存類字節(jié)碼；

類生成單元，用于通過(guò)遠(yuǎn)程加載二進(jìn)制字節(jié)流的方式將所述類字節(jié)碼形成類。

9.根據(jù)權(quán)利要求7所述的系統(tǒng)，其特征在于，還包括：

事件消費(fèi)者，用于根據(jù)所述類及對(duì)象加載方式將收到的所述事件數(shù)據(jù)解析成對(duì)象，并進(jìn)行事件消費(fèi)處理。

10.根據(jù)權(quán)利要求7所述的系統(tǒng)，其特征在于，

所述事件中心，還用于根據(jù)需要?jiǎng)討B(tài)創(chuàng)建或銷毀事件通道。