[發(fā)明專(zhuān)利]一種數(shù)據(jù)處理方法、裝置、服務(wù)器以及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202010013795.5
• 申請(qǐng)日: 2020-01-07
• 公開(kāi)（公告）號(hào): CN111240859A
• 公開(kāi)（公告）日: 2020-06-05
• 發(fā)明（設(shè)計(jì)）人: 黃智勇
• 申請(qǐng)（專(zhuān)利權(quán)）人: 北京達(dá)佳互聯(lián)信息技術(shù)有限公司
• 主分類(lèi)號(hào): G06F9/54
• 分類(lèi)號(hào): G06F9/54;G06Q10/10;G06Q50/00
• 代理公司: 北京中博世達(dá)專(zhuān)利商標(biāo)代理有限公司 11274
• 代理人: 申健

本公開(kāi)關(guān)于一種數(shù)據(jù)處理方法、裝置、服務(wù)器以及存儲(chǔ)介質(zhì)，涉及網(wǎng)絡(luò)技術(shù)領(lǐng)域，使得消費(fèi)服務(wù)能夠得到快速的重啟，并且不會(huì)導(dǎo)致任務(wù)的丟失。具體方案為：接收重啟消息，該重啟消息用于指示重啟消費(fèi)服務(wù)。響應(yīng)于該重啟消息，將目標(biāo)任務(wù)存儲(chǔ)到消息隊(duì)列，并重啟該消費(fèi)服務(wù)，該目標(biāo)任務(wù)是該消費(fèi)服務(wù)正在執(zhí)行的一個(gè)或多個(gè)消費(fèi)任務(wù)，該消息隊(duì)列用于存儲(chǔ)等待被執(zhí)行的消費(fèi)任務(wù)。在該消費(fèi)服務(wù)重啟后，從該消息隊(duì)列中獲取該目標(biāo)任務(wù)。調(diào)用該消費(fèi)服務(wù)執(zhí)行該目標(biāo)任務(wù)。

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

本公開(kāi)涉及網(wǎng)絡(luò)技術(shù)領(lǐng)域，尤其涉及一種數(shù)據(jù)處理方法、裝置、服務(wù)器以及存儲(chǔ)介質(zhì)。

背景技術(shù)

目前，用戶將拍攝的視頻通過(guò)手機(jī)等移動(dòng)終端上傳到網(wǎng)絡(luò)平臺(tái)(如視頻平臺(tái)等)，通過(guò)網(wǎng)絡(luò)平臺(tái)展示給其他用戶，已經(jīng)成為非常普遍的一種社交方式。其中，網(wǎng)絡(luò)平臺(tái)在收到用戶通過(guò)其移動(dòng)終端上傳的視頻之后，一般會(huì)對(duì)該視頻進(jìn)行審核，確保該視頻符合相關(guān)規(guī)定后，再展示給其他用戶。示例性的，網(wǎng)絡(luò)平臺(tái)在接收到用戶上傳的視頻后，可以發(fā)起審核任務(wù)，以便對(duì)該視頻進(jìn)行審核。網(wǎng)絡(luò)平臺(tái)可以提供消費(fèi)服務(wù)，用于執(zhí)行該審核任務(wù)，即對(duì)該審核任務(wù)對(duì)應(yīng)的視頻進(jìn)行審核。

其中，當(dāng)審核的規(guī)則出現(xiàn)變化或者現(xiàn)有審核邏輯存在漏洞時(shí)，需要對(duì)消費(fèi)服務(wù)進(jìn)行更新。一般而言，更新后的消費(fèi)服務(wù)重啟才能生效。相關(guān)技術(shù)中，提供了兩種消費(fèi)服務(wù)重啟的方法：

1)、在需要重啟現(xiàn)有消費(fèi)服務(wù)時(shí)，如果存在審核任務(wù)正在被執(zhí)行，則可等待該任務(wù)完成后再執(zhí)行重啟。應(yīng)用該方案進(jìn)行消費(fèi)服務(wù)的重啟，會(huì)使得消費(fèi)服務(wù)重啟等待較長(zhǎng)時(shí)間，導(dǎo)致消費(fèi)服務(wù)更新不夠及時(shí)。

2)、在需要重啟現(xiàn)有消費(fèi)服務(wù)時(shí)，立即或者在短時(shí)間內(nèi)執(zhí)行重啟。應(yīng)用該方案進(jìn)行消費(fèi)服務(wù)的重啟，雖然能夠及時(shí)地更新消費(fèi)服務(wù)，但由于消費(fèi)服務(wù)一旦被執(zhí)行，會(huì)被從消息隊(duì)列中移除，因此該方案會(huì)導(dǎo)致正在被執(zhí)行的審核任務(wù)丟失。

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

本公開(kāi)提供一種數(shù)據(jù)處理方法、裝置、服務(wù)器以及存儲(chǔ)介質(zhì)，使得消費(fèi)服務(wù)能夠得到快速的重啟，并且不會(huì)導(dǎo)致任務(wù)的丟失。本公開(kāi)的技術(shù)方案如下：

根據(jù)本公開(kāi)實(shí)施例的第一方面，提供一種數(shù)據(jù)處理方法，該方法包括：接收重啟消息，該重啟消息用于指示重啟消費(fèi)服務(wù)。響應(yīng)于該重啟消息，將目標(biāo)任務(wù)存儲(chǔ)到消息隊(duì)列，并重啟該消費(fèi)服務(wù)，該目標(biāo)任務(wù)是該消費(fèi)服務(wù)正在執(zhí)行的一個(gè)或多個(gè)消費(fèi)任務(wù)，該消息隊(duì)列用于存儲(chǔ)等待被執(zhí)行的消費(fèi)任務(wù)。在該消費(fèi)服務(wù)重啟后，從該消息隊(duì)列中獲取該目標(biāo)任務(wù)。調(diào)用該消費(fèi)服務(wù)執(zhí)行該目標(biāo)任務(wù)。基于該方案，當(dāng)接收到重啟消費(fèi)任務(wù)的重啟消息時(shí)，可以將正在被執(zhí)行的第一任務(wù)重新存儲(chǔ)到消息隊(duì)列中，使得不需等待該第一任務(wù)執(zhí)行完成后才重啟，并且在重啟之后第一任務(wù)還可以被獲取并執(zhí)行。

可選地，在該接收重啟消息后，該方法還包括：響應(yīng)于該重啟消息，將退出狀態(tài)碼設(shè)置為第一值，被設(shè)置為該第一值的該退出狀態(tài)碼用于指示接收到指示重啟該消費(fèi)服務(wù)的消息。基于該方案，當(dāng)接收到重啟消費(fèi)服務(wù)的重啟消息后，可以設(shè)置退出狀態(tài)碼為第一值，使得退出狀態(tài)碼能夠標(biāo)示當(dāng)前已經(jīng)收到重啟消費(fèi)服務(wù)的重啟消息。

可選地，在該消費(fèi)服務(wù)重啟后，將該退出狀態(tài)碼設(shè)置為第二值，被設(shè)置為該第二值的該退出狀態(tài)碼用于指示未接收到指示重啟該消費(fèi)服務(wù)的消息。基于該方案，在啟動(dòng)消費(fèi)服務(wù)時(shí)設(shè)置退出狀態(tài)碼，使得退出狀態(tài)碼能夠在消費(fèi)服務(wù)運(yùn)行過(guò)程中準(zhǔn)確地標(biāo)示是否收到了重啟消費(fèi)服務(wù)的重啟消息。例如，當(dāng)退出狀態(tài)碼為第二值時(shí)，則表明并未受到重啟消費(fèi)服務(wù)的命令，消費(fèi)服務(wù)可以繼續(xù)正常工作。

可選地，在接收重啟消息之前，該方法還包括：在目標(biāo)任務(wù)被發(fā)起時(shí)，將目標(biāo)任務(wù)存儲(chǔ)到消息隊(duì)列中。從該消息隊(duì)列中獲取該目標(biāo)任務(wù)，該目標(biāo)任務(wù)在被獲取后，從該消息隊(duì)列中被刪除。調(diào)用該消費(fèi)服務(wù)執(zhí)行該目標(biāo)任務(wù)。基于該方案，目標(biāo)任務(wù)在被獲取后從消息隊(duì)列中刪除，可以有效地減少消息隊(duì)列中的無(wú)效數(shù)據(jù)量，使得消息隊(duì)列能夠占用有限的存儲(chǔ)空間不斷地對(duì)新的消費(fèi)任務(wù)提供存儲(chǔ)。在目標(biāo)任務(wù)被獲取后，就可以調(diào)用消費(fèi)服務(wù)來(lái)執(zhí)行該任務(wù)，使得消費(fèi)任務(wù)被正確執(zhí)行。