node.js - 与 Nodejs Websocket 同步发送消息

Question

我的应用程序包含三个模块：

1. WebSocket 模块：驻留在远程服务器（互联网）上，它充当 Websocket 服务器，用于处理客户端模块和 Webhook 模块之间的连接。
2. Webhook 模块：驻留在远程服务器（互联网）上，它充当 webhook 来回答用户的 HTTP 发布请求。它也通过 websocket 连接到 Websocket 模块。
3. 客户端模块：驻留在我的本地机器上，它通过 websocket 连接到 Webhook 模型。该客户端负责从我的本地后端获取查询。

当用户通过 HTTP Post 请求调用 Webhook 模块时，Webhook 模块通过 websocket 发起与 WebSocket 模块的连接。然后，WebSocket 模块发起与客户端模块的连接并返回必要的信息。实际上，我必须这样做以消除我公司中被阻止的 HTTP 隧道。

问题是，当我打开两个浏览器窗口以使用不同的参数同时执行 HTTP Post 请求时，例如参数“A”，我希望得到返回“A”，参数“B”，我希望得到“B”而不是“A”。但是我的代码/设计有问题。如果我同时执行，我抛出“A”然后我得到“B”，这是错误的。我该如何克服这一点。

这是一个简单的图表来说明它。

WebSocket 模块：

'use strict'

//This is WebSocket Server

const clients = {};
const SocketIO = require('socket.io');
const express = require('express');
const http = require('http');
const app = express();
const server = http.createServer(app);
const ws = SocketIO(server);

const port = 3000;

var clientid;

ws.on('connection', (client) => {
  clients[client.id] = client;
  console.log('new connection', client.id);

  clientid = client.id;

  client.emit('message', { message: 'welc' })

  client.on('disconnect', () => {
    delete clients[client.id];
    console.log('Client ' + client.id + ' disconnected. Deleted');
  });

  client.on('WH', function (from, msg) {
    console.log('Message from Webhook', from, ' : ', msg);
    client.broadcast.emit('message', { message: msg });

    //console.log('send to: ' + clientid);
    //ws.to(clientid).emit('hey', { message: msg });

    //client.emit('message', { message: msg })
  });

  client.on('CL', function (from, msg) {
    console.log('Message from Client', from, ' : ', msg);
    client.broadcast.emit('message', 'me', msg);

    //ws.to(client.id).emit('message', 'me', msg);
    //client.emit('message', 'me', msg);
  });


});
server.listen(process.env.PORT || port);
console.log('WebSocket Server is running on port ' + port);

网络钩子模块

'use strict'

//This is WebHook Server

const express = require('express');
const bodyParser = require('body-parser');
const request = require('request');
const http = require('http');
const io = require('socket.io-client');

const app = express()
app.use(bodyParser.json())

const clients = {};
const SocketIO = require('socket.io');
const server = http.createServer(app);
const ws = SocketIO(server);

const port = 5000;

let Res;
let httpreq = false;
let nctid;
let ts;

const socket = io.connect('http://localhost:3000', {reconnect: true});

// Add a connect listener
socket.on('connect', function() {
    console.log('Connected to WebSocket server!');
});


socket.on('message', function(from, msg) {

    //console.log('Message from ', from, ' : ', msg);
    console.log('nctid: ' + nctid + ', ts: ' + ts);

    //Get the message from Client

    if (httpreq) {
        Res.send({
            replies: [{
                type: 'text',
                content: msg,
            }],
            conversation: {
                memory: {
                    key: msg
                }
            }
        })

        httpreq = false;
    }
});

app.listen(process.env.PORT || port, () => {
    console.log('Webhook server is running on port ' + port);
})


app.post('/', (req, res) => {
    //console.log(req.body)

    let query = req.body.nlp.entities.query[0].value;
    nctid = req.body.nlp.entities.nctid[0].value;

    ts =  Math.floor(Date.now() / 1000);

    console.log("query: " + query + '|' + nctid + '|' + ts);

    //Send message to WebSocket server with parameter query and NCTID

    socket.emit('WH', 'me', query + '|' + nctid);
    Res = res;
    httpreq = true;
})

app.post('/errors', (req, res) => {
    console.log(req.body);
    res.send();
})

客户端模块

'use strict'

//This is client app running on client premise

const request = require('request');
const parser = require('xml2json');
const io = require('socket.io-client');
const socket = io.connect('http://localhost:3000', {reconnect: true});

// Add a connect listener
socket.on('connect', function(socket) {
    console.log('Connected to WebSocket server!');
});

socket.on('message', function(from, msg) {
    //console.log('MSG', from, ' : ', msg);
    console.log(from);
    let param = from.message.split('|');
    let query = param[0];
    let nctid = param[1];


    if (typeof nctid != 'undefined') {
        getNCTID(nctid, function(returnValue) {
            //console.log(returnValue);
            try {
                let json = parser.toJson(returnValue);
                json = JSON.parse(json);

                if (query == 'title')
                    socket.emit('CL', 'me', 'Title is ' + json.clinical_study.brief_title);
                else
                    socket.emit('CL', 'me', 'Status is ' + json.clinical_study.overall_status);

            } catch (e) {
                console.log(e);
                socket.emit('CL', 'me', 'No NCTID ' + nctid);
            }
        });
    }
});


function getNCTID(nctid, callback) {

    let url = "https://clinicaltrials.gov/ct2/show/" + nctid + "?displayxml=true";

    let options = {
        url: url,
        method: 'GET'
    }

    //console.log(options);
    let requestWithEncoding = function(options, callback) {
        let req = request.get(options);

        req.on('response', function(res) {
            let chunks = [];
            res.on('data', function(chunk) {
                chunks.push(chunk);
            });


            res.on('end', function() {
                let buffer = Buffer.concat(chunks);
                let encoding = res.headers['content-encoding'];
                if (encoding == 'gzip') {
                    zlib.gunzip(buffer, function(err, decoded) {
                        callback(err, decoded && decoded.toString());
                    });
                } else if (encoding == 'deflate') {
                    zlib.inflate(buffer, function(err, decoded) {
                        callback(err, decoded && decoded.toString());
                    })
                } else {
                    callback(null, buffer.toString());
                }
            });
        });


        req.on('error', function(err) {
            callback(err);
        });
    }


    requestWithEncoding(options, function(err, data) {
        if (err) {
            console.log('err:' + err);
            callback('error');
        } else
            //console.log(data);
            callback(data);
    })
}

标签： node.jswebsocket