赛事直播系统，赛事直播系统开发指南，足球篮球电竞体育赛事直播系统源码，php赛事直播系统，java赛事直播系统

Clients
 ├─ 主播/裁判推流 (OBS/APP/SRT) --> RTMP/SRT --> 流媒体集群 (SRS/ZL)
 ├─ 观众 Web / Mobile --> HLS/HTTP-FLV/WebRTC --> CDN
 └─ Chat / 弹幕客户端 --> WebSocket / IM 服务

Backend Services
 ├─ API 服务 (PHP/Node) --> MySQL + Redis
 ├─ 流媒体回调处理 (on_publish/on_close)
 ├─ 异步任务 (转码/录制/统计)
 ├─ 礼物/打赏服务
 ├─ 赛事管理/排期/房间管理
 └─ 监控/运维/报警

Storage & Infra
 ├─ MySQL/Redis
 ├─ OSS/S3/MinIO (录制回放)
 ├─ CDN 分发
 ├─ Prometheus/Grafana 监控
 └─ 日志 ELK / Loki

CREATE TABLE users (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  username VARCHAR(64),
  password_hash VARCHAR(255),
  role TINYINT,
  created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

CREATE TABLE events (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  name VARCHAR(255),
  start_time DATETIME,
  end_time DATETIME,
  status TINYINT,
  created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

CREATE TABLE rooms (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  event_id BIGINT,
  owner_id BIGINT,
  stream_key VARCHAR(128),
  is_live TINYINT DEFAULT 0,
  viewers_count INT DEFAULT 0,
  hls_url VARCHAR(512),
  created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

CREATE TABLE streams (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  room_id BIGINT,
  start_at DATETIME,
  stop_at DATETIME,
  record_url VARCHAR(512)
);

CREATE TABLE messages (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  room_id BIGINT,
  user_id BIGINT,
  type VARCHAR(32),
  content TEXT,
  created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

          ┌─────────────┐
          │ 主播/裁判端 │
          │ OBS / APP   │
          └─────┬───────┘
                │ RTMP/SRT/WebRTC
                ▼
        ┌───────────────┐
        │ 流媒体服务器  │
        │ SRS/ZLMediaKit│
        └─────┬─────────┘
              │ HLS/FLV/WebRTC
              ▼
           CDN分发
              │
 ┌────────────┴─────────────┐
 │         观众端           │
 │ Web/APP/TV               │
 │ 播放 HLS/FLV/WebRTC      │
 │ 弹幕 WebSocket/IM         │
 └────────────┬─────────────┘
              │
              ▼
        ┌───────────────┐
        │ 业务后端 API  │
        │ PHP Laravel   │
        │ MySQL/Redis   │
        │ WebSocket/Swoole
        └─────┬─────────┘
              │
  ┌───────────┴────────────┐
  │ 异步任务/转码/录制 Worker│
  │ RabbitMQ/Kafka + FFmpeg │
  └───────────┬────────────┘
              │
      ┌───────┴────────┐
      │ 对象存储/OSS/S3 │
      │ 录制回放文件   │
      └────────────────┘

// app/Models/User.php
namespace App\Models;
use Illuminate\Foundation\Auth\User as Authenticatable;

class User extends Authenticatable {
    protected $fillable = ['username','password','role'];
}

// app/Models/Event.php
class Event extends Model {
    protected $fillable = ['name','start_time','end_time','status'];
}

// app/Models/Room.php
class Room extends Model {
    protected $fillable = ['event_id','owner_id','stream_key','is_live','viewers_count','hls_url'];
}

// app/Models/Stream.php
class Stream extends Model {
    protected $fillable = ['room_id','start_at','stop_at','record_url'];
}

// app/Http/Controllers/StreamHookController.php
namespace App\Http\Controllers;
use Illuminate\Http\Request;
use App\Models\Room;
use App\Models\Stream;

class StreamHookController extends Controller {
    // 推流开始
    public function onPublish(Request $request){
        $streamKey = $request->input('name');
        $room = Room::where('stream_key', $streamKey)->first();
        if(!$room) return response('Unauthorized', 401);
        
        $room->is_live = 1;
        $room->save();

        // 新增 stream 记录
        Stream::create([
            'room_id' => $room->id,
            'start_at' => now()
        ]);

        return response('OK', 200);
    }

    // 推流结束
    public function onClose(Request $request){
        $streamKey = $request->input('name');
        $room = Room::where('stream_key', $streamKey)->first();
        if(!$room) return response('Unauthorized', 401);

        $room->is_live = 0;
        $room->save();

        $stream = Stream::where('room_id',$room->id)->latest()->first();
        $stream->stop_at = now();
        $stream->save();

        // 触发异步任务: 转码/上传 OSS
        dispatch(new \App\Jobs\ProcessStream($stream));

        return response('OK', 200);
    }
}

// app/Http/Controllers/PlayTokenController.php
use Illuminate\Support\Str;
use Illuminate\Support\Facades\Cache;

class PlayTokenController extends Controller {
    public function getToken(Request $request, $roomId){
        $room = Room::findOrFail($roomId);
        $token = hash_hmac('sha256', $room->stream_key.'|'.time(), env('APP_KEY'));
        // 缓存 token 5分钟
        Cache::put('play_token_'.$token, $room->id, 300);
        return response()->json(['token'=>$token, 'hls_url'=>$room->hls_url]);
    }
}

// routes/api.php
use App\Http\Controllers\StreamHookController;
use App\Http\Controllers\PlayTokenController;

Route::post('/hook/on_publish', [StreamHookController::class,'onPublish']);
Route::post('/hook/on_close', [StreamHookController::class,'onClose']);
Route::get('/rooms/{id}/play-token', [PlayTokenController::class,'getToken']);

// app/Jobs/ProcessStream.php
namespace App\Jobs;
use App\Models\Stream;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;

class ProcessStream implements ShouldQueue {
    use Queueable;
    protected $stream;
    public function __construct(Stream $stream){ $this->stream = $stream; }
    public function handle(){
        $file = "/recordings/{$this->stream->id}.ts";
        $output = "/recordings/{$this->stream->id}.mp4";
        exec("ffmpeg -i $file -c:v copy -c:a copy $output");
        // 上传 OSS/S3 (示例)
        // Storage::disk('oss')->putFileAs('streams',$output,"{$this->stream->id}.mp4");
        $this->stream->record_url = "/oss/streams/{$this->stream->id}.mp4";
        $this->stream->save();
    }
}