Nodejs websocket与外部系统通信

Posted 2023-02-16

【中文标题】Nodejs websocket与外部系统通信

【英文标题】：Nodejs websocket communication with external system

【发布时间】：2014-11-21 19:06:02

【问题描述】：

我是 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)
);

【问题讨论】：

您不会在服务器启动或第一页请求时打开 Web 套接字，然后将该套接字存储在特定请求之外的变量中。然后，您可以将该套接字用于将来的任何请求。如果您可能同时从多个页面请求通过同一个 websocket 运行多个请求，那么您将必须能够区分哪个 websocket 响应属于哪个请求。

或者你可以在缓存中维护 N 个 websocket，当请求进入时从缓存中获取一个，然后在请求完成时将其放回缓存中。

【参考方案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)
);