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

在審

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

本發(fā)明實(shí)施例公開了一種偏向應(yīng)用的結(jié)構(gòu)優(yōu)化的分布式事件中心的方法及系統(tǒng)。本發(fā)明實(shí)施例提供的偏向應(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ù)至對應(yīng)的事件通道；根據(jù)訂閱關(guān)系數(shù)據(jù)，事件通道接收事件數(shù)據(jù)并發(fā)送事件數(shù)據(jù)至事件消費(fèi)者；事件中心通過動(dòng)態(tài)加載解析器技術(shù)動(dòng)態(tài)同步事件解析數(shù)據(jù)至事件消費(fèi)者。本發(fā)明實(shí)施例提供的技術(shù)方案實(shí)現(xiàn)了在事件分發(fā)環(huán)節(jié)去除中心節(jié)點(diǎn)，對事件中心功能調(diào)整為偏向于元數(shù)據(jù)的定義及存儲(chǔ)，實(shí)現(xiàn)智能工廠自動(dòng)信息配置中事件源直接向事件通道發(fā)送事件數(shù)據(jù)，減小了不同事件之間相互干擾的問題。

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

本發(fā)明實(shí)施例涉及事件分發(fā)技術(shù)領(lǐng)域，尤其涉及一種偏向應(yīng)用的結(jié)構(gòu)優(yōu)化的分布式事件中心的方法及系統(tǒng)。

背景技術(shù)

選煤廠包括壓濾、密控、沉降、加藥以及配煤等不可缺少的環(huán)節(jié)，現(xiàn)有的選煤廠的生產(chǎn)過程中有諸多環(huán)節(jié)都依賴人工操作，智能選煤工廠包括壓濾、密控、沉降、加藥以及配煤等多種自動(dòng)控制模塊或系統(tǒng)，智能選煤工廠自動(dòng)信息配置成為發(fā)展趨勢，現(xiàn)有的智能選煤工廠自動(dòng)信息配置中需要采用分布式事件中心進(jìn)行事件的集中和配置，導(dǎo)致不同事件之間存在相互干擾，影響事件的處理能力。

現(xiàn)有的智能選煤工廠自動(dòng)信息配置中不同事件之間存在相互干擾成為業(yè)內(nèi)亟待解決的問題。

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

本發(fā)明實(shí)施例提供一種偏向應(yīng)用的結(jié)構(gòu)優(yōu)化的分布式事件中心的方法及系統(tǒng)，以解決現(xiàn)有的智能選煤工廠自動(dòng)信息配置中可以使用的事件都是相對固定的，不同事件之間存在相互干擾的問題。

為實(shí)現(xiàn)上述技術(shù)問題，本發(fā)明采用以下技術(shù)方案：

第一方面，本發(fā)明實(shí)施例提供了一種偏向應(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ù)至對應(yīng)的事件通道；

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

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

進(jìn)一步地，事件定義數(shù)據(jù)包括靜態(tài)上下文數(shù)據(jù)；

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

進(jìn)一步地，所述事件中心通過動(dòng)態(tài)加載解析器技術(shù)動(dòng)態(tài)同步事件解析數(shù)據(jù)至所述事件消費(fèi)者，包括：

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

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

進(jìn)一步地，在所述根據(jù)所述事件定義數(shù)據(jù)，所述事件源生成事件數(shù)據(jù)并發(fā)送所述事件數(shù)據(jù)至對應(yīng)的事件通道之后，還包括：

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

進(jìn)一步地，所述事件中心通過動(dòng)態(tài)加載解析器技術(shù)動(dòng)態(tài)同步事件解析數(shù)據(jù)至所述事件消費(fèi)者之后，還包括：

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

進(jìn)一步地，在所述根據(jù)所述訂閱關(guān)系數(shù)據(jù)，事件通道接收所述事件數(shù)據(jù)并發(fā)送所述事件數(shù)據(jù)至事件消費(fèi)者之前，還包括：

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

第二方面，本發(fā)明實(shí)施例還提供了一種攜帶順序歷史數(shù)據(jù)的事件消息分發(fā)的系統(tǒng)，包括：

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