1

使用以下代码，我注册了一个 node.js 事件侦听器，等待来自 zeromq 连接的响应，该连接通过名为 zmqevent 的全局 nodejs EventEmitter 转发。

global.zmqevent.removeAllListeners(req.user._id)
global.zmqevent.on(req.user._id, function (msg, status) {
        console.log('event triggered');
});

global.zmq_controller_pub.send(recipient + " " + String(req.user._id) + " " + "getReportSingle");

console.log("1");
console.log("1");
console.log("1");
console.log("1");
console.log("1");
console.log("1");
console.log("1");
console.log("1");

基本上事件队列有效。zmq_controller_pub.send 向我的外部脚本发出请求，响应到达 node.js，发出一个 node.js 事件，该事件触发上面定义的事件侦听器。

如何让事件侦听器在脚本末尾中断 console.log() 链？当前输出如下：

1
1
1
1
1
1
1
1
event triggered

基本上我想等待来自我的 zeromq 连接的响应 2 秒，如果没有响应到达，则触发和替代“离线”结果。但即使是这个简单的示例也不起作用，并且仅在脚本的最后触发事件。你有想法吗？显然，一定有一个愚蠢的错误......

4

2 回答 2

4

你不能。

NodeJS（和 io.js）中 JavaScript 的并发模型是所有同步代码在微/宏任务队列上调度的任何事件处理程序耗尽之前运行。

这正是并发模型的工作方式，它实际上非常有用，因为从来没有中断会使您的代码处于不一致的状态。

于 2015-04-17T08:18:22.210 回答
0

如果我理解正确，你想要这样的东西：

var timeout    = null;
var didRespond = false;

// Wait for an event
global.zmqevent.removeAllListeners(req.user._id)
global.zmqevent.on(req.user._id, function (msg, status) {
  console.log('event triggered');

  // Remove the timeout so it won't trigger the handler anymore.
  clearTimeout(timeout);

  // If we already responded (due to the timeout), we don't respond here.
  if (didResponse) { 
    return;
  }

  // Send your response.
  ...
});

// I think the "removeAllListeners"/"on" combo can be folded into one "once":
// global.zmqevent.once(req.user._id, ...)

// Start a timer that triggers in two seconds.
timeout = setTimeout(function() {
  // Do the "offline" handling, since it took more than 2 seconds for the
  // event to arrive.
  didRespond = true;
  ...
}, 2000);
于 2015-04-17T14:40:47.683 回答