[發(fā)明專利]一種實(shí)時消息處理裝置

有效

• 申請?zhí)枺?/td>: 201910116268.4
• 申請日: 2019-02-15
• 公開（公告）號: CN109889455B
• 公開（公告）日: 2020-09-11
• 發(fā)明（設(shè)計(jì)）人: 王澄
• 申請（專利權(quán)）人: 浙江吉利汽車研究院有限公司;浙江吉利控股集團(tuán)有限公司
• 主分類號: H04L12/863
• 分類號: H04L12/863;H04L12/865;H04L12/875
• 代理公司: 廣州三環(huán)專利商標(biāo)代理有限公司 44202
• 代理人: 郝傳鑫;賈允

1.一種實(shí)時消息處理裝置，所述實(shí)時消息處理裝置基于消息總線進(jìn)行實(shí)時消息處理，其特征在于，所述裝置包括：

實(shí)時消息生產(chǎn)者，用于產(chǎn)生實(shí)時消息并將實(shí)時消息發(fā)送至消息分發(fā)器；

實(shí)時消息消費(fèi)者，用于從消息隊(duì)列獲取實(shí)時消息；

消息分發(fā)器，用于接收實(shí)時消息，并將所述實(shí)時消息路由至相應(yīng)的消息隊(duì)列中以供實(shí)時消息消費(fèi)者使用；消息分發(fā)器支持多線程并發(fā)處理消息，針對不同消息對實(shí)時性要求的不同、消息生產(chǎn)者發(fā)送消息的頻率屬性不同，采用不同的消息發(fā)送機(jī)制；在微秒級實(shí)時性要求中，采用輪詢分發(fā)機(jī)制；在毫秒級實(shí)時性要求中，采用定時器驅(qū)動的分發(fā)機(jī)制；

消息隊(duì)列，用于存儲實(shí)時消息；

所述消息分發(fā)器包括：

輪詢管理模塊，用于根據(jù)實(shí)際需求控制輪詢分發(fā)線程，所述輪詢分發(fā)線程用于采用輪詢分發(fā)機(jī)制進(jìn)行消息分發(fā)；

定時器驅(qū)動管理模塊，用于根據(jù)實(shí)際需求控制驅(qū)動分發(fā)線程，所述驅(qū)動分發(fā)線程采用定時器驅(qū)動的分發(fā)機(jī)制進(jìn)行消息分發(fā)；

所述輪詢管理模塊，包括：

排序單元，用于將全部消息隊(duì)列的優(yōu)先級進(jìn)行降序排列；

訪問控制單元，用于按照排序結(jié)果訪問消息隊(duì)列，訪問過程為：判斷當(dāng)前消息隊(duì)列是否為空；若為空，則判斷是否達(dá)到最后一個消息隊(duì)列，若是，則返回將全部消息隊(duì)列的優(yōu)先級進(jìn)行降序排列后再重新訪問；若否，則訪問下一個消息隊(duì)列；若不為空，則發(fā)送所述當(dāng)前消息隊(duì)列中的數(shù)據(jù)，并更新當(dāng)前消息隊(duì)列的優(yōu)先級。

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

所述實(shí)時消息生產(chǎn)者和所述實(shí)時消息消費(fèi)者位于相同設(shè)備或相同模塊。

3.根據(jù)權(quán)利要求1所述的裝置，其特征在于：

消息分發(fā)器根據(jù)消息中攜帶的標(biāo)識屬性，將消息進(jìn)一步路由至相應(yīng)的消息隊(duì)列中，以便在多核和多個發(fā)送線程之間實(shí)現(xiàn)負(fù)載均衡。

4.根據(jù)權(quán)利要求1所述的裝置，其特征在于：

消息分發(fā)器根據(jù)各線程的負(fù)載統(tǒng)計(jì)和實(shí)時性監(jiān)測結(jié)果，把消息分發(fā)到恰當(dāng)?shù)南㈥?duì)列，和/或，消息分發(fā)器實(shí)時監(jiān)控每一個實(shí)時消息處理裝置的負(fù)載情況進(jìn)行決策，選擇接收實(shí)時消息的實(shí)時消息處理裝置。

5.根據(jù)權(quán)利要求1所述的裝置，其特征在于：

還包括消息確認(rèn)模塊，用于確認(rèn)消息是否已經(jīng)被發(fā)送至實(shí)時消息消費(fèi)者；當(dāng)實(shí)時消息消費(fèi)者成功接收消息后，發(fā)送確認(rèn)信息給消息確認(rèn)模塊，之后該消息才從消息隊(duì)列中刪除。

6.根據(jù)權(quán)利要求1所述的裝置，其特征在于，所述定時器驅(qū)動管理模塊中不同的消息隊(duì)列共享或分別設(shè)立定時器，定時器超時則觸發(fā)計(jì)數(shù)器的計(jì)數(shù)，根據(jù)計(jì)數(shù)器的計(jì)數(shù)即可觸發(fā)消息隊(duì)列中的消息的發(fā)送。

7.根據(jù)權(quán)利要求6所述的裝置，其特征在于，定時器時間間隔選取各消息發(fā)送周期的最大公約數(shù)。