[發明專利]一種上下線消息的接收處理方法和裝置

有效

• 申請號: 201710178636.9
• 申請日: 2017-03-23
• 公開（公告）號: CN106888384B
• 公開（公告）日: 2019-08-30
• 發明（設計）人: 溫雷;李順龍;冷曉林;趙文博;王輝
• 申請（專利權）人: 北京奇藝世紀科技有限公司
• 主分類號: H04N21/2187
• 分類號: H04N21/2187;H04N21/24;H04N21/262
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 王寶筠

技術領域

本發明涉及視頻直播領域，更具體地說，涉及一種上下線消息的接收處理方法和裝置。

背景技術

近年來，視頻直播行業迎來了里程碑式的大爆發。視頻直播的實現過程：用戶通過視頻播放終端向服務器發出直播請求，服務器根據直播請求信息，是將該直播頻道的播放地址發送給視頻播放終端，視頻播放終端根據該地址加入對應的直播房間，即可接收到該直播視頻的碼流了。有一個非常顯見的場景是熱門視頻直播間人數可能達到幾十萬人，視頻直播中龐大的用戶訪問量會引發卡頓、宕機、網站崩潰、用戶無法訪問等異常情況。異常情況的發生容易引起僵尸用戶的產生，即下線的用戶還存在業務端的用戶在線列表中。

發明內容

有鑒于此，本發明提出一種上下線消息的接收處理方法和裝置，以減少僵尸用戶的存在，提高用戶在線列表的準確性。

為了實現上述目的，現提出的方案如下：

一種上下線消息的接收處理方法，包括：

接收接入服務器發送的上線消息和下線消息；

解析得到每個所述上線消息包含的第一標識，第一標識包括用戶標識和視頻直播間標識，將第一標識對應的引用計數器的計數值加1，并將每個所述上線消息存儲在無序集合中；

解析得到每個所述下線消息包含的第二標識，第二標識包括用戶標識和視頻直播間標識，從所述無序集合中匹配與下線消息對應的上線消息，且在匹配成功后將匹配得到的上線消息從所述無序集合中刪除，并將與刪除的上線消息包含的第一標識對應的引用計數器的引用計數器的計數值減1；

判斷引用計數器的計數值是否大于零，若否，則發送下線消息通知業務端進行下線處理，每個引用計數器的初始值為零。

優選的，在所述接收接入服務器發送的上線消息和下線消息后，還包括；

將所述上線消息和所述下線消息存儲至本地緩存隊列；

異步從所述本地緩存隊列獲取所述上線消息和所述下線消息。

優選的，在所述將與刪除的上線消息包含的第一標識對應的引用計數器的引用計數器的計數值減1后，還包括：

如果引用計數器的計數值大于零，則判斷所述無序集合中與該引用計數器對應的所有上線消息是否存在非真實在線的上線消息，若是，則設置該引用計數器的計數值為真實在線的上線消息的數量。

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

針對每個引用計數器，監測其計數值大于零的時間是否大于預設時間，若是，則發送下線消息通知業務端進行下線處理。

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

根據所述無序集合中存儲的上線消息對所述業務端的在線列表進行校正。

一種上下線消息的接收處理裝置，包括：

接收單元，用于接收接入服務器發送的上線消息和下線消息；

第一處理單元，用于解析得到每個所述上線消息包含的第一標識，第一標識包括用戶標識和視頻直播間標識，將第一標識對應的引用計數器的計數值加1，并將每個所述上線消息存儲在無序集合中；

第二處理單元，用于解析得到每個所述下線消息包含的第二標識，第二標識包括用戶標識和視頻直播間標識，從所述無序集合中匹配與下線消息對應的上線消息，且在匹配成功后將匹配得到的上線消息從所述無序集合中刪除，并將與刪除的上線消息包含的第一標識對應的引用計數器的引用計數器的計數值減1；

第一調整單元，用于判斷引用計數器的計數值是否大于零，若否，則發送下線消息通知業務端進行下線處理，每個引用計數器的初始值為零。

優選的，所述裝置，還包括：

緩存單元，用于將所述上線消息和所述下線消息存儲至本地緩存隊列；

異步獲取單元，用于異步從所述本地緩存隊列獲取所述上線消息和所述下線消息。

優選的，所述裝置，還包括：

第二調整單元，用于在所述將與刪除的上線消息包含的第一標識對應的引用計數器的引用計數器的計數值減1后，如果引用計數器的計數值大于零，則判斷所述無序集合中與該引用計數器對應的所有上線消息是否存在非真實在線的上線消息，若是，則設置該引用計數器的計數值為真實在線的上線消息的數量。

優選的，所述裝置，還包括：

第三調節單元，用于根據所述無序集合中存儲的上線消息對所述業務端的在線列表進行校正。

優選的，所述裝置，還包括：

第四調節單元，用于針對每個引用計數器，監測其計數值大于零的時間是否大于預設時間，若是，則發送下線消息通知業務端進行下線處理。