workerman是一款高性能的php框架，它能夠通過異步非阻塞I/O實現千萬級并發連接，適合用于實時通訊、高并發服務器等場景。在本文中，我們將介紹如何使用Workerman框架開發一個基于websocket協議的視頻直播系統，包括搭建服務、實現直播視頻流的推送和接收、前端頁面的展示等。
一、搭建服務端
1.安裝Workerman依賴包：
運行以下命令安裝Workerman的依賴包：
composer require workerman/workerman
2.創建服務端
創建一個workerman.php文件，作為我們的服務端代碼。代碼如下：
<?php use WorkermanWorker; use WorkermanLibTimer; require_once __DIR__ . '/vendor/autoload.php'; // 創建一個Worker監聽2345端口，使用websocket協議通訊 $worker = new Worker("websocket://0.0.0.0:2345"); // 啟動4個進程對外提供服務 $worker->count = 4; // 客戶端連接時觸發 $worker->onConnect = function($connection) { echo "New client connected! "; }; // 客戶端請求時觸發 $worker->onMessage = function($connection, $data) { if(strpos($data, 'start') === 0) { // 該客戶端請求直播視頻流 $connection->send(getVideoStream()); // 啟動定時器，每秒向客戶端發送一份視頻流 $timer_id = Timer::add(1, function()use($connection){ $connection->send(getVideoStream()); }); // 將定時器ID綁定到連接上，方便后續停止定時器 $connection->timer_id = $timer_id; } else if(strpos($data, 'stop') === 0) { // 該客戶端停止請求直播視頻流 Timer::del($connection->timer_id); } else { // 其他請求，直接返回響應 $connection->send("Hello, $data!"); } }; // 客戶端斷開連接時觸發 $worker->onClose = function($connection) { // 清除定時器 Timer::del($connection->timer_id); echo "Client disconnected! "; }; // 以下是獲取直播視頻流的代碼，可以替換為你自己的視頻流獲取代碼 function getVideoStream() { $fp = fopen("videos/video.mp4", "rb"); $chunk_size = 1024*1024; // 每次讀取1MB $buffer = ""; while(!feof($fp)) { $buffer .= fread($fp, $chunk_size); ob_flush(); flush(); } fclose($fp); return $buffer; } // 運行worker Worker::runAll();
在上面的代碼中，我們創建了一個名為worker的Worker對象，并監聽2345端口，使用websocket協議通信。在onMessage回調函數中，如果客戶端發送了”start”消息，則表示客戶端想要請求直播視頻流。我們通過getVideoStream函數獲取視頻流，并使用定時器每秒向客戶端推送一份視頻流數據。如果客戶端發送了”stop”消息，則表示客戶端停止請求直播視頻流，我們關閉該連接對應的定時器。其他請求則直接返回響應。
2.創建視頻文件
我們在根目錄下創建一個videos文件夾，并在其中添加一個名為video.mp4的視頻文件。該視頻文件可以替換為你自己的直播視頻流。
3.啟動服務端
在命令行中進入到workerman.php所在的目錄，運行以下命令啟動服務端：
php workerman.php start
啟動成功后，服務端就監聽在2345端口上，可以接收來自客戶端的請求了。
二、實現客戶端
1.引入socket.io和video.JS
我們使用socket.io和video.js兩個庫實現客戶端的功能，需要在html頁面中引入這兩個庫。
<meta charset="UTF-8"><title>Video live demo</title><style> video { width: 800px; height: 600px; } </style><h1>Video live demo</h1> <button id="start">Start live</button> <button id="stop">Stop live</button> <br><br><video id="video-player" class="video-js vjs-default-skin"></video><script src="https://cdn.bootcss.com/socket.io/3.1.3/socket.io.js"></script><link href="https://cdn.bootcss.com/video.js/7.15.4/video-js.min.css" rel="stylesheet"><script src="https://cdn.bootcss.com/video.js/7.15.4/video.min.js"></script><script> var socket = io('http://localhost:2345'); var player = videojs('video-player'); // 點擊開始按鈕，向服務端發起請求獲取視頻流 document.querySelector('#start').addEventListener('click', function() { socket.send('start'); }); // 點擊結束按鈕，停止請求視頻流 document.querySelector('#stop').addEventListener('click', function() { socket.send('stop'); player.pause(); }); // 收到服務端推送的視頻流數據，開始播放視頻 socket.on('message', function(data) { player.src({ type: 'video/mp4', src: URL.createObjectURL(new Blob([data], { type: 'video/mp4' })) }); player.play(); }); </script>
在上面的代碼中，我們創建了一個簡單的html頁面，包括一個開始按鈕、一個結束按鈕和一個視頻播放器。當點擊開始按鈕時，向服務端發送”start”消息表示請求視頻流。當點擊結束按鈕時，向服務端發送”stop”消息表示停止請求視頻流，并暫停視頻播放。當收到服務端推送的視頻流數據時，我們使用URL.createObjectURL函數創建一個視頻流的URL，并將該URL傳遞給video.js的播放器進行播放。
2.啟動客戶端
在瀏覽器中訪問上述html頁面，點擊開始按鈕，即可開始播放直播視頻流。點擊停止按鈕，則停止請求視頻流并暫停視頻播放。
總結
通過使用Workerman框架和WebSocket協議，我們可以輕松實現一個高性能、低延遲的視頻直播系統。Workerman提供了異步非阻塞I/O的支持，能夠快速處理數百萬連接同時訪問的場景，為實時通訊、高并發服務器等領域帶來了極大的便利。本文中，我們用到了Workerman的異步通訊能力，在服務端和客戶端之間實現了實時視頻流的推送和接收，讓直播系統變得更加流暢和高效。
