从zmq套接字返回值

我正在使用Socket.IO有一个客户端网页从我的Node.JS服务器dynamic获取数据。 在服务器端,我使用zeromq套接字库(REQ / REP结构,请参阅zguide中的rrclient.js示例)将请求转发到Python后端。

但是,由于我的服务器是作为socket.io服务器,我必须包装我的回应如下,以便将其发送回特定的客户端:

socket.on('app_request',function(appRequest){ //route this request to the backend. var results = fetch_data(appRequest); //return it to the client socket.emit('app_results',results); }); 

所以fetch_data函数使用zmq套接字(socket.send)将请求推送到服务器。

但Node ZMQ套接字使用socket.on('message',function(){})响应请求; 监听器,并不实际返回任何东西。

如何使用socket.on('message',function(){}); 返回一个值到发起socket.send()请求的特定函数?

换句话说,我怎么能得到一个客户端的socket.io请求让Node.JS使用ZMQ从python后端获取相关数据,然后将其返回给socket.io客户端? (当然是以非阻塞的方式)

       

网上收集的解决方案 "从zmq套接字返回值"

我做了类似的事情,你会想这样做,

 socket.on('app_request',function(appRequest){ //route this request to the backend. fetch_data(appRequest, function(err, results) { socket.emit('app_results',results); }); }); 

zmq是非阻塞的,因此在将其发送到socket.io之前,不会收到响应,使用此方法,您可以调整fetch_data方法来存储callback,直到返回响应,然后再触发它。

粗糙的fetch_data灵感只有未经testing;

 var zmq = require('zmq'), req = zmq.socket('req'), count = 0, jobs = {}; req.on('message', function(response) { var args = JSON.parse(response), reply = args[0], id = args[i]; if (id && jobs[id]) { jobs[id].apply(null, Array.isArray(reply) ? reply : [reply]); delete jobs[id]; } } function fetch_data(appRequest, callback) { var data = JSON.stringify([appRequest, count]); jobs[count] = callback; req.send(data); ++count; } 

然后在另一边parsingjson并保存id并将其发送回响应。