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

在審

• 申請?zhí)枺?/td>: 202010763403.7
• 申請日: 2020-07-31
• 公開（公告）號: CN111880910A
• 公開（公告）日: 2020-11-03
• 發(fā)明（設(shè)計）人: 王福業(yè);毛小冰;劉增輝
• 申請（專利權(quán)）人: 北京小米移動軟件有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F9/50
• 代理公司: 北京善任知識產(chǎn)權(quán)代理有限公司 11650
• 代理人: 康艷青

本公開是關(guān)于一種數(shù)據(jù)處理方法及裝置、服務(wù)器及存儲介質(zhì)。該方法包括：接收待處理的用戶事件；將所述待處理的用戶事件存儲至與待處理的用戶事件的事件屬性對應(yīng)的事件隊列；其中，不同事件屬性的所述用戶事件，對應(yīng)于不同的事件隊列；通過多個進(jìn)程，從所述事件隊列中讀取所述用戶事件進(jìn)行處理；從所述事件隊列中，刪除處理完的所述用戶事件。通過該方法，能提升用戶事件的處理速度，還能提升服務(wù)平臺的穩(wěn)定性。

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

本公開涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種數(shù)據(jù)處理方法及裝置、服務(wù)器及存儲介質(zhì)。

背景技術(shù)

隨著互聯(lián)網(wǎng)通信的發(fā)展，互聯(lián)網(wǎng)系統(tǒng)規(guī)模越來越大，用戶任務(wù)數(shù)量日益增多，任務(wù)也變得越來越復(fù)雜。尤其是在分布式環(huán)境下，存在多個業(yè)務(wù)系統(tǒng)，每個業(yè)務(wù)系統(tǒng)都有用戶任務(wù)的需求，如果都在自身系統(tǒng)中調(diào)度，一方面增加業(yè)務(wù)系統(tǒng)的復(fù)雜度，另一方面也不方便管理，因此需要有一個任務(wù)平臺對分散的任務(wù)進(jìn)行統(tǒng)一管理調(diào)度。

在對任務(wù)進(jìn)行管理時，如何采取有效的調(diào)度策略來快速執(zhí)行任務(wù)，提升任務(wù)平臺的穩(wěn)定性，成為亟待解決的問題。

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

本公開提供一種數(shù)據(jù)處理方法及裝置、服務(wù)器及存儲介質(zhì)。

根據(jù)本公開實(shí)施例的第一方面，提供一種數(shù)據(jù)處理方法，包括：

接收待處理的用戶事件；

將所述待處理的用戶事件存儲至與待處理的用戶事件的事件屬性對應(yīng)的事件隊列；其中，不同事件屬性的所述用戶事件，對應(yīng)于不同的事件隊列；

通過多個進(jìn)程，從所述事件隊列中讀取所述用戶事件進(jìn)行處理；

從所述事件隊列中，刪除處理完的所述用戶事件。

可選的，所述方法還包括：

確定位于同一個事件隊列中的所述用戶事件的優(yōu)先級；

根據(jù)所述優(yōu)先級，調(diào)整所述用戶事件在所述事件隊列中的位置；

其中，所述用戶事件從所述事件隊列的隊尾進(jìn)入所述事件隊列，并被所述進(jìn)程從所述事件隊列的隊頭取出。

可選的，所述確定位于同一個事件隊列中的所述用戶事件的優(yōu)先級，包括：

獲取同一個所述事件隊列中的所述用戶事件的時間信息；

根據(jù)所述時間信息對應(yīng)的時間，確定位于同一個所述事件隊列中的所述用戶事件的優(yōu)先級；其中，所述優(yōu)先級的高低，與所述用戶事件的時間信息對應(yīng)的時間遲早正相關(guān)。

可選的，所述通過多個進(jìn)程，從所述事件隊列中讀取所述用戶事件進(jìn)行處理，包括：

所述多個進(jìn)程中的一個進(jìn)程，從一個所述事件隊列的隊頭讀取所述用戶事件，并確定是否達(dá)到讀取的所述用戶事件的觸發(fā)時間；

若達(dá)到讀取的所述用戶事件的觸發(fā)時間，處理讀取的所述用戶事件。

可選的，所述通過多個所述進(jìn)程，從所述事件隊列中讀取所述用戶事件進(jìn)行處理，包括：

通過多個所述進(jìn)程，以輪詢的方式從不同的所述事件隊列中讀取并處理所述用戶事件。

可選的，所述方法還包括：

對多個所述事件隊列進(jìn)行隨機(jī)排序；

所述通過多個所述進(jìn)程，以輪詢的方式從不同的所述事件隊列中讀取并處理所述用戶事件，包括：

通過多個所述進(jìn)程，以輪詢的方式從隨機(jī)排序后不同的所述事件隊列中讀取并處理所述用戶事件。

可選的，所述事件屬性包括：指示所述用戶事件所屬用戶的用戶標(biāo)識；不同所述用戶標(biāo)識的用戶事件，對應(yīng)于不同的事件隊列中。