Nodejs websocket 与外部系统的通信

Question

我是nodejs的新手，我正在尝试解决与外部系统的通信问题。

有一个外部系统的网关，可以处理端口 5000 上的 websocket 请求。在下面的示例中，当您请求主页时，nodejs 打开 websocket 连接，然后在 websocket open 事件上发送请求并等待用于 HTTP 响应的响应。

您知道如何只向外部系统打开一次 websocket 并根据请求 ID 处理请求吗？

var ws = require('ws');
var express = require('express');
var async = require('async');
var uuid = require('node-uuid');
app = express();
app.get('/', function (req, res) {
    var webSocket = new ws('ws://localhost:5000/');
    async.series([
        function (callback) {
            webSocket.on('open', function () {
                webSocket.send(JSON.stringify({query:'data query', requestid: uuid.v4()}));
                callback(null, 'data query');
            });            
        },
        function (callback) {
            webSocket.on('message', function (data, flags) {
                callback(null, data);
            })
        }
    ], function (err, results) {
        res.setHeader('content-type', 'text/javascript');
        res.send(results[1]);
        webSocket.terminate();
    });
});
var server = app.listen(3000, function () {
    var port = server.address().port
    console.log('Listening at %s', port)
});

Answer 1

感谢您的提示。我以以下解决方案结束，该解决方案符合我的预期：

var ws = require('ws');
var express = require('express');
var uuid = require('node-uuid');
var requests = {};
app = express();
var webSocket = new ws('ws://localhost:5000/');
webSocket.on('open', function () {
    console.log('Connected!');
});            
webSocket.on('message', function (data, flags) {
    var json = JSON.parse(data);
    console.log(json.requestId);
    var res = requests[json.requestId];
    res.setHeader('content-type', 'text/javascript');
    res.send(json.data);
    delete requests[json.requestId];
});

app.get('/', function (req, res) {
    var rid = uuid.v4();
    requests[rid] = res;
    webSocket.send(JSON.stringify({query:'data query', requestId: rid}));
});
var server = app.listen(3000, function () {
    var port = server.address().port
    console.log('Listening at %s', port)
});