如何在socket.io上执行RPC？

Question

假设我们有一个简单的echo服务器(在第一次请求时调整得更长):

var waiting = 8000;
io.on('connection', function(socket){   
    socket.on('doEcho', function (data) {
        setTimeout( function () {
            socket.emit('echoDone', data);
        }, waiting);
        waiting = 1;
    });
});

然后说一个index.html客户端脚本:

askEcho ("11111", function (resp) {
         console.log("answer for 11111 " + resp);
});
askEcho ("22222", function (resp) {
         console.log("answer for 22222 " + resp);
});

其中askEcho是下列车函数,故作一个RPC存根:

function askEcho (text, fun) {
     socket.emit('doEcho', text);
     socket.on('echoDone', function (data) {
         fun ( data );
     });
  }

显然我得到的是下面的混乱

answer for 11111  22222
answer for 22222  22222
answer for 11111  11111
answer for 22222  11111

因为我为同一个事件安装了两个监听器.这可以轻松解决,但我没有看到如何在客户端正确订购响应,没有服务器端的帮助(编程更多).

这一切似乎都有点太多的负担.不能askEcho正确编码的功能吗？

Answer 1

使用socket.io，您可以通过回调发送和接收确认。

请参阅：http://socket.io/docs/#sending-and-getting-data-(致谢)

Answer 2

实际上，有一个简单的技巧：使用计数器来区分答案，并在完成后删除回调（更好地使用once而不是on）。这只会在服务器和客户端造成微小的变化。

让我们展示一下：

回显服务器是（现在没有任何延迟超时）：

io.on('connection', function(socket){   
    socket.on('doEcho', function (callCounter, data) {    
        socket.emit('echoDone'+callCounter, data);
    });
});

在客户端 ( index.html)，用户代码仍然相同，如所需：

askEcho ("11111", function (resp) {
    console.log("answer for 11111 " + resp);
});
askEcho ("22222", function (resp) {
    console.log("answer for 22222 " + resp);
});

askEcho这是在与服务器端团队合作中正常工作的存根：

var callCounter = 0;
function askEcho (text, fun) {
     var localCallCounter = ++callCounter;
     socket.emit('doEcho', localCallCounter, text);
     socket.once('echoDone'+localCallCounter, function (data) {
         // not required: socket.removeListener ('echoDone'+localCallCounter);
         fun ( data );
     });
 }