NodeJS 事件发射器阻塞问题

Question

我有一个节点应用程序使用此处找到的 Node-ZMQ 绑定处理来自另一个应用程序的一些 ZeroMQ 事件：https://github.com/JustinTulloss/zeromq.node

我遇到的问题是某个事件的操作需要很长时间才能处理，这似乎会阻止在此期间处理任何其他事件。尽管应用程序当前没有集群，但这样做只会提供更多线程，并不能真正解决问题。我想知道是否有一种方法可以让这些异步调用在它们处理时不阻塞其他传入请求，以及如何实现它们。

这是我目前正在做的一个高度浓缩/人为的代码示例：

var zmq = require('zmq');
var zmqResponder = zmq.socket('rep');
var Client = require('node-rest-client').Client;
var client = new Client();

zmqResponder.on('message', function (msg, data) {
  var parsed = JSON.parse(msg);
  logging.info('ZMQ Request received: ' + parsed.event);
  switch (parsed.event) {
    case 'create':
        //Typically short running process, not an issue
    case 'update':
        //Long running process this is the issue
        serverRequest().then(function(response){
            zmqResponder.send(JSON.stringify(response));
        });
     }

});

function serverRequest(){
    var deferred = Q.defer();
      client.get(function (data, response) {
      if (response.statusCode !== 200) {
        deferred.reject(data.data);
      } else {
        deferred.resolve(data.data);
      }
  });
    return deferred.promise;
}

编辑** 这是代码的要点：https://gist.github.com/battlecow/cd0c2233e9f197ec0049

Answer 1

我认为，通过评论线程，我已经确定了您的问题。 REQ/REP 有严格的同步消息顺序保证...您必须接收-发送-接收-发送-等等。 REQ 必须以发送开头，REP 必须以接收开头。因此，您一次只处理一条消息，因为您选择的套接字类型强制执行该操作。

如果您使用的是不同的、非事件驱动的语言，当您尝试连续两次发送或接收时，您可能会收到一条错误消息，告诉您您做错了什么，但 node 允许您这样做并且只是将后续消息排队，直到轮到它们按消息顺序。

您想将REQ/REP 更改为DEALER/ROUTER，它会按您期望的方式工作。您必须稍微更改 ROUTER 套接字的逻辑才能使其正确发送，但其他一切都应该相同。

---

粗略的示例代码，使用已发布要点的相关部分：

var zmqResponder = zmq.socket('router');

zmqResponder.on('message', function (msg, data) {
    var peer_id = msg[0];
    var parsed = JSON.parse(msg[1]);
    switch (parsed.event) {
        case 'create':
            // build parsedResponse, then...
            zmqResponder.send([peer_id, JSON.stringify(parsedResponse)]);
            break;
    }
});

zmqResponder.bind('tcp://*:5668', function (err) {
    if (err) {
        logging.error(err);
    } else {
        logging.info("ZMQ awaiting orders on port 5668");
    }
});

...您需要获取peer_id（或任何您想称呼它的名称，在 ZMQ 命名法中，它是您发送的套接字的套接字 ID，将其视为某种“地址”）从您收到的消息的第一帧开始，然后将其用作您发回的消息的第一帧。

顺便说一句，我刚刚注意到你的主旨是connect()-ing 和 bind()-ing 在同一个套接字上（分别是 zmq.js 第 52 和 143 行）。不要那样做。从其他线索推断，你只是想bind()在这个过程中。