laravel5.5集成FFmpeg，redis队列异步视频转码

1、laravel PHP-FFmpeg 扩展 下载地址：https://github.com/PHP-FFMpeg/PHP-FFMpeg

2、安装方法：

$ composer require php-ffmpeg/php-ffmpeg

3、使用：

安装redis：

$ composer require predis/predis

配置.env文件：

QUEUE_DRIVER=redis
REDIS_HOST=127.0.0.1
REDIS_PASSWORD=
REDIS_PORT=6379

更改 config/queue.php：

'redis' => [
'driver' => 'redis',
'connection' => 'default',
'queue' => '{default}',
'retry_after' => 36000,//这里设置10个小时转码消耗的最大时间
],
//注意：
//参数项 --timeout 的值应该是中小于配置项retry_after的值
//这是为了确保队列进程总在任务重试以前关闭。
//如果 --timeout 比retry_after 大，则你的任务可能被执行两次。

创建任务：

$ php artisan make:job MakeCoding

编辑 App/Jobs/MakeCoding.php:

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Config;
use App\Models\Element;//你的素材模型 自己定义

class MakeCoding implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/**
* The number of seconds the job can run before timing out.
*
* @var int
*/
public $timeout = 30000; //最大超时时间
public $element_id; //素材id
public $relapath; //素材路径
public $chakge_path; //更改后的路径
public $tries = 3;//最大失败次数
/**
* Create a new job instance.
*
* @return void
*/
public function __construct($relapath, $element_id)
{
$this->relapath    = $relapath;
$this->element_id  = $element_id;
}

/**
* Execute the job.
*
* @return void
*/
public function handle()
{
$path              = public_path() . DIRECTORY_SEPARATOR . $this->relapath;//文件保存在public下
$save_path         = explode('.', $path)[0] . '.mp4';
$this->chakge_path = explode('.', $this->relapath)[0] . '.mp4';
$ffmpeg_path       = Config::get("phpFFmpeg.ffmpeg"); //ffmpeg运行的路径
$ffprobe_path      = Config::get("phpFFmpeg.ffprobe"); //ffprobe运行路径

$ffmpeg = \FFMpeg\FFMpeg::create(array(
'ffmpeg.binaries'  => $ffmpeg_path,
'ffprobe.binaries' => $ffprobe_path,
'timeout'          => 30000, // The timeout for the underlying process
'ffmpeg.threads'   => 12, // The number of threads that FFMpeg should use
));
$default = ini_get('max_execution_time');//取得php最大超时时间，相应的修改apache或nginx的配置文件中的超时时间，和文件上传大小限制
set_time_limit(-1);//设置成永不超时
$video  = $ffmpeg->open($path);
$format = new \FFMpeg\Format\Video\X264('libmp3lame', 'libx264');
$format->on('progress', function ($video, $format, $percentage) {
echo $percentage . '% ';//转码进度
if ($percentage >= 99) {//有的文件转码到99%会认为完成了
　　　　　　　　　　//1、删除源文件
@unlink($path);
//2、修改数据库文件路径信息转码完成，自己定义
@Element::where('id', $this->element_id)->update(['path' => $this->chakge_path, 'trans_status' => '1']);
}
});
$video->save($format, $save_path);
set_time_limit($default);//恢复php的最大超时时间
}
}

添加配置文件 config/phpFFmpeg.php:

<?php
//windows
return [
'ffmpeg' =>'C:/xampp/php/ffmpeg/bin/ffmpeg.exe',
'ffprobe' =>'C:/xampp/php/ffmpeg/bin/ffprobe.exe',
];
　/*linux
return [
'ffmpeg' =>'/usr/local/ffmpeg/bin/ffmpeg',
'ffprobe' =>'/usr/local/ffmpeg/bin/ffprobe',
];*/

在你的项目目录鼠标 Shift+右键 在此打开命令行 运行队列进程：

$ php artisan queue:work

编辑你的上传文件的 Controller:

<?php

use App\Jobs\MakeCoding;

//这里写伪代码
//1、上传文件
//2、保存到数据库
//3、如果是上传视频，并且不是mp4格式的，那么进行转码
//4、发送任务 参数：素材的真实保存路径和素材id
if ($type == 'video' && 'mp4' != $ext) {
dispatch(new MakeCoding($realpath, $element_id));
}

完成~！

1 <?php
2 /**
3  * IO公共操作类
4  */
5 class IOHelper
6 {
7     /**
8      * 获取音频或视频信息
9      * @param  [string] $path     [文件路径]
10      * @return [array]  result    [文件信息]
11      */
12     public static function getMediaInfo($path)
13     {
14         $result = array();
15         $cmd    = sprintf('/home/samba/ffmpeg/bin/ffprobe -v quiet -print_format json -show_format -show_streams "%s" 2>&1', $path);//你的FFMpeg执行文件地址自己定义
16         exec($cmd, $arr);
17         $obj = json_decode(implode($arr));
18
19         if ($obj && property_exists($obj, "format")) {
20             $type           = $obj->format->format_name;
21             $result["Type"] = $type;
22
23             if (false === stripos($type, "_pipe")) {
24                 $result["Duration"]        = (int) $obj->format->duration; //持续时间
25                 $result["DisplayDuration"] = self::formatTime($obj->format->duration); //格式化后的时间
26                 $result["byte_size"]       = (int) $obj->format->size; //字节大小
27                 $result["format_size"]     = self::formatSize($obj->format->size); //格式化后的大小
28             }
29
30             if ("mp3" != $type) {
31                 foreach ($obj->streams as $stream) {
32                     //视频流和音频流
33                     if ($stream->codec_type == "video") {
34                         //找到视频流
35                         $result["Resolution"] = sprintf("%sx%s", @$stream->width, @$stream->height); //分辨率
36                         break;
37                     }
38                 }
39             }
40         }
41
42         return $result;
43     }
44
45     /**
46      * 返回格式化后的时间格式
47      */
48     private static function formatTime($sec)
49     {
50         $sec           = $sec % (24 * 3600);
51         $hours         = floor($sec / 3600);
52         $remainSeconds = $sec % 3600;
53         $minutes       = floor($remainSeconds / 60);
54         $seconds       = intval($sec - $hours * 3600 - $minutes * 60);
55
56         return sprintf("%s:%s:%s", str_pad($hours, 2, "0", STR_PAD_LEFT), str_pad($minutes, 2, "0", STR_PAD_LEFT), str_pad($seconds, 2, "0", STR_PAD_LEFT));
57     }
58
59     /**
60      * 返回格式化后的文件尺寸
61      */
62     public static function formatSize($bytes, $decimals = 2)
63     {
64         $size       = ['B', 'KB', 'MB', 'GB', 'TB', 'PB'];
65         $factor     = floor((strlen($bytes) - 1) / 3);
66         $byte       = $bytes / pow(1024, $factor);
67         $formatSize = floor($byte * 100) / 100;
68
69         return sprintf("%.{$decimals}f", $formatSize) . @$size[$factor];
70     }
71     /**
72      * *
73      * @return boolean [是否是windows系统]
74      */
75     public static function isWin()
76     {
77         if (substr(PHP_OS, 0, 3) === 'WIN') {
78             return true;
79         }
80         return false;
81     }
82     /**
83      * 判断目录是否为空
84      * @param  [string] $dir [目录路径]
85      * @return [bool]        [true/false]
86      */
87     public static function isEmptyDir($dir)
88     {
89         if (!is_dir($dir)) {
90             return "$dir is not a directory";
91         }
92         $handle = opendir($dir);
93         while (($file = readdir($handle)) !== false) {
94             if ($file != "." && $file != "..") {
95                 closedir($handle);
96                 return false;
97             }
98         }
99         closedir($handle);
100
101         return true;
102     }
103
104     /**
105      * 删除一个目录
106      * @param  [string] $dir [目录路径]
107      * @return [type]      [description]
108      */
109     public static function removeDir($dir)
110     {
111         if (! is_dir($dir))
112         {
113             return "$dir is not a directory";
114         }
115         $handle = opendir($dir);
116         while (($file = readdir($handle)) !== false)
117         {
118             if ($file != "." && $file != "..")
119             {
120                 is_dir("$dir/$file") ? removeDir("$dir/$file") : unlink("$dir/$file");
121             }
122         }
123         if (readdir($handle) == false)
124         {
125             closedir($handle);
126             rmdir($dir);
127         }
128     }
129
130     /**
131      * 生成一个文件
132      * @param  [type] $path [description]
133      * @param  [type] $data [description]
134      * @return [type]       [description]
135      */
136     public static function writeFile ($path, $data)
137     {
138         //$dir = str_replace('/'.basename($path),'',$path);
139         //@mkdir($dir,0777,true);
140         $fp = fopen($path, 'w');
141         if(fwrite($fp, $data)){
142             return true;
143         }
144         fclose($fp);
145         return false;
146     }
147
148     /**
149      * 自定义获取文件md5
150      * @param  [string] $file [文件路径]
151      * @return [string]       [md5值]
152      */
153     public static function md5($file)
154     {
155         if(! $fp = fopen($file, 'r')){
156             return false;
157         }
158
159         $size = filesize($file);
160         // 1024*1024 = 1MB
161         if (1048576 > $size) {
162             return  md5_file($file);
163         }
164
165         $file_path = '';
166         $file_path_temp = '';
167
168         fseek($fp, 0); // 1 - 2012
169         $file_path .= fread($fp, 2012);
170
171         fseek($fp, $size / 2 - 1999); // size/2 - 1999
172         $file_path .= fread($fp, 1999);
173
174         fseek($fp, -2010, SEEK_END); // -2010
175         $file_path .= fread($fp, 2010);
176
177         fclose($fp);
178
179         //自己定义你的临时文件路径
180         $file_path_temp = sprintf("%s/%s_%s", public_path(), time(), basename($file));
181
182         if(! $fp_temp = fopen($file_path_temp, "wb")){
183             return false;
184         }
185         //写入截取的文件片段
186         fwrite($fp_temp, $file_path);
187         fclose($fp_temp);
188
189         $md5 = md5_file($file_path_temp);
190         unlink($file_path_temp);
191
192         return $md5;
193     }
194 }