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

有效

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

1.一種上下線消息的接收處理方法，其特征在于，包括：

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

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

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

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

2.根據權利要求1所述的方法，其特征在于，在所述接收接入服務器發送的上線消息和下線消息后，還包括；

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

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

3.根據權利要求1所述的方法，其特征在于，在所述將與刪除的上線消息包含的第一標識對應的引用計數器的引用計數器的計數值減1后，還包括：

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

4.根據權利要求1所述的方法，其特征在于，所述方法，還包括：

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

5.根據權利要求1～4任意一項所述的方法，其特征在于，所述方法，還包括：

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

6.一種上下線消息的接收處理裝置，其特征在于，包括：

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

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

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

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

7.根據權利要求6所述的裝置，其特征在于，所述裝置，還包括：

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

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

8.根據權利要求6所述的裝置，其特征在于，所述裝置，還包括：

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

9.根據權利要求6所述的裝置，其特征在于，所述裝置，還包括：

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

10.根據權利要求6～9任意一項所述的裝置，其特征在于，所述裝置，還包括：

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