php直播系统源码-系统开发指南

原创

钠斯音视频开发-林经理

发布于 2025-10-24 17:51:57

3174

文章被收录于专栏：音视频开发音视频开发

1 概览 — 目标与定位

目标：用 PHP 构建一个支持 主播推流（RTMP）→ 流媒体转发（HLS/FLV/HTTP-FLV/可选WebRTC）→ 浏览器/移动端播放 的直播平台，具备房间管理、鉴权、弹幕/聊天室、礼物与支付、回放（录制）、基础监控。

适用场景：直播课堂、直播带货、社交直播、企业内网直播（私有化部署）。

2 技术选型（推荐）

流媒体：SRS 或 ZLMediaKit（生产推荐 SRS/ZLMediaKit；测试可用 nginx-rtmp）
后端：PHP 8.x + FPM（框架：Laravel / Hyperf / ThinkPHP，根据团队偏好；推荐 Laravel 便于生态）
即时通讯/聊天室：Swoole WebSocket（PHP）或 Node.js + Socket.IO。若要快速上线，也可用第三方 IM（腾讯云 IM、环信）接入。
存储：MySQL（主数据） + Redis（在线状态、限流、短期 token）
缓存/CDN：对象存储（OSS/MinIO）+ CDN（阿里/腾讯/Cloudflare）分发 HLS/TS。
容器与编排：Docker + Docker Compose / Kubernetes（生产）
日志/监控：Prometheus + Grafana + ELK（或 Loki）
CI/CD：GitHub Actions / GitLab CI

3 系统架构（分层）

用户/业务层（PHP API） — 房间管理、鉴权、礼物、订单、统计
实时层（WebSocket/IM） — 弹幕、聊天室、连麦信令
流媒体层（SRS/ZLMediaKit） — 接收 RTMP，产出 HTTP-FLV / HLS / WebRTC，提供 HTTP API 回调（on_publish/on_close）
存储层 — MySQL/Redis/对象存储
分发层 — CDN、边缘缓存

4 核心表设计（示例）

-- users, rooms, streams, messages, gifts, orders
CREATE TABLE users (id INT AUTO_INCREMENT PRIMARY KEY, username VARCHAR(64), password_hash VARCHAR(255), role TINYINT, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP);
CREATE TABLE rooms (id INT PRIMARY KEY AUTO_INCREMENT, owner_id INT, title VARCHAR(255), stream_key VARCHAR(128), is_live TINYINT DEFAULT 0, hls_url VARCHAR(512), created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP);
CREATE TABLE streams (id INT AUTO_INCREMENT PRIMARY KEY, room_id INT, start_at DATETIME, stop_at DATETIME, record_url VARCHAR(512));
CREATE TABLE messages (id BIGINT AUTO_INCREMENT PRIMARY KEY, room_id INT, user_id INT, type VARCHAR(32), content TEXT, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP);
CREATE TABLE gifts (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(64), price INT);
CREATE TABLE orders (id BIGINT AUTO_INCREMENT PRIMARY KEY, user_id INT, room_id INT, gift_id INT, amount INT, status VARCHAR(32), created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP);

5 关键流程与接口（示例）

主播创建房间 → 后端生成 stream_key（存 rooms）
主播用 OBS 推流：rtmp://STREAM_SERVER/live/{stream_key}
流媒体服务收到推流，触发 on_publish 回调到 PHP：PHP 验证 stream_key → 返回 2xx 允许推流 → 更新 rooms.is_live = 1，写入 streams 表 start_at
观众打开房间页 → 前端向 PHP 请求短期播放 token（签名、过期） → 前端用 flv.js 或 hls.js 拉流（带 token）
弹幕/聊天室通过 WebSocket（Swoole）连接 → 消息写入 Redis 并广播，落库异步化
结束推流 → 流媒体触发 on_publish_done → PHP 标记 stop_at、生成回放（若录制）

关键接口示例（REST）：

POST /api/room/create — 创建房间（返回 stream_key, room_id）
POST /api/auth/on_publish — (RTMP callback) 验证推流
GET /api/room/{id}/playtoken — 获取短期 play token
WS /ws?token=xxx — WebSocket 聊天/弹幕

6 代码片段（简化示例）

6.1 生成 stream_key（Laravel 风格）

function genStreamKey($userId) {
    return bin2hex(random_bytes(16)) . '-' . $userId;
}

6.2 nginx-rtmp / SRS on_publish 验证（示例 PHP）

// on_publish.php
<?php
// nginx-rtmp POST: name, ip, args...
$stream = $_POST['name'] ?? '';
$pdo = new PDO(...);
$stmt = $pdo->prepare("SELECT id FROM rooms WHERE stream_key = ? LIMIT 1");
$stmt->execute([$stream]);
if ($stmt->fetch()) {
    // update is_live etc
    http_response_code(200);
    echo "OK";
} else {
    http_response_code(403);
    echo "Forbidden";
}

6.3 生成播放短期 token（HMAC）

function createPlayToken($roomId, $secret, $expire=300) {
    $exp = time() + $expire;
    $payload = $roomId . '|' . $exp;
    $sig = hash_hmac('sha256', $payload, $secret);
    return base64_encode($payload . '|' . $sig);
}