node 事件,node的事件循环机制

  node 事件,node的事件循环机制

  InfoQ:node . js的简单解释(4):node . js的事件机制。

  Node.js简单介绍(四):Node.js的事件机制

  Node.js Node.js的事件机制在其Github代码库(https://github.com/joyent/node)中有一个简短的介绍:Evented I/O for V8 JavaScript。这句类似广告语的话,道出了Node.js的独到之处:基于V8引擎的事件驱动IO。在本文的这一部分,让我来揭开“Evented”这个关键词的所有谜团。

  Node.js能在众多后端JavaScript技术中脱颖而出,也正是因为其基于事件的特性,才广受欢迎。对比Rhino可以看出,Rhino引擎支持的后端JavaScript无法摆脱其他语言同步执行的影响,导致后端编程与前端编程差异显著,编程模型无法统一。在前端编程中,事件被广泛使用,DOM上的各种事件。Ajax大规模应用后,异步请求得到了更广泛的认可,Ajax也是基于事件机制的。在Rhino中,文件读取等操作都是同步进行的。在这种单线程编程模式下,如果采用同步机制,则无法匹配PHP等服务器端脚本语言的成熟度,性能并不显著。直到Ryan Dahl在2009年推出Node.js,后端JavaScript才走出困惑。随着Node.js的推出,我觉得是时候改变两种情况了:

  统一了前后台JavaScript的编程模型。充分利用事件机制,用异步IO突破单线程编程模型的性能瓶颈,让JavaScript在后端实现实用价值。在第二次浏览器大战的领头羊V8的及时帮助下,Node.js在短短两年内取得了可观的运营效率,并迅速被大家所接受。这从Github上Node.js项目的受欢迎程度和NPM上的库数量就可以看出来。

  至于Node.js为什么选择V8 JavaScript的Evented I/O的结构和形式来实现,可以参考2011年初对作者Ryan Dahl的一次采访:http://bostinno . com/2011/01/31/node-js-interview-4-questions-with-creator-Ryan-Dahl/。

  事件机制的实现Node.js中的大部分模块都继承自事件模块(http://nodejs . org/docs/latest/API/events . html)。事件模块(事件。EventEmitter)是事件侦听器模式的简单实现。具有基本事件侦听模式的方法实现,如addListener/on、once、removeListener、removeAllListeners、emit等。和前端DOM树上的事件不一样,因为它没有冒泡、逐层捕捉等属于DOM的事件的行为,也没有preventDefault()、stopPropagation()、stopImmediatePropagation()等处理事件交付的方法。

  从另一个角度来看,事件侦听器模式也是事件钩子的一种机制,用于将内部数据或状态导出到外部调用方。Node.js中的很多对象都有黑盒的特点,功能点较少。如果它们不是以事件挂钩的形式出现,就无法获得对象在运行过程中的中间值或内部状态。这种方式,通过事件钩子,让程序员不用去关注组件是如何启动和执行的,而只关注需要的事件点。

  var选项={

  主持人: www.google.com ,

  端口:80,

  路径:“/上传”,

  方法:“发布”

  var req=http.request(options,function (res) {

  console . log( STATUS: RES . STATUS code );

  console . log( HEADERS: JSON . stringify(RES . HEADERS));

  RES . set encoding( utf8 );

  res.on(data ,function (chunk) {

  console . log( BODY: chunk );

  req.on(错误,函数(e) {

  console.log(请求问题: e . message );

  //将数据写入请求体

  req . write( data \ n );

  req . write( data \ n );

  req . end();在这段HTTP请求的代码中,程序员只需要关注错误、数据等业务事件,不要太关注内部流程。

  值得一提的是,如果您向一个事件添加超过10个侦听器,您将会得到一个警告。这样的设计和Node.js本身的单线程运行有关。设计者认为监听器太多可能导致内存泄漏,所以有这样的警告。调用:

  emitter . setmaxlisteners(0);这个限制可以取消。

  其次,为了提高Node.js程序的健壮性,EventEmitter对象对error事件进行了特殊处理。如果运行时的错误触发了错误事件。EventEmitter将检查是否有侦听器被添加到错误事件中。如果是,该错误将由侦听器处理;否则,该错误将作为异常抛出。如果这个异常没有被外部捕获,它将导致线程退出。

  事件机制的高级应用继承事件。EventEmitter实现一个继承EventEmitter的类非常简单。以下是Node.js中继承EventEmitter的流对象的示例:

  函数流(){

  事件。event emitter . call(this);

  util.inherits(流,事件。event emitter);Node.js将继承的方法封装在工具模块中,所以在这里可以方便地调用。程序员可以通过这种方式轻松继承EventEmitter对象。使用事件机制可以帮助您解决一些问题。

  多个事件间的协作在稍微大一点的应用中,数据和Web服务器的分离是不可避免的,比如新浪微博、脸书、Twitter等。这样做的好处是数据源统一,可以针对同一个数据源开发各种富客户端程序。以Web应用为例。在呈现页面时,通常需要从多个数据源提取数据并将其呈现给客户端。在这种情况下,Node.js可以自然而方便地并行发起对多个数据源的请求。

  api.getUser(用户名,函数(配置文件){

  //获取了配置文件

  api.getTimeline(用户名,函数(时间线){

  //得到时间线

  api.getSkin(用户名,函数(皮肤){

  //得到了皮肤

  });Node.js通过异步机制使请求畅通,达到并行请求的目的,有效调用下层资源。然而,这个场景中的问题是Node.js本身并不支持多个事件响应结果的协调。为了在进行下一步之前实现所有三个请求的结果,程序可能会被更改为以下情况:

  api.getUser(用户名,函数(配置文件){

  api.getTimeline(用户名,函数(时间线){

  api.getSkin(用户名,函数(皮肤){

  //TODO

  });这将导致请求变成串行的,不能充分利用底层的API服务器。

  为了解决这样的问题,我写了一个模块(https://github.com/JacksonTian/eventproxy)来实现多事件协作。以下是上述代码的改进版本:

  var proxy=new event proxy();

  proxy.all(profile , timeline , skin ,函数(profile,timeline,skin) {

  //TODO

  api.getUser(用户名,函数(配置文件){

  proxy.emit(profile ,profile);

  api.getTimeline(用户名,函数(时间线){

  proxy.emit(timeline ,timeline);

  api.getSkin(用户名,函数(皮肤){

  proxy.emit(skin ,皮肤);

  });EventProxy也是事件侦听器模式的一个简单实现。因为底层实现和Node.js的EventEmitter不一样,所以不能合并到Node.js中,但是提供了比EventEmitter更强大的功能,API也符合EventEmitter和Node.js的思想,可以在前端应用。

  这里的all方法是指监听profile、timeline和skin方法后,执行回调函数,并传入监听接收到的数据。

  最后介绍一个多事件协作的解决方案:JSCEX(https://github . com/Jeffrey Zhao/JSCEX)。Jscex通过运行时编译(或者必要时运行前编译)的思想,将同步思维的代码转换成最终的异步代码执行。写代码时可以用同步思维来写,可以享受同步思维的便捷编写和异步执行的高效性能。如果通过Jscex编写,它将采用以下形式:

  var data=$await(Task.whenAll({

  配置文件:api.getUser(用户名),

  时间轴:api.getTimeline(username ),

  skin: api.getSkin(username )

  //使用data.profile,data.timeline,data.skin。

  //TODO本节感谢Jscex作者@老赵(http://blog.zhaojie.me/)的指正和帮助。

  利用事件队列解决雪崩问题所谓雪崩问题,就是在缓存失效的情况下,大并发、高流量会同时涌入数据库,数据库无法同时承受如此大的查询请求,从而影响网站整体的缓慢响应。那么在Node.js中如何处理这种情况呢?

  var select=函数(回调){

  db.select(SQL ,函数(结果){

  回拨(成绩);

  };以上是一个数据库查询的调用。如果站点刚刚启动,此时缓存中没有数据。但是如果访问量很大,同样的SQL会被发送到数据库重复查询,会影响服务的整体性能。一个改进是添加一个状态锁。

  var status= ready

  var select=函数(回调){

  if(状态===就绪){

  状态=“挂起”;

  db.select(SQL ,函数(结果){

  回拨(成绩);

  状态=“就绪”;

  };但是,在这个场景中,select被重复调用,只有第一次调用有效,后续的select没有数据服务。所以此时引入事件队列:

  var proxy=new event proxy();

  var status= ready

  var select=函数(回调){

  proxy.once(selected ,回调);

  if(状态===就绪){

  状态=“挂起”;

  db.select(SQL ,函数(结果){

  proxy.emit(selected ,results);

  状态=“就绪”;

  };在这里,EventProxy对象的once方法用于将所有请求的回调推送到事件队列中,监视器在执行一次后将被移除的特性确保了每个回调只执行一次。对于同一个SQL语句,可以保证从同一查询的开始到结束总是只有一个调用。在这个查询期间,传入的调用只需要在队列中等待数据准备好,从而节省了重复的数据库调用开销。由于Node.js的单线程执行,这里不用担心状态。其实这种方法也可以应用到其他远程调用场景中,即使没有外部缓存策略,也能有效节省重复开销。这里也可以用EventEmitter代替EventProxy,但是可能会有太多的侦听器,这可能会导致警告。您需要调用setMaxListeners(0)来移除警告或设置更大的警告阈值。

  参考:3358 nodejs . org/docs/latest/API/events . html 3359 github . com/jacksonian/event proxy/blob/Master/README . MD 3359 github . com/Jeffrey Zhao/jscex/blob/Master/README-cn . MD关于作者,新浪微博@ Park Ling,前端工程师,曾就职于SAP,现就职于淘宝,花名Park Ling,致力于NodeJS和移动Web App的研发工作。双修前端JavaScript,希望把NodeJS介绍给更多的工程师。兴趣:读万卷书,行万里路。个人Github地址:http://github.com/JacksonTian.

郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。

相关文章阅读

  • Vue项目启动,nodejs启动vue项目,如何启动一个Vue.js项目
  • pm2自动重启node项目,nodejs 部署,nodejs高大上的部署方式(PM2)
  • pm2管理nodejs,
  • npm切换淘宝镜像指令,node配置淘宝镜像
  • node实现爬虫的几种简易方式选择,node实现爬虫的几种简易方式选择,node实现爬虫的几种简易方式
  • node写爬虫,node实现爬虫的几种简易方式选择
  • nodemon怎么安装,nodemon app.js
  • nodemon怎么安装,nodemon app.js,node.js开发辅助工具nodemon安装与配置详解
  • nodejs __dirname,node环境变量
  • nodejs __dirname,node环境变量,node全局变量__dirname与__filename的区别
  • node.js配置环境变量,如何配置node环境
  • node.js配置环境变量,如何配置node环境,node安装及环境变量配置详细教程
  • node. js安装,Windows安装node
  • node. js安装,Windows安装node,Node.js安装详细步骤教程(Windows版)详解
  • node sass安装不上,安装sass一定安装nodesass吗
  • 留言与评论(共有 条评论)
       
    验证码: