[發明專利]一種分布式推流的方法、裝置及系統

有效

• 申請號: 201110451761.5
• 申請日: 2011-12-29
• 公開（公告）號: CN102547385A
• 公開（公告）日: 2012-07-04
• 發明（設計）人: 宋波
• 申請（專利權）人: 深圳市同洲視訊傳媒有限公司
• 主分類號: H04N21/238
• 分類號: H04N21/238;H04N21/63
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.一種分布式推流的方法，其特征在于，包括：

推流主控單元接收請求播放消息，并根據所述請求播放消息，獲得即將推送的切片；

所述推流主控單元向分布式文件系統詢問即將推送的切片的位置信息；

所述推流主控單元接收所述分布式文件系統返回的所述即將推送的切片所在的存儲節點信息，根據所述存儲節點信息找到對應的推流執行單元；

所述推流主控單元向所述推流執行單元發送推流消息；

所述推流執行單元根據所述推流消息，通過內部總線從所述分布式文件系統的存儲節點讀取所述即將推送的切片數據；

所述推流執行單元推送所述即將推送的切片數據。

2.如權利要求1所述的方法，其特征在于，在所述推流執行單元從所述緩存中推送數據的同時，還包括：

所述推流執行單元向所述推流主控單元發送獲取下一個推流執行單元的消息；

所述推流主控單元接收到獲取下一個推流執行單元的消息，根據下一個切片信息，向所述分布式文件系統詢問下一個切片的位置信息；

所述推流主控單元接收所述分布式文件系統返回的所述下一個切片所在的下一個存儲節點信息，根據所述下一個存儲節點信息找到對應的下一個推流執行單元，并將下一個推流執行單元信息返回所述推流執行單元；

當所述推流執行單元完成推送數據后，發送推流消息給所述下一個推流執行單元，所述下一個推流執行單元接收到所述推流消息后，推送下一個切片的數據。

3.如權利要求2所述的方法，其特征在于，在所述當所述推流執行單元完成推送數據后，發送推流消息給所述下一個推流執行單元，所述下一個推流執行單元接收到所述推流消息開始推送下一個切片的數據之前，還包括：

所述推流執行單元在完成推送數據前，向所述下一個推流執行單元發送準備推流消息，所述準備推流消息包括下一個切片信息、推送碼流大小、推流起始和終止位置、IP正交幅度調制器地址；

所述下一個推流執行單元接收到所述準備推流消息后，從所述分布式文件系統讀取下一個切片的數據到緩存。

4.如權利要求2所述的方法，其特征在于，在所述下一個推流執行單元接收到所述推流消息的步驟之后，推送下一個切片的數據的步驟之前，還包括步驟：判斷延時時間是否到達預設的延時時間。

5.如權利要求1所述的方法，其特征在于，所述根據所述存儲節點信息找到對應的推流執行單元還包括：

所述推流主控單元根據負載均衡策略，選擇其中一個推流執行單元。

6.如權利要求1所述的方法，其特征在于，還包括：所述推流消息包括即將推送的切片信息、推送碼流大小、推流起始和終止位置、IP正交幅度調制器地址。

7.一種視頻推流裝置，其特征在于，包括：

推流主控單元，用于接收請求播放消息，并根據所述請求播放消息，獲得即將推送的切片，向分布式文件系統詢問所述即將推送的切片的位置信息，并接收所述分布式文件系統返回的所述即將推送的切片所在的存儲節點信息，根據所述存儲節點信息找到對應的推流執行單元，并向對應的推流執行單元發送推流消息；

推流執行單元，設置在分布式文件系統的存儲節點中，與所述推流主控單元通過網絡相連，與所述分布式文件系統的存儲節點通過系統內部總線相連，接收所述推流消息，并根據所述推流消息，通過內部總線從所述分布式文件系統讀取即將推送的切片的數據，推送所述即將推送的切片的數據。

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

所述推流執行單元，還用于向所述推流主控單元發送獲取下一個推流執行單元的消息；

所述推流主控單元，還用于接收到獲取下一個推流執行單元的消息，根據下一個切片信息，向所述分布式文件系統詢問下一個切片的位置信息，接收所述分布式文件系統返回的所述下一個切片所在的下一個存儲節點信息，根據所述下一個存儲節點信息找到對應的下一個推流執行單元，并將下一個推流執行單元信息返回所述推流執行單元；

所述推流執行單元，還用于當完成推送數據后，發送推流消息給所述下一個推流執行單元，所述下一個推流執行單元接收到所述推流消息開始推送下一個切片的數據。