[發明專利]高效率低延遲上報讀取用戶在線播放信息的方法

有效

• 申請號: 202110461489.2
• 申請日: 2021-04-27
• 公開（公告）號: CN113139081B
• 公開（公告）日: 2023-10-27
• 發明（設計）人: 張志軍;任亮
• 申請（專利權）人: 中山億聯智能科技有限公司
• 主分類號: G06F16/71
• 分類號: G06F16/71;G06F16/73
• 代理公司: 深圳正和天下專利代理事務所(普通合伙) 44581
• 代理人: 楊波

1.一種高效率低延遲上報讀取用戶在線播放信息的方法，其特征在于，包括以下步驟：

S1、用戶在線播放的信息保存到系統專用緩沖區；

S2、當所述專用緩沖區中數據達到設定規模，或到達預先設定的提交時間時，批量將所有數據提交到redis數據庫。

2.根據權利要求1所述的高效率低延遲上報讀取用戶在線播放信息的方法，其特征在于，還包括步驟：

S3、當用戶開始播放節目，出現一條全新的播放記錄需要添加時；

S3.1、先使用redis中的hash結構來保存每條播放記錄的各項數據(play:pidxxx)；

S3.2、再使用redis中的有序集合結構保存所述S3.1中添加的新數據的唯一標識號。

3.根據權利要求2所述的高效率低延遲上報讀取用戶在線播放信息的方法，其特征在于，所述S3.2還包括：保存數據添加的時間(notic:plays:)；用于通知系統用戶開始播放節目，數據已經更新完成。

4.根據權利要求3所述的高效率低延遲上報讀取用戶在線播放信息的方法，其特征在于，還包括步驟：

S4、當用戶結束播放節目時,最后一次更新該播放記錄。

5.根據權利要求4所述的高效率低延遲上報讀取用戶在線播放信息的方法，其特征在于，所述步驟S4包括：

S4.1、更新保存對應播放記錄的hash結構；

S4.2、將該條播放記錄保存至另外一個hash結構(cache:vidxxx)，使用用戶標識作為鍵值，作為該用戶上一次播放的緩沖數據，并設置超時時間；

S4.3、將S4.2中的數據鍵值和當前時間保存至redis的有序集合中(cache:plays:),來記錄S4.2中每條緩存數據的最后更新時間

S4.4、通知系統用戶播放已斷開，數據已經更新，可以隨時讀取，使用有序集合play:pidxxx來完成，參考用戶開始播放時的第一步。

6.根據權利要求5所述的高效率低延遲上報讀取用戶在線播放信息的方法，其特征在于，所述步驟S4.3中，系統周期性的檢查這些數據的更新時間，將超過有效期時間的數據，批量讀取出來，轉化成歷史用戶記錄，并刪除cache:plays:以及這些超時的數據。

7.根據權利要求6所述的高效率低延遲上報讀取用戶在線播放信息的方法，其特征在于，還包括步驟：

S5、周期性的將持續播放的用戶信息批量的更新到數據庫，并檢查用于通知系統用戶開始結束播放的結構notice:plays:，緩存上一次播放記錄的結構cache:plays:的數據規模，剔除設定時間范圍和設定規模內的數據，防止數據記錄過多緩存數據。

8.根據權利要求2至7任一項所述的高效率低延遲上報讀取用戶在線播放信息的方法，其特征在于，所述步驟S3中：

S3.3、周期性的嘗試，從負責通知開始結束播放的有序集合notice:plays:結構中彈出多條數據，相對應的redis命令是zpopmin(key,1000)；

S3.4、使用S3.3中讀到的數據，作為鍵值來讀取保存所有播放記錄的結構play:pidxxx，判斷記錄時播放開始還是結束。

9.根據權利要求8所述的高效率低延遲上報讀取用戶在線播放信息的方法，其特征在于，當該條數據是播放結束，立即從數據庫redis中刪除該記錄。

10.根據權利要求8所述的高效率低延遲上報讀取用戶在線播放信息的方法，其特征在于，還包括步驟S6：

S6.1、周期批量的嘗試讀取超過設定時長記錄緩存上次播放記錄時間和標識的結構cache:plays:；

S6.2、讀取并刪除S6.1中讀取的數據，將讀到的數據轉變為歷史播放數據另外存儲。