Nodejs & FFmpeg 直播推流到斗鱼实现影视剧轮播

2017-11-05

斗鱼平台有些直播间24h轮播一些影视剧，当然可以选择在电脑上开一个播放器，列表顺序播放来达到效果；这里利用云服务器进行不间断推流。

先安装FFmpeg和Nodejs

安装FFmpeg：

yum -y install epel-release
su -c 'yum localinstall --nogpgcheck https://download1.rpmfusion.org/free/el/rpmfusion-free-release-6.noarch.rpm https://download1.rpmfusion.org/nonfree/el/rpmfusion-nonfree-release-6.noarch.rpm'
yum -y install ffmpeg ffmpeg-devel
ffmpeg -version

安装Nodejs：

wget -c https://nodejs.org/dist/v8.8.1/node-v8.8.1-linux-x64.tar.xz
tar -xvf node-v8.8.1-linux-x64.tar.xz 
mv node-v8.8.1-linux-x64 nodejs
ln -s /root/live/nodejs/bin/npm /usr/local/bin/npm
ln -s /root/live/nodejs/bin/node /usr/local/bin/node
node -v

上面用yum装的FFmpeg版本太低了0.10.…，下载已经编译好的新版本，替换yum安装的版本：

wget -c https://johnvansickle.com/ffmpeg/releases/ffmpeg-release-64bit-static.tar.xz
tar -xvf ffmpeg-release-64bit-static.tar.xz
mv ffmpeg-3.4-64bit-static/ ffmpeg
./ffmpeg/ffmpeg -version
yum remove ffmpeg
yum remove ffmpeg-devel
ln -s /root/live/ffmpeg/ffmpeg /usr/local/bin/ffmpeg
ffmpeg -version

安装node调用依赖

pm2（用于守护进程，轮播跳集的时候用到）
fluent-ffmpeg（封装了ffmpeg的api）
moment（格式化时间）

npm init // 生成package.json,方便npm安装
npm -g install pm2 // 全局安装pm2
npm install fluent-ffmpeg
npm install moment

主要代码

先生成循环播放所需的列表：xiaolifeidao.json, 可以用nodejs读取目录结构生成。

多集直播推流代码：

var fs = require('fs');  // 文件操作模块
var moment = require('moment'); // 时间格式化模块
var url = 'rtmp://send3.douyu.com/live/';  // 推流地址
var code = '3579367resFwhA2g?wsSecret=bfa90220bd55955806ffe482885610a5&wsTime=59f9ec9f&wsSeek=off';  // 推流参数
// 记录时间
function logTime() {
    return moment().format("YYYY-MM-DD h:mm:ss a");
}
//写入文件utf-8格式
function writeFile(fileName, data, cur)
{
  console.log(cur);
  fs.writeFile(fileName, data, 'utf-8', function() {
     console.log("文件写入成功，" + 'update cur index :' + cur);
  });  
}
console.log('[' + logTime() + '] argv, json list: ' +  process.argv[2]);
var fileName = process.argv[2] ? process.argv[2] : 'xiaolifeidao.json'; // 文件列表
var logo = './logo.png';  // 水印logo
function ffmpegLive() {
    var jstr = fs.readFileSync(fileName, 'utf-8');
    var fl = JSON.parse(jstr);
    console.log('[' + logTime() + '] Find ' + fl.video.length + ' Video Files !');
    var index = fl.cur;
    var ffmpeg = require('fluent-ffmpeg');
    var inputPath = fl.video[index].value;
    var outputPath = url + code;
    fl.cur = index + 1;
    if (fl.cur >= fl.video.length) {
        fl.cur = 0;
    }
    writeFile(fileName, JSON.stringify(fl), fl.cur);
    
    ffmpeg(inputPath)
        .inputOptions('-re')
        .addInput(logo)
        .addOptions([
            '-vcodec libx264',
            '-preset veryfast',
            '-crf 22',
            '-maxrate 1000k', // 1000k
            '-bufsize 3000k',
            '-acodec libmp3lame',
            '-ac 2',
            '-ar 44100',
            '-b:a 96k'
        ])
        .complexFilter([{
            filter: 'scale',
            options: [1280, -2],
            inputs: '[0:v]',
            outputs: 'video'
        }, {
            filter: 'scale',
            options: [220, -1],
            inputs: '[1:v]',
            outputs: 'logo'
        }, {
            filter: 'overlay',
            options: {
                x: 'main_w-overlay_w-15',
                y: 15
            },
            inputs: ['video', 'logo']
        }])
        .format('flv')
        .output(outputPath, {
            end: true
        })
        .on('start', function(commandLine) {
            console.log('[' + logTime() + '] Vedio "' + fl.video[index].name + '" is Pushing !');
            console.log('[' + logTime() + '] Spawned Ffmpeg with command :' + commandLine);
        })
        .on('error', function(err, stdout, stderr) {
            console.log('error: ' + err.message);
            console.log('stdout: ' + stdout);
            console.log('stderr: ' + stderr);
        })
        .on('end', function() {
            console.log('[' + logTime() + '] Vedio "' + fl.video[index].name + '" Pushing is Finished !');
        })
        .run();
}
ffmpegLive();

执行：

node live.js xiaolifeidao.json

[2017-11-06 01:23:31 am] argv, json list: xiaolifeidao.json
0
{ cur: 1,
  video: 
   [ { name: '【国产】小李飞刀1999【40集全】字幕完整版(1).mp4',
       value: './video/xiaolifeidao/【国产】小李飞刀1999【40集全】字幕完整版(1).mp4' },
     { name: '【国产】小李飞刀1999【40集全】字幕完整版(2).mp4',
       value: './video/xiaolifeidao/【国产】小李飞刀1999【40集全】字幕完整版(2).mp4' },
     { name: '【国产】小李飞刀1999【40集全】字幕完整版(3).mp4',
       value: './video/xiaolifeidao/【国产】小李飞刀1999【40集全】字幕完整版(3).mp4' },
     { name: '【国产】小李飞刀1999【40集全】字幕完整版(4).mp4',
       value: './video/xiaolifeidao/【国产】小李飞刀1999【40集全】字幕完整版(4).mp4' },
     { name: '【国产】小李飞刀1999【40集全】字幕完整版(5).mp4',
       value: './video/xiaolifeidao/【国产】小李飞刀1999【40集全】字幕完整版(5).mp4' },
     { name: '【国产】小李飞刀1999【40集全】字幕完整版(6).mp4',
       value: './video/xiaolifeidao/【国产】小李飞刀1999【40集全】字幕完整版(6).mp4' } ] }
1
[2017-11-06 01:23:31 am] Find 6 Video Files !
文件写入成功，update cur index :1
[2017-11-06 01:23:31 am] Vedio "【国产】小李飞刀1999【40集全】字幕完整版(1).mp4" is Pushing !
[2017-11-06 01:23:31 am] Spawned Ffmpeg with command :ffmpeg -re -i ./video/xiaolifeidao/【国产】小李飞刀1999【40集全】字幕完整版(1).mp4 -i ./logo.png -filter_complex [0:v]scale=1280:-2[video];[1:v]scale=220:-1[logo];[video][logo]overlay=x=main_w-overlay_w-15:y=15 -vcodec libx264 -preset veryfast -crf 22 -maxrate 1000k -bufsize 3000k -acodec libmp3lame -ac 2 -ar 44100 -b:a 96k -f flv rtmp://send3.douyu.com/live/3579367resFwhA2g?wsSecret=bfa90220bd55955806ffe482885610a5&wsTime=59f9ec9f&wsSeek=off