دليل شامل لبرمجة تطبيق البث المباشر باستخدام PHP مع الأمثلة والكود

تُعد تطبيقات البث المباشر من التطبيقات الشائعة والمطلوبة في العصر الحالي، حيث تتيح للمستخدمين بث محتوى الفيديو والصوت مباشرة إلى جمهورهم في الوقت الفعلي. يمكن استخدام لغة البرمجة PHP لتطوير تطبيقات البث المباشر نظرًا لمرونتها وسهولة دمجها مع تقنيات الويب الأخرى. في هذا المقال، سنتعرف على كيفية برمجة تطبيق بث مباشر باستخدام PHP، وسنوضح الكود اللازم لتطوير هذا النوع من التطبيقات.

المتطلبات الأساسية

قبل البدء في برمجة تطبيق البث المباشر، يجب التأكد من توفر بعض المتطلبات الأساسية، وهي:

• خادم ويب (Web Server): مثل Apache أو Nginx.
• PHP: الإصدار 7 أو الأحدث.
• قاعدة بيانات: مثل MySQL لتخزين بيانات المستخدمين والبث.
• مكتبة ffmpeg: لمعالجة الفيديو وتحويل الصيغ.
• مكتبة WebSocket: لتبادل البيانات في الوقت الفعلي بين المستخدمين والخادم.

إعداد بيئة العمل

للبدء في برمجة تطبيق البث المباشر، يجب عليك إعداد بيئة العمل على خادم الويب. يمكن تنصيب مكتبة ffmpeg باستخدام الأوامر التالية على نظام Linux:

sudo apt-get update
sudo apt-get install ffmpeg

كما يمكن إعداد WebSocket باستخدام مكتبة Ratchet في PHP:

composer require cboden/ratchet

هيكلية التطبيق

يجب تصميم التطبيق ليكون سهل الاستخدام وقابل للتطوير. تتضمن هيكلية التطبيق ما يلي:

• واجهة المستخدم (Frontend): تتضمن صفحة لبدء البث وصفحة لمشاهدة البث المباشر.
• واجهة برمجة التطبيقات (API): لمعالجة الطلبات القادمة من الواجهة الأمامية.
• قاعدة البيانات: لتخزين بيانات المستخدمين وتفاصيل البث.

كتابة الكود

أ. إنشاء قاعدة البيانات

ابدأ بإنشاء قاعدة بيانات لتخزين معلومات البث:

CREATE DATABASE live_streaming;
USE live_streaming;

CREATE TABLE users (
   id INT AUTO_INCREMENT PRIMARY KEY,
   username VARCHAR(255) NOT NULL,
   password VARCHAR(255) NOT NULL
);

CREATE TABLE streams (
   id INT AUTO_INCREMENT PRIMARY KEY,
   user_id INT,
   stream_key VARCHAR(255) UNIQUE,
   status ENUM('live', 'offline') DEFAULT 'offline',
   created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
   FOREIGN KEY (user_id) REFERENCES users(id)
);

ب. تسجيل الدخول وإنشاء بث

لتسهيل عملية تسجيل الدخول وإنشاء بث جديد، يمكن استخدام الكود التالي:

<?php
session_start();
include 'db.php'; // ملف الاتصال بقاعدة البيانات

if ($_SERVER['REQUEST_METHOD'] === 'POST') {
   $username = $_POST['username'];
   $password = md5($_POST['password']);

   $query = $pdo->prepare("SELECT * FROM users WHERE username = :username AND password = :password");
   $query->execute(['username' => $username, 'password' => $password]);
   $user = $query->fetch();

   if ($user) {
       $_SESSION['user_id'] = $user['id'];
       header('Location: create_stream.php');
       exit();
   } else {
       echo "خطأ في اسم المستخدم أو كلمة المرور.";
   }
}
?>
<form method="POST">
   <input type="text" name="username" placeholder="اسم المستخدم" required>
   <input type="password" name="password" placeholder="كلمة المرور" required>
   <button type="submit">تسجيل الدخول</button>
</form>

ج. بدء البث المباشر

عند إنشاء بث مباشر، يمكن استخدام مفتاح فريد للبث لتحديد كل بث على حدة:

<?php
session_start();
include 'db.php';

if (isset($_SESSION['user_id'])) {
   $user_id = $_SESSION['user_id'];
   $stream_key = md5(uniqid($user_id, true));

   $query = $pdo->prepare("INSERT INTO streams (user_id, stream_key, status) VALUES (:user_id, :stream_key, 'live')");
   $query->execute(['user_id' => $user_id, 'stream_key' => $stream_key]);

   echo "مفتاح البث الخاص بك: " . $stream_key;
} else {
   header('Location: login.php');
   exit();
}
?>

عرض البث للمشاهدين

لاستعراض البث المباشر، يمكن للمستخدمين الدخول إلى صفحة المشاهدة باستخدام مفتاح البث:

<?php
include 'db.php';

$stream_key = $_GET['key'];

$query = $pdo->prepare("SELECT * FROM streams WHERE stream_key = :stream_key AND status = 'live'");
$query->execute(['stream_key' => $stream_key]);
$stream = $query->fetch();

if ($stream) {
   echo "<video src='stream_url/{$stream_key}' controls autoplay></video>";
} else {
   echo "البث غير متاح حالياً.";
}
?>

استخدام WebSocket لتحديث البث في الوقت الفعلي

يمكن استخدام WebSocket لتحديث حالة البث للمشاهدين في الوقت الفعلي:

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class StreamServer implements MessageComponentInterface {
   protected $clients;

   public function __construct() {
       $this->clients = new \SplObjectStorage;
   }

   public function onOpen(ConnectionInterface $conn) {
       $this->clients->attach($conn);
   }

   public function onMessage(ConnectionInterface $from, $msg) {
       foreach ($this->clients as $client) {
           if ($from !== $client) {
               $client->send($msg);
           }
       }
   }

   public function onClose(ConnectionInterface $conn) {
       $this->clients->detach($conn);
   }

   public function onError(ConnectionInterface $conn, \Exception $e) {
       $conn->close();
   }
}

require 'vendor/autoload.php';

$server = IoServer::factory(
   new HttpServer(
       new WsServer(
           new StreamServer()
       )
   ),
   8080
);

$server->run();