javascript - 带有 node.js 管道接收器的 ZeroMQ 会在一段时间后停止接收消息

Question

我一直在尝试设置通风机/工作人员/接收器模式以抓取页面，但我从未通过测试阶段。我的设置的一个特殊之处是水槽与呼吸机处于相同的过程中。所有 Node 都使用 ipc://传输。目前只交换测试消息。呼吸机发送任务，工作人员接收并等待，然后向接收器发送确认。

症状:一段时间后(通常少于 5 分钟)，Sink 停止接收确认消息，即使呼吸机继续发送任务并且工作人员继续接收任务并发送确认消息。

我知道确认已发送，因为如果我重新启动接收器，它会在启动时获取所有丢失的消息。

我认为 ZeroMQ 处理了自动重新连接。

呼吸机/水槽

var push = zmq.socket('push');
var sink = zmq.socket('pull');
var pi = 0;
setInterval(function() {
    push.send(['ping', pi++], zmq.ZMQ_SNDMORE);
    push.send('end');
}, 2000);
push.bind('ipc://crawl.ipc');
sink.bind('ipc://crawl-sink.ipc');
sink.on('message', function() {
    var args = [].slice.apply(arguments).map(function(e) {return e.toString()});
    console.log('got message', args.join(' '));
});

worker.js

var pull = zmq.socket('pull');
var sink = zmq.socket('push');
sink.connect(opt.sink);
pull.connect(opt.push);

pull.on('message', function() {
    var args = [].slice.apply(arguments).map(function(e) {return e.toString()});
    console.log('got job ', args.join(' '));
    setTimeout(function() {
        console.log('job done ', args.join(' '));
        sink.send(['job done', args.join(' ')]);
    }, Math.random() * 5 * 1000);
});

编辑我尝试将接收器移动到另一个进程，它似乎工作。但是，我真的希望它存在于同一个进程中，并且在每个进程处理多个 zmq 套接字时，我观察到了类似的行为，无论使用何种模式

编辑我正在使用这个模块 https://github.com/JustinTulloss/zeromq.node

Answer 1

我不一定希望这个答案会被接受，但我将其放在这里以供引用。有一个非常忠实的 node-only 模块，叫做 Axon灵感来自 ZeroMQ。

• Axon 没有编译依赖，并重新创建与 ZeroMQ 相同的套接字类型。
• Axon 还基于 pub/sub 套接字类型来创建网络事件发射器。
• 最后，ZMQ 的 req/rep 套接字不适用于 Node.js，因为 ZMQ 期望回复同步发生。作为原生 Node ，Axon 库可以正确处理 req/rep 模式。

注意: ZMQ 和 Axon 不可互操作。