[發(fā)明專利]一種消息處理方法及系統(tǒng)、存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202011026589.4
• 申請(qǐng)日: 2020-09-25
• 公開（公告）號(hào): CN112099975A
• 公開（公告）日: 2020-12-18
• 發(fā)明（設(shè)計(jì)）人: 劉君
• 申請(qǐng)（專利權(quán)）人: OPPO廣東移動(dòng)通信有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;G06F9/50;G06F9/48
• 代理公司: 北京派特恩知識(shí)產(chǎn)權(quán)代理有限公司 11270
• 代理人: 王軍紅;張穎玲

本申請(qǐng)實(shí)施例提供了一種消息處理方法及系統(tǒng)、存儲(chǔ)介質(zhì)，該消息處理系統(tǒng)包括：面向消息的中間件服務(wù)和多個(gè)消息隊(duì)列；多個(gè)消息隊(duì)列中的每一個(gè)消息隊(duì)列對(duì)應(yīng)一個(gè)隊(duì)列優(yōu)先級(jí)，每一個(gè)消息隊(duì)列中存儲(chǔ)與其隊(duì)列優(yōu)先級(jí)匹配的消息，中間件服務(wù)中存儲(chǔ)至少一個(gè)消息處理對(duì)象，至少一個(gè)消息處理對(duì)象中的每一個(gè)消息處理對(duì)象對(duì)應(yīng)多個(gè)消息隊(duì)列中的至少一個(gè)消息隊(duì)列，至少一個(gè)消息隊(duì)列屬于同一類別；中間件服務(wù)，用于按照隊(duì)列優(yōu)先級(jí)，依次將多個(gè)消息隊(duì)列中的待處理消息傳輸至多個(gè)消息隊(duì)列對(duì)應(yīng)的目標(biāo)消息處理對(duì)象中；以利用目標(biāo)消息處理對(duì)象對(duì)待處理消息進(jìn)行消息處理。

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

本申請(qǐng)涉及信號(hào)處理領(lǐng)域，尤其涉及一種消息處理方法及系統(tǒng)、存儲(chǔ)介質(zhì)。

背景技術(shù)

通常，系統(tǒng)中的控制過(guò)程包括一組人物，任務(wù)通過(guò)嵌入式處理器(System OnChip，SOC)和實(shí)時(shí)操作系統(tǒng)(Real Time Operating System，RTOS)實(shí)時(shí)操作系統(tǒng)，其中系統(tǒng)可以是一個(gè)復(fù)雜的通信系統(tǒng)、工業(yè)控制系統(tǒng)或者自動(dòng)中央控制單元。通常情況下，控制過(guò)程包括大量獨(dú)立的功能任務(wù)，這些任務(wù)處理與系統(tǒng)事務(wù)操作有關(guān)的消息和事件，任務(wù)使用其專用堆棧進(jìn)行維護(hù)以進(jìn)行上下文保存，并有RTOS預(yù)定義的優(yōu)先級(jí)進(jìn)行調(diào)度，由于系統(tǒng)中不斷發(fā)展的新功能，會(huì)導(dǎo)致系統(tǒng)復(fù)雜性的增加、進(jìn)而導(dǎo)致任務(wù)的數(shù)量成倍增加；而任務(wù)數(shù)量的增加會(huì)增加RTOS的交互，進(jìn)而增加系統(tǒng)的延時(shí)以及降低系統(tǒng)的性能。

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

本申請(qǐng)實(shí)施例提供一種消息處理方法及系統(tǒng)、存儲(chǔ)介質(zhì)，能夠降低系統(tǒng)的延時(shí)、提高系統(tǒng)的性能。

本申請(qǐng)的技術(shù)方案是這樣實(shí)現(xiàn)的：

第一方面，本申請(qǐng)實(shí)施例提供一種消息處理系統(tǒng)，所述系統(tǒng)包括：面向消息的中間件服務(wù)和多個(gè)消息隊(duì)列；所述多個(gè)消息隊(duì)列中的每一個(gè)消息隊(duì)列對(duì)應(yīng)一個(gè)隊(duì)列優(yōu)先級(jí)，所述每一個(gè)消息隊(duì)列中存儲(chǔ)與其隊(duì)列優(yōu)先級(jí)匹配的消息，所述中間件服務(wù)中存儲(chǔ)至少一個(gè)消息處理對(duì)象，所述至少一個(gè)消息處理對(duì)象中的每一個(gè)消息處理對(duì)象對(duì)應(yīng)所述多個(gè)消息隊(duì)列中的至少一個(gè)消息隊(duì)列，所述至少一個(gè)消息隊(duì)列屬于同一類別；

所述中間件服務(wù)，用于按照所述隊(duì)列優(yōu)先級(jí)，依次將所述多個(gè)消息隊(duì)列中的待處理消息傳輸至所述多個(gè)消息隊(duì)列對(duì)應(yīng)的目標(biāo)消息處理對(duì)象中；以利用所述目標(biāo)消息處理對(duì)象對(duì)所述待處理消息進(jìn)行消息處理。

第二方面，本申請(qǐng)實(shí)施例提供一種消息處理方法，應(yīng)用于消息處理系統(tǒng)，所述消息處理系統(tǒng)包括面向消息的中間件服務(wù)和多個(gè)消息隊(duì)列，所述多個(gè)消息隊(duì)列中的每一個(gè)消息隊(duì)列對(duì)應(yīng)一個(gè)隊(duì)列優(yōu)先級(jí)，所述每一個(gè)消息隊(duì)列中存儲(chǔ)與其隊(duì)列優(yōu)先級(jí)匹配的消息，所述中間件服務(wù)存儲(chǔ)至少一個(gè)消息處理對(duì)象；所述方法包括：

通過(guò)所述中間件服務(wù)按照所述消息隊(duì)列的隊(duì)列優(yōu)先級(jí)，依次調(diào)度多個(gè)消息隊(duì)列中的待處理消息，并依次查找所述多個(gè)消息隊(duì)列對(duì)應(yīng)的目標(biāo)消息處理對(duì)象；

利用所述目標(biāo)消息處理對(duì)象對(duì)所述待處理消息進(jìn)行消息處理。

第三方面，本申請(qǐng)實(shí)施例提供一種存儲(chǔ)介質(zhì)，其上存儲(chǔ)有計(jì)算機(jī)程序，該計(jì)算機(jī)程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)如上述任一項(xiàng)所述的方法。