node的socket主动读取数据

现在我需要使用socket向服务端发送请求,等待对方返回信息
发送用socket.write,

socket.write(Buffer.from('data'));

读取返回信息用

socket.on('data',(data) => {
    console.log(data);
})

使用ondata无法实现,调用请求命令直接返回请求结果;而且返回的两条信息太快时,ondata会两条一起输出,
请问:如何才能实现socket.write发送不同命令后可以主动read返回对应信息

补充:

const Command = function(cmdText, data) {//cmdText命令代码,data要传输的数据
    //对cmdText和data处理后生成命令header
    ......
    client.write(header);
    client.write(data);
    //此处需要获取服务器端返回的结果result
    
    return result;
}
阅读 5.1k
2 个回答

Command方法使用async,并返回promise,promise监控 状态aa,并返回 数据bb

const Command = async function(cmdText, data) {//cmdText命令代码,data要传输的数据
    //对cmdText和data处理后生成命令header
    ......
    aa = false;
    bb = '';
    client.write(header);
    client.write(data);
    client.resume();
    
    return new Promise(function (resolve, reject) {
            let a = setInterval(function(){
            if(aa) {
                clearInterval(a)
                resolve(bb);
            }
        },1)
    });
}

有数据时,改变全局变量 状态aa和数据bb

client.on('data', (data) => {
    aa = true;
    bb = data.toString();
    client.pause();
});

最后使用await获取socket返回值。

function test() {
    let a = await Command('test', Buffer.from('hello world'));
    console.log(a)
}

发送不同的emit,监听不同emit

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题