javascript - 是否可以从即将关闭的 ZMQ 套接字获取数据？

Question

我需要实现 ZMQ 的位扩展，其中“REQ”套接字具有名为“.request()”的额外方法”。

此方法可以接收多个参数，并且(这里我有问题)如果第一个参数是 0，.request( 0, ... ) 只是发送消息，否则必须等待 10 秒，如果这段时间我没有响应或错误，我必须 .close() 套接字并再次打开它。

所以，问题是:我如何知道在我的 ZMQ 扩展中，客户端连接到哪里以便能够重新连接有我的新套接字吗？

(我也需要使用 promise ，这就是为什么在代码中出现“Q.deffer()”以及所有这些东西)

var zmq = require('./pzmq');
var rq = zmq.socket('req');
var counter=0;
function onSuccess(msg) {
    console.log('Response: '+msg);
    console.log(msg instanceof Array);
}

function onError(err) {
    console.log('Error: '+err);
}
rq.connect('tcp://127.0.0.1:8888');
console.log(rq.indentity);

// The "Hello" string is sent every second

reply = rq.request(0, counter++,4);
reply.then(onSuccess,onError);

这里我有一个 ZMQ 的小扩展，名为 pzmq:

var zmq = require('zmq');
var Q = require('bluebird');

// Save the original socket method, we need it
var socket = zmq.socket;

// Create and store the wrapper method
zmq.socket = function(kind) {

    // it uses the original method anyways, to get a zmq socket
    var so = socket.call(zmq, kind);

    if (kind == 'req') {
        // if a 'req' socket is requested, then we add the extra method 2
        so.request = request;
    }
    return so;
};


function request() {
    var d = Q.defer();
    var that = this; 

    var onResponse = function () {
        console.log(arguments instanceof Array);
        d.resolve(Array.prototype.slice.call(arguments)); 
        that.removeListener('error', onError);  
    };
    var onError = function (e) {
        d.reject(e);
        that.removeListener('message', onResponse); 
    };

    this.once('message', onResponse); // set up the handler for only one message
    this.once('error', onError);      // set up the handler for only one

    var argumentos = Array.prototype.slice.call(arguments);
    var tiempo = argumentos[0];
    if (tiempo==0){
        this.send(argumentos);
    }else{
        //HERE IS THE PROBLEM
    }

    return d.promise;
}

Answer 1

简短:否。

长:是的。

ZeroMQ 库允许您设置可扩展的消息传递框架，根据您的需求进行设计。灵 active 是最高准则，您的设计和想象力边界是主要限制。

如果您需要 .close()/重新打开 ZMQ 套接字，您的应用程序应创建它自己的、全状态的连接管理器，它既了解并负责传输 -类设置、连接寻址、原型(prototype)选择以及最后但并非最不重要的一点，.connect()/.bind()/ev 的正确时机。重新订阅阶段。

听起来好像很复杂？是的，确实如此，但没有“廉价捷径”。低级库方法和属性根本无法“猜测”您的外部规则和优先级，因此轮到您指定+分析+设计+测试/验证应用程序层上的强制功能/行为。

ZMQ将帮助您执行“剩下的”。