Как закрыть дочерний процесс Node.js FFMPEG, который активно транслируется из источника захвата в реальном времени?

Следующий код загружается моим основным app.js как модуль с использованием метода child_process.fork():

    var spawn = require('child_process').spawn;

    var ffmpeg = spawn('C:\\Program Files (x86)\\ffmpeg\\bin\\ffmpeg.exe', ['-y', '-threads', '-0', '-re', '-rtbufsize', '204800000', '-probesize', '4096', '-vsync', '2', '-async', '30', '-f', 'dshow', '-s', '320x240', '-i', 'video=Integrated Webcam:audio=Microphone Array (IDT High Defi', '-c:a', 'libvo_aacenc', '-ab', '48000', '-ar', '22050', '-ac', '2', '-c:v', 'libx264', '-s', '400x300', '-g', '96', '-x264opts', 'bitrate=1200', '-preset', 'ultrafast', '-profile:v', 'baseline', '-pix_fmt', 'yuv420p', '-aspect', '4:3', '-f', 'flv', 'rtmp://server']);

    setTimeout(function() {
        ffmpeg.stderr.on('data', function() {
            ffmpeg.stdin.setEncoding('utf8');
            ffmpeg.stdin.write('q');
            process.exit();
        });
    }, 10000);

Это было гораздо менее сложно, чем я делал. Основной app.js — это базовая HTML-страница, которая обслуживается и использует socket.io для получения события и соответствующих данных. В этом случае «истинное» событие загружает файл module.js, который запускает сеанс захвата FFMPEG в реальном времени, передает его на сервер RTMP и корректно завершает работу FFMPEG по тайм-ауту в 10 секунд.

Моя следующая задача — выключить его через событие, инициированное из веб-интерфейса, в отличие от текущего метода тестирования тайм-аута.

Глядя на диспетчер задач в Windows, процесс FFMPEG закрывается, как и процесс вторичного узла.

Причина этого в том, что ни один из модулей node-ffmpeg, которые я нашел, не поддерживает прямую трансляцию через ввод захвата. Похоже, они в первую очередь предназначены для перекодирования существующего контента. Конечным результатом этого в идеале будет веб-интерфейс, который может запускать и останавливать FFMPEG. Наш вариант использования заменит Adobe Flash Media Live Encoder в качестве источника для нашего Adobe Media Server из-за его невозможности сохранять стандартные файлы mp4.

Вы можете просто убить его.

ffmpeg.kill(SIGHUB)

или любой другой сигнал уничтожения, который вы хотите, см. http://en.wikipedia.org/wiki/Unix_signal

Если я правильно понимаю ваш пример, вы передаете все аргументы процесса node в ffmpeg, включая поток. Чтобы заставить ваш ffmeg.end() работать, вам нужно будет выполнять потоковую передачу непосредственно из процесса вашего узла. Я думаю, что ffmpeg не останавливается, когда он непрерывно получает данные с вашей камеры.

Далее следует более или менее окончательное решение проблемы запуска и закрытия сеанса FFMPEG в реальном времени с использованием Node.js:

    var     spawn = require('child_process').spawn
,   fs = require('fs');


    function ffmpeg(cmd, opts, callback) {
    var p;
    //console.log(callback());
    if(p == undefined) {
        var p = spawn(cmd, opts);

        p.stderr.on('data', function(data) {
            /*p.stdin.setEncoding('utf8');
                p.stdin.write('q');
                process.exit()
            */
            fs.readFile(__dirname + '/server-state.json', function(error, data) {
                if(error) {
                        console.log(error); 
                    } else {
                        content = JSON.parse(data);
                        console.log(content['State']);

                        if(content['State'] == 'false') {
                            p.stdin.setEncoding('utf8');
                            p.stdin.write('q');
                            process.exit()
                        }
                    }
            });

        });

        return p;
    }

}

    ffmpeg_var = ffmpeg('C:\\Program Files (x86)\\ffmpeg\\bin\\ffmpeg.exe', ['-y', '-threads', '-0', '-re', '-rtbufsize', '204800000', '-probesize', '4096', '-vsync', '2', '-async', '30', '-f', 'dshow', '-s', '320x240', '-i', 'video=Integrated Webcam:audio=Microphone Array (IDT High Defi', '-c:a', 'libvo_aacenc', '-ab', '48000', '-ar', '22050', '-ac', '2', '-c:v', 'libx264', '-s', '400x300', '-g', '96', '-x264opts', 'bitrate=1200', '-preset', 'ultrafast', '-profile:v', 'baseline', '-pix_fmt', 'yuv420p', '-aspect', '4:3', '-f', 'mp4', __dirname + '/IntegrityTest.mp4'], function() {


    });

Этот код инкапсулирован в файле «module.js», который создается с помощью child_process.fork() в корневом файле application.js. Он читает текстовый файл, в котором хранится «состояние». Это состояние переключается с помощью метода записи/чтения в корневом приложении. В событии on('data') он считывает файл и, если обнаруживает, что состояние изменилось на false, затем отключает FFMPEG, записывая команду q в стандартный ввод.

Помимо уточнения с помощью базы данных, если бы я реализовал его в большем масштабе, я более чем открыт для отзывов относительно более элегантного способа кодирования.

вам нужно отправить EOF после того, как файл будет передан в ffmpeg. тогда ffmpeg закончит работу и выключится правильно