nodejs异步IO

业界作者：SegmentFault 2022-04-24 15:06:34 阅读：1060

作者：小江不可求

来源：SegmentFault 思否社区

1.IO了解

IO分类(是否立即获取到调用之后的结果)：

阻塞IO：

重复调用IO操作，判断IO是否结束（任务轮询:read、select、poll、kqueue、event ports）因为在轮询的过程中，程序再等待IO的结果，对于代码而言，还是同步的效果。

非阻塞IO：

实现无需判断的非阻塞IO，通过某种信号或者回调的形式传回给当前的代码进行使用


文件IO：

放入到node实现的线程池中

异步网络IO：

利用到了node的核心库libuv库

可判断所运行的平台

根据平台调用不同的异步IO处理的方法
（做到了类似于跨平台的效果）

实现异步IO的过程：

2.为什么要使用异步I/O

在不同模式下执行两任务，显然，异步使用的时间，比同步使用的时间少

3.事件驱动架构

事件轮询是异步IO的实现，对异步IO结果的处理（利用事件驱动、发布订阅、观察则模式），依赖于nodejs的events库;

代码层面展示:


const EventEmitter = require('events');
const emitter = new EventEmitter();

// 订阅1
emitter.on('event',(result)=>{
    console.log('event1 fired');
    console.log(result);
})

// 订阅2
emitter.on('event',(result)=>{
    console.log('event2 fired');
})

// 发布
emitter.emit('event','event_result');

/*结果
event1 fired
event_result
event2 fired
*/

理解到平时编码中，所写的异步代码（订阅啊事件），回调函数就是事件的处理程序，不过发布事件是由系统完成的

4.nodejs单线程

怎么实现并发：异步非阻塞IO配合事件事件回调通知

运行js代码的主线程是单线程（减少了多线程切换的cpu开销与内存开销），但是在libuv库中，使用到了node实现的线程池

缺点：处理cpu密集型的任务时，无法体现多核cpu的优势

代码展示单线程处理cpu密集型任务时出现的阻塞现象：


const http = require('http');

function sleepTime(time){
    const sleep = Date.now() + time * 1000;
    // 同步代码，等待时间
    while(Date.now() < sleep){};
    return;
}

sleepTime(4);
const server = http.createServer((req,res)=>{
    res.end('server starting ...');
});

server.listen('8080',()=>{
    console.log('服务启动了');
})

5.nodejs应用场景

适合IO密集型任务处理，nodejs作为中间层，搭建bff层服务器（提高吞吐量，方便处理数据）：

点击左下角阅读原文，到 SegmentFault 思否社区 和文章作者展开更多互动和交流，扫描下方”二维码“或在“公众号后台“回复“ 入群 ”即可加入我们的技术交流群，收获更多的技术文章~

- END -

*文章为作者独立观点，不代表免费SSL 立场

本文由 SegmentFault 发表，转载此文章须经作者同意，并请附上出处(免费SSL )及本页链接。

原文链接 https://www.51uos.com/news/industry/3530.html