我正在写的应用程序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的块不仅流,但与像下载文件等很长一段时间的行动。
如果你使用一个面向对象的框架,如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.
}
这是因为PHP锁定会话。 您的第一请求将锁定会话,并用相同的会议(您的第二个选项卡)后续请求将在方框session_start()
直到所述第一请求完成。 (具有相同的会话请求被完成了串口,一个后下)。
看看这个链接有关会话并发性的信息。