我遇到了一个奇怪的情况。我正在编写一个用于从IP摄像头流式传输RTSP的Web应用程序。一切都很好,除非观看流的客户端重新加载或离开页面,服务器会崩溃(不是每次都会发生)。
以下是崩溃输出:
zlib.js:499
var newReq = self._handle.write(flushFlag,
^
TypeError: Cannot read property 'write' of null
at Zlib.callback (zlib.js:499:33)
服务器端:
const app = require('express')();
const child_process = require('child_process');
const server = require('http').Server(app);
const io = require('socket.io')(server);
io.of('/stream').on('connection', function(socket) {
let room;
socket.on('startStream', function(camuid) {
room = camuid;
let stream;
socket.join(room);
if (processes.indexOf(camuid) == -1) {
processes.push(camuid);
logic.Onvif.getStreamLink(camuid).then(rtsp_link => {
stream = child_process.spawn("ffmpeg", [
'-y',
'-re',
"-i", rtsp_link,
'-f', 'mjpeg',
'-'
], {
detached: false
});
stream.stdout.on('data', (data) => {
const frame = Object.values(new Uint8Array(data));
socket.nsp.to(room).emit('camfeed', frame);
});
}).catch((e) => {
socket.nsp.to(room).emit('streamError', true);
});
}
});
在客户端:
const io = require('socket.io-client');
socket = io.connect(`http://${location.hostname}:8088/stream`);
socket.on('connect', function() {
socket.emit('startStream', $this.$props.id);
});
socket.on('camfeed', function (data) {
//Here the data is displayed on canvas
});
我尝试找出服务器代码中导致该行为的部分,但迄今为止没有成功。
我尝试将函数、监听器和发射器放入try{}catch
中,并使用console.log
记录每一步以查看它在哪里停止,但输出结果并不总是相同的。
因此,我开始寻找解决方案,并发现一个 GitHub 问题说 zlib 负责将数据压缩为 gzip 后发送,而错误是因为尝试处理不存在的数据而引起的。另一方面,我没有安装 zlib 作为依赖项,据我所知,zlib 包已不再使用,因为 node 已经内置了这个功能。我搜索了node_modules
并找到 minizlib 包,但不知道它是谁的依赖关系。