PHP實現直播推流功能

隨著網路的不斷發展，直播已經成為了人們日常生活中不可或缺的一部分，而直播推流功能則是實現直播的關鍵。 PHP的出現，為Web應用程式開發帶來了強大的工具，實現直播推流功能也不例外。本文將介紹如何使用PHP實現直播推流功能。

一、瞭解直播推流的基本原理

在介紹如何實現直播推流功能之前，需要先了解直播推流的基本原理。直播推流是指在用戶進行直播時，將視訊資料上傳至伺服器並分發到其他用戶的過程。具體來講，其包含兩個基本環節：直播上傳和直播分發。

直播上傳指將使用者上傳的視訊資料進行處理和存儲，並進行即時轉碼，以滿足不同終端設備的播放需求。直播分發則是指將經過處理的視訊資料傳送給其他用戶，讓其他用戶進行觀看。通常直播分發分為兩個環節：伺服器分發和P2P分發。

二、使用PHP實作直播上傳

在PHP中，有不少函式庫可用於實作直播上傳。常用的函式庫包括FFmpeg，Libav和H264 Streaming Module等。這些函式庫都是基於C/C 語言編寫的，透過PHP的FFI擴充可以實現PHP與C/C 的互通。具體實作過程如下：

1.安裝FFI擴充

在PHP中使用FFI擴展，需要先安裝擴充。可以在PHP的官網（https://www.php.net/manual/zh/ffi.installation.php）上下載FFI擴展，或使用套件管理器進行安裝。安裝完成後，在php.ini檔案中加入以下程式碼：

extension=ffi.so

2.使用FFmpeg實作影片編碼

#使用FFmpeg對視訊資料進行編碼，需要將視訊資料分成若干幀，每幀進行編碼轉換。具體實作過程如下：

use FFI;

$ffi = FFI::cdef('
    typedef struct AVCodecParameters AVCodecParameters;
    typedef struct AVCodecContext AVCodecContext;
    typedef struct AVPacket AVPacket;
    typedef struct AVFrame AVFrame;
    typedef struct AVCodec AVCodec;
    typedef struct SwsContext SwsContext;

    AVCodec *avcodec_find_encoder(enum AVCodecID id);
    AVCodecContext *avcodec_alloc_context3(AVCodec *codec);
    int avcodec_parameters_to_context(AVCodecContext *codec_ctx, const AVCodecParameters *par);
    int avcodec_open2(AVCodecContext *avctx, const AVCodec *codec, AVDictionary **options);
    int avcodec_send_frame(AVCodecContext *avctx, const AVFrame *frame);
    int avcodec_receive_packet(AVCodecContext *avctx, AVPacket *avpkt);
    AVFrame *av_frame_alloc();
    void av_frame_free(AVFrame **frame);
    SwsContext* sws_getContext(int srcW, int srcH, enum AVPixelFormat srcFormat, int dstW, int dstH, enum AVPixelFormat dstFormat, int flags, SwsFilter *srcFilter, SwsFilter *dstFilter, const double *param);
    const uint8_t **av_fifo_generic_read(AVFifoBuffer *f, void *dest, int buf_size, void *(*func)(void *, const void *, size_t), void *dest_ctx);
    int av_fifo_size(const AVFifoBuffer *f);
    void av_fifo_reset(AVFifoBuffer *f);
    void av_fifo_free(AVFifoBuffer *f);
    int sws_scale(SwsContext *c, const uint8_t *const srcSlice[], const int srcStride[], int srcSliceY, int srcSliceH, uint8_t *const dst[], const int dstStride[]);
    #define AV_CODEC_ID_H264 AV_CODEC_ID_MPEG4
    #define AV_PIX_FMT_YUV420P AV_PIX_FMT_YUVJ420P
', 'libavcodec.so.58.54.100, libavutil.so.56.55.100, libavformat.so.58.29.100, libswscale.so.5.5.100');

$codec = $ffi->avcodec_find_encoder(AV_CODEC_ID_H264);
$codec_ctx = $ffi->avcodec_alloc_context3($codec);
$options = null;
$width = 640;
$height = 480;
$frame_rate = 25;
$bit_rate = 400000;
$codec_ctx->width = $width;
$codec_ctx->height = $height;
$codec_ctx->pix_fmt = AV_PIX_FMT_YUV420P;
$codec_ctx->bit_rate = $bit_rate;
$codec_ctx->time_base = FFI::new('AVRational');
$codec_ctx->time_base->num = 1;
$codec_ctx->time_base->den = $frame_rate;
$codec_ctx->gop_size = $frame_rate * 2;
$codec_ctx->max_b_frames = 1;
$codec_ctx->rc_buffer_size = $bit_rate;
$codec_ctx->rc_max_rate = $bit_rate;
$codec_ctx->rc_min_rate = $bit_rate;
$codec_ctx->codec_tag = $codec->id;
$codec_ctx->flags |= AV_CODEC_FLAG_GLOBAL_HEADER;

if ($codec->id == AV_CODEC_ID_H264) {
    $codec_ctx->profile = FF_PROFILE_H264_BASELINE;
    $codec_ctx->level = 30;
}

if ($ffi->avcodec_open2($codec_ctx, $codec, $options) < 0) {
    throw new Exception('Cannot init encoder');
}

$codec_pkt = $ffi->new('AVPacket[1]');
$frame = $ffi->av_frame_alloc();
$frame->format = AV_PIX_FMT_YUV420P;
$frame->width = $width;
$frame->height = $height;
$ffi->av_frame_get_buffer($frame, 32);

$sws = $ffi->sws_getContext(
    $width, $height, AV_PIX_FMT_RGB24,
    $width, $height, AV_PIX_FMT_YUV420P,
    SWS_FAST_BILINEAR, null, null, null);

$buffer = $ffi->malloc($width * $height * 3);
$i = 0;
while ($i < 120) {
    $i++;
    //$buffer = 获取一帧RGB24像素数据
    $image = 'data://' . base64_encode($buffer);
    $img = imagecreatefromstring(file_get_contents($image));
    $rgb = imagecreatetruecolor($width, $height);
    imagecopyresampled($rgb, $img, 0, 0, 0, 0, $width, $height, $width, $height);
    $rgb_buffer = $ffi->new('uint8_t[?]', $width * $height * 3);
    $p = $ffi->cast('char *', $ffi->addr($rgb_buffer));
    $linesize = $ffi->new('int[3]', [$width * 3, 0, 0]);
    $ffi->av_image_fill_arrays($frame->data, $frame->linesize, $p, AV_PIX_FMT_RGB24, $width, $height, 1);
    $ffi->sws_scale($sws, [$p], $linesize, 0, $height, $frame->data, $frame->linesize);
    $frame->pts = $i;
    $ret = $ffi->avcodec_send_frame($codec_ctx, $frame);
    if ($ret < 0) {
        throw new Exception('Cannot encode video frame');
    }
    while ($ret >= 0) {
        $ret = $ffi->avcodec_receive_packet($codec_ctx, $codec_pkt);
        if ($ret < 0) {
            break;
        }
        //将$codec_pkt->data中的视频数据作为流推送到服务器，代码略
        $ffi->av_packet_unref($codec_pkt);
    }   
}

上述程式碼使用FFmpeg對取得到的RGB24像素資料進行編碼轉換，並將轉換後的視訊資料推送到伺服器。如果要使用不同的編碼器，只需要替換掉上述程式碼中的AV_CODEC_ID_H264即可。

三、使用PHP實現直播分發

PHP實現直播分發的方式有很多，包括伺服器分發和P2P分發兩種方式。伺服器分發指將處理後的視訊資料透過串流傳送到伺服器，中間伺服器可以進行視訊的轉碼和分發；P2P分發指直接透過UDP協定將視訊資料分發給其他使用者。

以下是透過Ratchet框架實作伺服器分發的程式碼：

use RatchetServerIoServer;
use RatchetWebSocketWsServer;
use AppVideoServer;

require dirname(__DIR__) . '/vendor/autoload.php';

$server = IoServer::factory(new WsServer(new VideoServer()), 8080);
$server->run();

use RatchetConnectionInterface;
use RatchetMessageComponentInterface;
use ReactEventLoopFactory;
use ReactEventLoopLoopInterface;
use ReactStreamReadableResourceStream;

class VideoServer implements MessageComponentInterface {
    protected $clients;
    /** @var LoopInterface $loop */
    protected $loop;
    protected $sourceUrl;
    protected $sourceRenderer;

    public function __construct() {
        $this->clients = new SplObjectStorage();
        $this->loop = Factory::create();
        $this->sourceUrl = '';
        $this->sourceRenderer = null;
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        $conn->on('close', function() use ($conn) {
            $this->clients->detach($conn);
            if ($this->clients->count() === 0 && $this->sourceRenderer !== null) {
                $this->sourceRenderer->close();
                $this->sourceRenderer = null;
            }
        });

        if ($this->sourceRenderer === null) {
            $this->loop->futureTick(function() use ($conn) {
                $conn->send('Waiting for source video stream...');
            });
            return;
        }

        $resource = new ReadableResourceStream($this->sourceRenderer->stdout, $this->loop);
        $resource->on('data', function ($chunk) use ($conn) {
            foreach ($this->clients as $client) {
                if ($client !== $conn) {
                    $client->send($chunk);
                }
            }
        });
    }
    
    public function onMessage(ConnectionInterface $from, $msg) {
        if ($this->sourceRenderer === null) {
            $this->sourceUrl = trim($msg);
            $this->sourceRenderer = new ReactChildProcessProcess('ffmpeg -i ' . escapeshellarg($this->sourceUrl) . ' -c:v libx264 -preset superfast -tune zerolatency -b:v 400k -pix_fmt yuv420p -r 30 -f mpegts -');
            $this->sourceRenderer->start($this->loop);
        }
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        if ($this->clients->count() === 0 && $this->sourceRenderer !== null) {
            $this->sourceRenderer->close();
            $this->sourceRenderer = null;
        }
    }

    public function onError(ConnectionInterface $conn, Exception $e) {}
}

上述程式碼透過Ratchet框架實作WebSocket伺服器。當有用戶連接到伺服器時，伺服器開啟子進程運行FFmpeg進行視訊串流的處理，並透過WebSocket將處理後的視訊串流推送給用戶。如果有多個使用者連接到伺服器，伺服器會即時將處理後的視訊串流分發給各個用戶。

四、總結

本文介紹如何使用PHP實現直播推流功能。首先透過呼叫FFmpeg對視訊資料進行編碼，然後透過串流將編碼後的視訊資料推送到伺服器，最後透過Ratchet框架實現伺服器分發，將處理後的視訊串流即時分發給使用者。這些技術對於實現高效的直播推流功能至關重要，可以幫助開發者輕鬆地完成直播應用程式的開發。

以上是PHP實現直播推流功能的詳細內容。更多資訊請關注PHP中文網其他相關文章！