带有 ZeroMQ REQ/REP 的 Meteor.methods 永远不会返回答案

Question

这是我在服务器上的方法：

Meteor.methods({
    dotest: function (ruleid) {
        console.log('Do test called with argument : %s', ruleid)
        var socket = zmq.socket('req')
        socket.connect('tcp://localhost:5555')
        socket.send(ruleid)
        socket.on('message', function(data) {
            console.log('Reply: ' + data);
            return data
        })
    }
})

当然，它不起作用，因为在 dotest 方法结束后会触发“return”。 我该如何解决这个问题？

Answer 1

这可以通过Futures来完成！

Meteor.methods({
    dotest: function (ruleid) {
        var Future = Npm.require("fibers/future");
        var fut = new Future();

        console.log('Do test called with argument : %s', ruleid);
        var socket = zmq.socket('req');
        socket.connect('tcp://localhost:5555');
        socket.send(ruleid);
        socket.on('message', function(data) {
            console.log('Reply: ' + data);
            fut['return'](data);
        });
        return fut.wait();
    }
});

我没有对此进行测试，但它应该可以工作。编码愉快。