Node.js process.exit() 不会在 createReadStream 打开时退出

Question

我有一个通过 EAGI 与 Asterisk 通信的程序。 Asterisk 打开我的 Node.js 应用程序并通过 STDIN 向其发送数据，程序通过 STDOUT 发送 Asterisk 命令。当用户挂断时，Node.js 进程会收到一个 SIGHUP 命令。这是为了更干净的退出而被拦截。此功能正在运行。

Asterisk 还在 fd 3 (STDERR+1) 上发送 RAW 音频数据。 Node.js 进程正确截取数据，并能够读取音频、转换音频或执行任何其他需要完成的操作。但是，当在 fd 3 上创建 createReadStream 时，Node.js 进程将不会退出并很快变成僵尸。如果我注释掉 createReadStream 代码，Node.js 会按预期退出。

如何让 Node.js 像预期的那样使用 process.exit() 函数退出？我正在使用 Node.js 版本 v0.10.30.

Node.js createReadStream 代码：

// It was success
this.audioInStream = fs.createReadStream( null, { 'fd' : 3 } );

// Pipe the audio stream to a blackhole for now so it doesn't get queued up
this.audioInStream.pipe( blackhole() );

SIGHUP 代码：

process
.on( 'SIGHUP', function() {
    log.message.info( "[%s] Asterisk process hung up.", that.callerid );
    that.exitWhenReady();
} );

exitWhenReady 函数

Index.prototype.exitWhenReady = function() {
    if( !this.canExit )
        return;

    log.message.info( "[%s] Exiting program successfully.", this.callerid );

    // Get rid of our streams
    this.audioInStream.unpipe();
    this.audioInStream.close();
    this.audioInStream.destroy();

    process.exit( 0 );
};

黑洞模块：

var inherits = require( 'util' ).inherits;
var Writable = require( 'stream' ).Writable;
var process = require( 'process' );

function Blackhole( opts ) {
    if( !(this instanceof Blackhole) )
        return( new Blackhole( opts ) );

    if( !opts )
        opts = {};

    Writable.call( this, opts );
}

inherits( Blackhole, Writable );

Blackhole.prototype._write = function( chunk, encoding, done ) {
    process.nextTick( done );
};

module.exports = Blackhole;

值得注意的是

Asterisk process hung up

和

Exiting program successfully.

当 createReadStream 正在读取 fd 3 时从不显示在日志文件中，但当它不是时它们会显示。

Answer 1

我发现挂钩 SIGHUP 并打开 fd 3 会导致程序即使在调用 process.exit() 时也不会关闭。这真是奇怪。

我为解决此问题所做的工作是监听进程的 "exit" 事件。在 "exit" 事件中，我使用 SIGTERM 手动终止了自己的进程。这足以停止整个程序。我发现这实际上与 Winston 记录器异常记录器一起工作得很好。 Winston 可以将异常写入日志文件，然后成功退出。

结果代码：

process
.on( 'SIGHUP', function() {
    log.message.info( "[%s] Asterisk process hung up.", that.callerid );
    that.exitWhenReady( true );
} )
.on( 'exit', function() {
    process.kill( process.pid, 'SIGTERM' );
} );

上述函数基本上是在发送 SIGHUP 时调用 exitWhenReady()。检查所有任务是否完成，一旦所有任务完成，它将调用 "process.exit()" 调用上述事件的函数。

我希望这对某人有所帮助。

Answer 2

在寻找答案时遇到了这个问题。对“强制退出”不太满意，因为它也会阻止任何其他进程结束他们的工作。

经过大量试验和错误后，这是我的发现。而不是 createReadStream()，而是创建一个套接字：

const audio = new net.Socket({ fd: 3, readable: true });

其次，在 SIGHUP 上创建一个事件侦听器，它会破坏您的 stdin 和音频流：

process.addListener("SIGHUP", () => {
  process.stdin.destroy();
  audio.destroy();
});

这应该允许 Node.js 干净地退出。

Node.js process.exit() 不会在 createReadStream 打开时退出

Node.js process.exit() will not exit with a createReadStream open

javascript

stream

exit

node.js