node.js自己已经封装了ffmpeg了,但是依然没有解决动态改变输入源的方法,因为ffmpeg同一个进程只接受一个输入源,这个输入源可以是文件路径,也可以是一个可读的流数据。起初的想法是用开启一个进程的方法 const spawn = require('child_process').spawn我们来操作命令去不断结束上一次操作然后重新操作指令,但是我们推流到服务器的话,发现服务器要重新接受数据,而且如果操作频繁的话,对于关闭开启的子进程比较麻烦,在用进程命令调用ffmpeg时,因为,ffmpeg也是一个进程,所以一旦执行命令,就说额外开启了两个进程,关闭进程很麻烦。 const Ffmpegs = require('fluent-ffmpeg')后来发现node.js本身是有封装的对ffmpeg。用法如下 playsure = new Ffmpegs() playsure.input('E://KuGou//08.mp3') playsure.inputOption('-re') playsure.outputOptions([ '-rtsp_transport', 'tcp', '-f', 'rtsp' ]) playsure.output('rtsp://47.103.130.92:554') playsure.run() playsure.on('end', () => { console.log('结束end') })进行向特定服务器推流。我们指定了一帧一帧的推,且是tcp方式推送rtsp流。
这样也实现了推流的效果,但是当你重新指定输入源的时候是不允许的,需要先结束之前的ffmpeg在指定ffmpeg输入源,这样还是要先断开一次连接,服务器那边还要重新接受数据才行。
后来想到用管道来传输,想的只用改变输入端的数据,将管道的输出端放到ffmpeg的输入端,只要不关闭管道,因该就可以实现输入源的切换,进行了多方搜索,发现在node.js中只能有 var fs = require('fs')var rs = fs.createReadStream('E://KuGou//08.mp3', { highWaterMark: 4608 })var ws = fs.createWriteStream('E://KuGou//')fs.pipe(ws)这两个数据流进行管道操作,也有双工流,是有读写功能的,但是没有研究出来同时读写操作。
显然我们操作ffmpeg需要的是能读能写的管道,而且不能关闭。后来想到了我们本来就是用的tcp协议的,tcp的socket也可以充当管道作用,它也是用来分发数据的。于是乎我又写了tcp客户端和服务器接收端专门用socket来充当管道。 server: var net = require('net')var TcpServer = net.createServer() TcpServer.listen(3000, function () { console.log('tcp_server listening 3000') }) TcpServer.on('connection', (Socket) => { if (trsocket) { var playsure1 = new Ffmpegs() playsure1.input(Socket) playsure1.inputOption('-re') playsure1.outputOptions([ '-rtsp_transport', 'tcp', '-f', 'rtsp' ]) playsure1.pipe('rtsp://47.103.130.92:554') } Socket.on('data', (data) => { console.log('接受到数据:') // console.log('read data ', data) }) .on('close', () => { console.log('close server') }) .on('error', (error) => { console.log('error :' + error) }) })- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
client var options = { host: '127.0.0.1', port: 3000}var Tcpclient = new net.Socket() Tcpclient.connect(options, () => { var playsure = new Ffmpegs() var rs = fs.ReadStream('E://KuGou//08.mp3') rs.pipe(Tcpclient) console.log('开始发送数据:') })这个可以实现tcp传输了,但是当一首歌传完,socket尽然也自动断开连接了。无语。。。。
还是server主动断开的。
后来尝试去找ffmpeg传输结束发出的信号,发现它就是会自动断开连接。于是我将它的设置更改一下 playsure1.pipe('rtsp://47.103.130.92:554', { end: false, autoClose: false })//不让它结束后断开连接对ffmpeg的输出进行了设置。但是发现还是会断开socket,于是想是不是和输入端有关
对输入端进行更改 rs.pipe(Tcpclient, { end: false, autoClose: false })是的它不断开连接,感觉接近成功了。
但是我去操作输入文件的时候发现不行,还是改不了输入源(可能方法不对,后面没有直接更改文件)
考虑到我们要控制输入源,还要实现随时停止等操作,要对输入传输速度有要求。想到ffmpeg本身就可以设置输出格式,于是干脆在客户端直接在创建一个ffmpeg来控制传输速度和格式客户端的代码改变如下 var Tcpclient = null Tcpclient = new net.Socket() var playsure = new Ffmpegs() Tcpclient.connect(options, () => { playsure.input('E://KuGou//08.mp3') playsure.inputOption('-re') playsure.outputOptions([ '-rtsp_transport', 'tcp', '-f', 'mp3' ]) playsure.output(Tcpclient, { end: false, autoClose: false }) playsure.run()因为现在socket已经不会断开了,所以我们可以更改输入源的数据了,client里面的ffmpeg只是用来控制数据格式的,我们只用记录好当前连接的socket只向它里面传输数据就可以了。client中的ffmpeg我们可以随意断开,进行切换传到socket中的数据进而实现动态切换ffmpeg的输入数据的,当ffmpeg传输结束会抛出end信号 playsure.on('end', () => { console.log('数据传输结束') })关闭ffmpeg在node.js中我使用kill()来结束的,但是ffmpeg结束是结束了,就是会跑出来一个错误 Error: ffmpeg was killed with signal SIGKILL目前还没有对它进行研究,我是直接把它try掉了,没有管,下次重新调用的时候也没有问题。
|