Symfony2的视频流(Symfony2 video streaming)

2019-08-08 13:15发布

我正在写的应用程序symfony2 ,我有视频流的问题。

如果一个动作需要很长的时间来执行-例如1 minute ,整个应用程序被冻结(当在第二标签打开),并且必须等待执行的结束。

问题出在哪儿?

//编辑

    public function streamAction($fileName) {

    $user = $this->get('security.context')->getToken()->getUser();
    $request = $this->getRequest();

    $uid = $request->get('uid') != 'null' ? $user->getId() : $request->get('uid');

    $libPath = $this->_libPath('Users', 'uid' . str_pad($uid, 6, "0", STR_PAD_LEFT));

    $file = pathinfo($fileName);
    $fileName = $file['basename'];
    $fileExt = $file['extension'];
    $filePath = realpath($libPath . $fileName);

    if (in_array($fileExt, $this->formats['video'])) {
        $mime = 'video';
    }

    if (in_array($fileExt, $this->formats['audio'])) {
        $mime = 'audio';
    }

    $mime .= '/' . $fileExt;

    header("Accept-Ranges: bytes");

    if (is_file($filePath)) {
        header("Content-type: $mime");
        if (isset($_SERVER['HTTP_RANGE'])) {

            $fp = fopen($filePath, 'rb');
            $size = filesize($filePath);
            $length = $size;
            $start = 0;
            $end = $size - 1;

            if (isset($_SERVER['HTTP_RANGE'])) {
                $c_start = $start;
                $c_end = $end;
                list(, $range) = explode('=', $_SERVER['HTTP_RANGE'], 2);

                if (strpos($range, ',') !== false) {
                    header('HTTP/1.1 416 Requested Range Not Satisfiable');
                    header("Content-Range: bytes $start-$end/$size");
                    exit;
                }

                if ($range == '-') {
                    $c_start = $size - substr($range, 1);
                } else {
                    $range = explode('-', $range);
                    $c_start = $range[0];
                    $c_end = ( isset($range[1]) && is_numeric($range[1]) ) ? $range[1] : $size;
                }

                $c_end = ($c_end > $end) ? $end : $c_end;
                if ($c_start > $c_end || $c_start > $size - 1 || $c_end >= $size) {
                    header('HTTP/1.1 416 Requested Range Not Satisfiable');
                    header("Content-Range: bytes $start-$end/$size");
                    exit;
                }

                $start = $c_start;
                $end = $c_end;
                $length = $end - $start + 1;
                fseek($fp, $start);
                header('HTTP/1.1 206 Partial Content');
                header('ETag: "' . md5(microtime()) . '"');
            }

            header("Content-Range: bytes $start-$end/$size");
            header("Content-Length: $length");
            header('Connection: Close');

            $buffer = 1024 * 8;
            while (!feof($fp) && ($p = ftell($fp)) <= $end) {
                if ($p + $buffer > $end) {
                    $buffer = $end - $p + 1;
                }
                set_time_limit(0);
                echo fread($fp, $buffer);
                flush();
            }
            fclose($fp);
        } else {
            header("Content-Length: " . filesize($filePath));
            readfile($filePath);
        }
    } else {
        echo "error";
    }
    die();
}

问题是不是代码,因为Symfony2的块不仅流,但与像下载文件等很长一段时间的行动。

Answer 1:

如果你使用一个面向对象的框架,如Symfony的,为什么仍然使用程序方法,而不是什么Symfony的所提供的? 例如在StreamedResponse类。

我提供你一个更OOP / Symfony的导向之下,但是如果提供的范围仅仅是-你现在重新设置范围开始......文件大小? 我敢肯定这是不是你应该做的。 我想你应该仔细检查它!

这里是streamAction()的的修订版本:

use SplFileInfo;
use RuntimeException;

// Symfony >= 2.1
use Symfony\Component\HttpFoundation\StreamedResponse;

public function streamAction($fileName) {
    $user = $this->getUser();
    $request = $this->getRequest();

    // Create the StreamedResponse object
    $response = new StreamedResponse();

    $uid = $request->get('uid') != 'null' ? $user->getId() : $request->get('uid');
    $libPath = $this->_libPath('Users', 'uid' . str_pad($uid, 6, "0", STR_PAD_LEFT));

    try {
        $file = new SplFileObject($libPath . $fileName);
    }
    catch (RuntimeException $runtimeException) {
        // The file cannot be opened (permissions?)
        // throw new AnyCustomFileErrorException() maybe?
    }

    // Check file existence
    if (!($file->isFile())) {
        // The file does not exists, or is not a file.
        throw $this->createNotFoundException('This file does not exists, or is not a valid file.');
    }

    // Retrieve file informations
    $fileName = $file->getBasename();
    $fileExt  = $file->getExtension();
    $filePath = $file->getRealPath();
    $fileSize = $file->getSize();

    // Guess MIME Type from file extension
    if (in_array($fileExt, $this->formats['video'])) {
        $mime = 'video';
    } elseif (in_array($fileExt, $this->formats['audio'])) {
        $mime = 'audio';
    }

    $mime .= '/' . $fileExt;

    $response->headers->set('Accept-Ranges', 'bytes');
    $response->headers->set('Content-Type', $mime);

    // Prepare File Range to read [default to the whole file content]
    $rangeMin = 0;
    $rangeMax = $fileSize - 1;
    $rangeStart = $rangeMin;
    $rangeEnd = $rangeMax;

    $httpRange = $request->server->get('HTTP_RANGE');

    // If a Range is provided, check its validity
    if ($httpRange) {
        $isRangeSatisfiable = true;

        if (preg_match('/bytes=\h*(\d+)-(\d*)[\D.*]?/i', $httpRange, $matches)) {
            $rangeStart  = intval($matches[1]);

            if (!empty($matches[2])) {
                $rangeEnd  = intval($matches[2]);
            }
        } else {
            // Requested HTTP-Range seems invalid.
            $isRangeSatisfiable = false;
        }

        if ($rangeStart <= $rangeEnd) {
            $length = $rangeEnd - $rangeStart + 1;
        } else {
            // Requested HTTP-Range seems invalid.
            $isRangeSatisfiable = false;
        }

        if ($file->fseek($rangeStart) !== 0) {
            // Could not seek the file to the requested range: it might be out-of-bound, or the file is corrupted?
            // Assume the range is not satisfiable.
            $isRangeSatisfiable = false;

            // NB : You might also wish to throw an Exception here...
            // Depending the server behaviour you want to set-up.
            // throw new AnyCustomFileErrorException();
        }

        if ($isRangeSatisfiable) {
            // Now the file is ready to be read...
            // Set additional headers and status code.
            // Symfony < 2.4
            // $response->setStatusCode(206);
            // Or using Symfony >= 2.4 constants
            $response->setStatusCode(StreamedResponse::HTTP_PARTIAL_CONTENT);

            $response->headers->set('Content-Range', sprintf('bytes %d/%d', $rangeStart - $rangeEnd, $fileSize));
            $response->headers->set('Content-Length', $length);
            $response->headers->set('Connection', 'Close');
        } else {
            $response = new Response();

            // Symfony < 2.4
            // $response->setStatusCode(416);
            // Or using Symfony >= 2.4 constants
            $response->setStatusCode(StreamedResponse::HTTP_REQUESTED_RANGE_NOT_SATISFIABLE);
            $response->headers->set('Content-Range', sprintf('bytes */%d', $fileSize));

            return $response;
        }
    } else {
        // No range has been provided: the whole file content can be sent
        $response->headers->set('Content-Length', $fileSize);
    }

    // At this step, the request headers are ready to be sent.
    $response->prepare($request);
    $response->sendHeaders();

    // Prepare the StreamCallback
    $response->setCallback(function () use ($file, $rangeEnd) {
        $buffer = 1024 * 8;

        while (!($file->eof()) && (($offset = $file->ftell()) < $rangeEnd)) {
            set_time_limit(0);

            if ($offset + $buffer > $rangeEnd) {
                $buffer = $rangeEnd + 1 - $offset;
            }

            echo $file->fread($buffer);
        }

        // Close the file handler
        $file = null;
    });

    // Then everything should be ready, we can send the Response content.
    $response->sendContent();

    // DO NOT RETURN $response !
    // It has already been sent, both headers and body.
}


Answer 2:

这是因为PHP锁定会话。 您的第一请求将锁定会话,并用相同的会议(您的第二个选项卡)后续请求将在方框session_start()直到所述第一请求完成。 (具有相同的会话请求被完成了串口,一个后下)。

看看这个链接有关会话并发性的信息。



文章来源: Symfony2 video streaming