[發(fā)明專利]一種防止消息超時(shí)導(dǎo)致重啟的方法、系統(tǒng)、設(shè)備及介質(zhì)

有效

• 申請(qǐng)?zhí)枺?/td>: 202110023820.2
• 申請(qǐng)日: 2021-01-08
• 公開(kāi)（公告）號(hào): CN112860449B
• 公開(kāi)（公告）日: 2023-01-10
• 發(fā)明（設(shè)計(jì)）人: 尤波
• 申請(qǐng)（專利權(quán)）人: 蘇州浪潮智能科技有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 北京連和連知識(shí)產(chǎn)權(quán)代理有限公司 11278
• 代理人: 劉小峰;張騰

本發(fā)明公開(kāi)了一種防止消息超時(shí)導(dǎo)致重啟的方法、系統(tǒng)、設(shè)備和存儲(chǔ)介質(zhì)，方法包括：創(chuàng)建空隊(duì)列、請(qǐng)求隊(duì)列和超時(shí)隊(duì)列；響應(yīng)于接收到上級(jí)平臺(tái)的消息，從所述空隊(duì)列中選擇一個(gè)節(jié)點(diǎn)，根據(jù)所述消息對(duì)所述節(jié)點(diǎn)進(jìn)行賦值后放入所述請(qǐng)求隊(duì)列；響應(yīng)于所述請(qǐng)求隊(duì)列的當(dāng)前節(jié)點(diǎn)處理超時(shí)，判斷所述當(dāng)前節(jié)點(diǎn)是否已經(jīng)下發(fā)；以及響應(yīng)于所述當(dāng)前節(jié)點(diǎn)還未下發(fā)，將所述當(dāng)前節(jié)點(diǎn)發(fā)送到所述超時(shí)隊(duì)列中進(jìn)行處理，并將處理后的節(jié)點(diǎn)返回所述空隊(duì)列。本發(fā)明通過(guò)新增鏈表和回復(fù)假消息以避免消息的超時(shí)處理導(dǎo)致設(shè)備重啟，增強(qiáng)了設(shè)備的穩(wěn)定性，提升了產(chǎn)品的競(jìng)爭(zhēng)力。

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

本發(fā)明涉及消息隊(duì)列領(lǐng)域，更具體地，特別是指一種防止消息超時(shí)導(dǎo)致重啟的方法、系統(tǒng)、計(jì)算機(jī)設(shè)備及可讀介質(zhì)。

背景技術(shù)

作為存儲(chǔ)級(jí)別的上層平臺(tái)與驅(qū)動(dòng)交互對(duì)實(shí)時(shí)性的要求較高，驅(qū)動(dòng)對(duì)上級(jí)平臺(tái)的請(qǐng)求需要做到“有求必應(yīng)”，某些場(chǎng)景下，驅(qū)動(dòng)可能作為中間層，需要向下級(jí)驅(qū)動(dòng)透?jìng)飨?，下?jí)驅(qū)動(dòng)處理消息的能力和穩(wěn)定性得不到保證的前提下，提高系統(tǒng)的容錯(cuò)率，減小系統(tǒng)重啟次數(shù)增高重啟的閾值變得很有必要。

一般來(lái)說(shuō)，驅(qū)動(dòng)作為中間層上傳下達(dá)需要?jiǎng)?chuàng)建維護(hù)隊(duì)列，將維護(hù)隊(duì)列作為緩存將上級(jí)平臺(tái)的消息暫存起來(lái)并創(chuàng)建輪詢函數(shù)，每隔一段時(shí)間檢查隊(duì)列，將隊(duì)列中的消息下發(fā)或者返回(或執(zhí)行)。當(dāng)下級(jí)驅(qū)動(dòng)處理超時(shí)，上級(jí)平臺(tái)會(huì)認(rèn)為下級(jí)驅(qū)動(dòng)出現(xiàn)異常從而啟動(dòng)重啟機(jī)制，這會(huì)導(dǎo)致系統(tǒng)頻繁重啟，給用戶帶來(lái)不好的體驗(yàn)。

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

有鑒于此，本發(fā)明實(shí)施例的目的在于提出一種防止消息超時(shí)導(dǎo)致重啟的方法、系統(tǒng)、計(jì)算機(jī)設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，通過(guò)新增鏈表和回復(fù)假消息以避免消息的超時(shí)處理導(dǎo)致設(shè)備重啟，增強(qiáng)了設(shè)備的穩(wěn)定性，提高了用戶體驗(yàn)，提升了產(chǎn)品的競(jìng)爭(zhēng)力。

基于上述目的，本發(fā)明實(shí)施例的一方面提供了一種防止消息超時(shí)導(dǎo)致重啟的方法，包括如下步驟：創(chuàng)建空隊(duì)列、請(qǐng)求隊(duì)列和超時(shí)隊(duì)列；響應(yīng)于接收到上級(jí)平臺(tái)的消息，從所述空隊(duì)列中選擇一個(gè)節(jié)點(diǎn)，根據(jù)所述消息對(duì)所述節(jié)點(diǎn)進(jìn)行賦值后放入所述請(qǐng)求隊(duì)列；響應(yīng)于所述請(qǐng)求隊(duì)列的當(dāng)前節(jié)點(diǎn)處理超時(shí)，判斷所述當(dāng)前節(jié)點(diǎn)是否已經(jīng)下發(fā)；以及響應(yīng)于所述當(dāng)前節(jié)點(diǎn)還未下發(fā)，將所述當(dāng)前節(jié)點(diǎn)發(fā)送到所述超時(shí)隊(duì)列中進(jìn)行處理，并將處理后的節(jié)點(diǎn)返回所述空隊(duì)列。

在一些實(shí)施方式中，方法還包括：響應(yīng)于所述當(dāng)前節(jié)點(diǎn)已經(jīng)下發(fā)，調(diào)用函數(shù)對(duì)所述當(dāng)前節(jié)點(diǎn)進(jìn)行強(qiáng)制回復(fù)。

在一些實(shí)施方式中，方法還包括：響應(yīng)于接收到上級(jí)平臺(tái)的終止指令，判斷所述終止指令對(duì)應(yīng)的節(jié)點(diǎn)是否已經(jīng)下發(fā)；以及響應(yīng)于所述節(jié)點(diǎn)還未下發(fā)，將所述請(qǐng)求隊(duì)列中所述節(jié)點(diǎn)后的待處理節(jié)點(diǎn)放入所述超時(shí)隊(duì)列。

在一些實(shí)施方式中，方法還包括：調(diào)用輪詢函數(shù)將所述超時(shí)隊(duì)列中的所述待處理節(jié)點(diǎn)依次釋放。

本發(fā)明實(shí)施例的另一方面，還提供了一種防止消息超時(shí)導(dǎo)致重啟系統(tǒng)，包括：創(chuàng)建模塊，配置用于創(chuàng)建空隊(duì)列、請(qǐng)求隊(duì)列和超時(shí)隊(duì)列；寫(xiě)入模塊，配置用于響應(yīng)于接收到上級(jí)平臺(tái)的消息，從所述空隊(duì)列中選擇一個(gè)節(jié)點(diǎn)，根據(jù)所述消息對(duì)所述節(jié)點(diǎn)進(jìn)行賦值后放入所述請(qǐng)求隊(duì)列；判斷模塊，配置用于響應(yīng)于所述請(qǐng)求隊(duì)列的當(dāng)前節(jié)點(diǎn)處理超時(shí)，判斷所述當(dāng)前節(jié)點(diǎn)是否已經(jīng)下發(fā)；以及執(zhí)行模塊，配置用于響應(yīng)于所述當(dāng)前節(jié)點(diǎn)還未下發(fā)，將所述當(dāng)前節(jié)點(diǎn)發(fā)送到所述超時(shí)隊(duì)列中進(jìn)行處理，并將處理后的節(jié)點(diǎn)返回所述空隊(duì)列。

在一些實(shí)施方式中，系統(tǒng)還包括：回復(fù)模塊，配置用于響應(yīng)于所述當(dāng)前節(jié)點(diǎn)已經(jīng)下發(fā)，調(diào)用函數(shù)對(duì)所述當(dāng)前節(jié)點(diǎn)進(jìn)行強(qiáng)制回復(fù)。

在一些實(shí)施方式中，系統(tǒng)還包括終止模塊，配置用于：響應(yīng)于接收到上級(jí)平臺(tái)的終止指令，判斷所述終止指令對(duì)應(yīng)的節(jié)點(diǎn)是否已經(jīng)下發(fā)；以及響應(yīng)于所述節(jié)點(diǎn)還未下發(fā)，將所述請(qǐng)求隊(duì)列中所述節(jié)點(diǎn)后的待處理節(jié)點(diǎn)放入所述超時(shí)隊(duì)列。

在一些實(shí)施方式中，系統(tǒng)還包括：調(diào)用模塊，配置用于調(diào)用輪詢函數(shù)將所述超時(shí)隊(duì)列中的所述待處理節(jié)點(diǎn)依次釋放。

本發(fā)明實(shí)施例的又一方面，還提供了一種計(jì)算機(jī)設(shè)備，包括：至少一個(gè)處理器；以及存儲(chǔ)器，所述存儲(chǔ)器存儲(chǔ)有可在所述處理器上運(yùn)行的計(jì)算機(jī)指令，所述指令由所述處理器執(zhí)行時(shí)實(shí)現(xiàn)如上方法的步驟。