node.js koa2中(或express),如何在http请求中,使用websocket请求数据,然后返回给http?

Question

我有个需求是http请求过来后,需要从websocket与本地软件通信获取数据,然后用这个数据返回给http,本地软件只能用websocket,socket.io暂时不支持,

意淫很长时间没有好的解决方案,本来想通过websocket.send的时候带上一个唯一的返回标识比如cbEventId:id123123,然后监听这个id,等有返回结果的时候再返回http应答,

感觉理论上能行的同,但是不知道怎么写等待监听到cbEventId返回的时候再返回http应答,websocket的监听都是监听messages时间,而这个监听事件一般都是写在http请求之外的,或者说是写在入口文件的,要是在http 内再声明监听事件应该会覆盖之前的监听...

若是直接入口文件指定一个事件数组,然后再websocket监听message事件中派发监听事件,好像行的通,但是仔细一想在http应答的时候,给监听事件数组赋值,并不是异步请求,而是赋值,所以http很可能就不会返回任何东西,直接先关闭了,然后websocket派发事件得到的数据也传不回来了,请问大神们这要如何解决呢?

Answer 1

按照你的描述，贴个伪代码吧，可以解决问题：

// events.js
export const events = new EventEmitter();

// websocket.js
export const websocket = createWebSocket();
websocket.on('message', function(msg){
    events.trigger(msg.eventId, msg);
});

// router.js
koaRouter.post('/send-to-websocket', async function(ctx, next){
    websocket.send(JSON.stringify({
        eventId: createUniqueId(),
        data: {}
    }));
    events.on(eventId, (msg)=> {
        ctx.body = JSON.stringify(msg);
    });
})