[發(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
• 代理人: 康艷青

1.一種數(shù)據(jù)處理方法，其特征在于，所述方法包括：

接收待處理的用戶事件；

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

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

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

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

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

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

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

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述確定位于同一個事件隊列中的所述用戶事件的優(yōu)先級，包括：

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

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

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述通過多個進程，從所述事件隊列中讀取所述用戶事件進行處理，包括：

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

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

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述通過多個所述進程，從所述事件隊列中讀取所述用戶事件進行處理，包括：

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

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述方法還包括：

對多個所述事件隊列進行隨機排序；

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

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

7.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述事件屬性包括：指示所述用戶事件所屬用戶的用戶標(biāo)識；不同所述用戶標(biāo)識的用戶事件，對應(yīng)于不同的事件隊列中。

8.根據(jù)權(quán)利要求7所述的方法，其特征在于，所述將所述待處理的用戶事件存儲至與待處理的用戶事件的事件屬性對應(yīng)的事件隊列，包括：

以一致性哈希算法處理所述待處理的用戶事件的所述用戶標(biāo)識，得到哈希值；

將所述待處理的用戶事件，存儲到與所述哈希值對應(yīng)的所述事件隊列中。

9.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述通過多個進程，從所述事件隊列中讀取所述用戶事件進行處理，包括：

采用腳本調(diào)用的方式，通過多個所述進程從所述事件隊列中讀取所述用戶事件進行處理。

10.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

在滿足擴容條件時，增加一個或多個事件隊列。

11.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

在滿足縮容條件時，禁止向一個或多個所述事件隊列中存入用戶事件；

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