Funkcje Node.js socket.send() nie kończą się przed zakończeniem

Question

W niektórych skryptach Node.js, które napisałem, zauważam, że nawet jeśli ostatnia linia jest połączeniem synchronicznym, czasami nie kończy się przed węzłem. js wychodzi.

Nigdy nie widziałem, aby instrukcja console.log nie działała/kończyła się przed wyjściem, ale widziałem, że inne instrukcje nie zostały zakończone przed wyjściem i uważam, że wszystkie są synchroniczne. Mogłem zrozumieć, dlaczego wywołanie funkcji asynchronicznej oczywiście nie zaszło w tym przypadku.

Kod w pytaniu jest ZeroMQ .send() wezwanie tak:

var zmq = require('zmq'); 
    var pub = zmq.socket('pub'); 

    pub.bindSync('tcp://127.0.0.1:5555'); 

    setInterval(function(){ 
     pub.send('polyglot'); 
    },500); 

Powyższy kod działa zgodnie z oczekiwaniami ... ale jeśli usunąć setInterval() i po prostu nazwać tak:

var zmq = require('zmq'); 
    var pub = zmq.socket('pub'); 

    pub.bindSync('tcp://127.0.0.1:5555'); 

    pub.send('polyglot'); //this message does not get delivered before exit 
    process.exit(0); 

... Następnie wiadomość nie zostanie dostarczona - program prawdopodobnie zakończy działanie przed zakończeniem połączenia pub.send().

Jaki jest najlepszy sposób, aby upewnić się, że wyciąg zakończy się przed wyjściem z Node.js? Haki zamykające zadziałają tutaj, ale obawiam się, że to tylko maskowałoby problem, ponieważ nie można umieścić wszystkiego, co jest potrzebne, aby zapewnić działanie w haku wyłączającym.

Problem ten można również przedstawić w ten sposób:

if (typeof messageHandler[nameOfHandlerFunction] == 'function') { 
      reply.send('Success'); 
      messageHandler[nameOfHandlerFunction](null, args); 
     } else { 
     reply.send('Failure'); //***this call might not complete before the error is thrown below.*** 
     throw new Error('SmartConnect error: no handler for ZMQ message sent from Redis CSV uploader.'); 
    } 

Wierzę, że to jest legit poważny problem/ponieważ wiele programów wystarczy opublikować wiadomości, a potem umrzeć, ale w jaki sposób możemy skutecznie zapewnić wszystkich wiadomości są wysyłane (choć niekoniecznie odbierane)?

EDIT: One (potencjalny) sposób naprawić to zrobić:

socket.send('xyz'); 
socket.close(); // supposedly this will block until the above message is sent 
process.exit(0); 

Answer 1

nurkowanie w zeromq.node, można zobaczyć, co Socket.send tylko pushes your data to _outgoing:

this._outgoing.push([msg, flags]); 

... a potem calls _flush iff zmq.ZMQ_SNDMORE is unset:

this._flush(); 

Wygląda na to, że _flush is actually doing the socket write. Jeśli nie powiedzie się _flush(), it emits an error.

Edit:

Zgaduję nazywając pub.unbind() przed wyjściem, zmusi _flush() się nazywać:

pub.unbind('tcp://127.0.0.1:5555', function(err) { 
    if (err) console.log(err); 
    process.exit(0); // Probably not even needed 
}); 

Answer 2

Myślę, że odpowiedź jest prosta metoda jest socket.send() Fakt asynchroniczny i dlatego widzimy zachowanie opisane w PO. Pytanie brzmi więc: dlaczego socket.send() musi być asynchroniczne - czy nie może istnieć blokująca/synchroniczna wersja, którą moglibyśmy użyć zamiast tego w zamierzonym celu w OP? Czy możemy prosić o socket.sendSync()? K dzięki