位置: 编程技术 - 正文
Nodejs实战心得之eventproxy模块控制并发(node.js 10实战)
编辑：rootadmin推荐整理分享Nodejs实战心得之eventproxy模块控制并发(node.js 10实战)，希望有所帮助，仅作参考，欢迎阅读内容。
文章相关热门搜索词:nodejs示例,nodejs实战教程,nodejs基础知识,nodejs 实战,nodejs总结,nodejs 实战,nodejs 实战,nodejs总结,内容如对您有帮助，希望把文章链接给更多的朋友！
目标
建立一个 lesson4 项目，在其中编写代码。
代码的入口是 app.js，当调用 node app.js 时，它会输出 CNode( ) 社区首页的所有主题的标题，链接和第一条评论，以 json 的格式。
输出示例：
挑战
以上文目标为基础，输出 comment1 的作者，以及他在 cnode 社区的积分值。
示例：
知识点
体会 Node.js 的 callback hell 之美
学习使用 eventproxy 这一利器控制并发
课程内容
这一章我们来到了 Node.js 最牛逼的地方——异步并发的内容了。
上一课我们介绍了如何使用 superagent 和 cheerio 来取主页内容，那只需要发起一次 http get 请求就能办到。但这次，我们需要取出每个主题的第一条评论，这就要求我们对每个主题的链接发起请求，并用 cheerio 去取出其中的第一条评论。
CNode 目前每一页有 个主题，于是我们就需要发起 1 + 个请求，来达到我们这一课的目标。
后者的 个请求，我们并发地发起：），而且不会遇到多线程啊锁什么的，Node.js 的并发模型跟多线程不同，抛却那些观念。更具体一点的话，比如异步到底为何异步，Node.js 为何单线程却能并发这类走近科学的问题，我就不打算讲了。对于这方面有兴趣的同学，强烈推荐 @朴灵 的 《九浅一深Node.js》： 。
有些逼格比较高的朋友可能听说过 promise 和 generator 这类概念。不过我呢，只会讲 callback，主要原因是我个人只喜欢 callback。
这次课程我们需要用到三个库：superagent cheerio eventproxy( )手脚架的工作各位自己来，我们一步一步来一起写出这个程序。
首先 app.js 应该长这样
运行 node app.js
输出如下图：
OK，这时候我们已经得到所有 url 的地址了，接下来，我们把这些地址都抓取一遍，就完成了，Node.js 就是这么简单。抓取之前，还是得介绍一下 eventproxy 这个库。
用 js 写过异步的同学应该都知道，如果你要并发异步获取两三个地址的数据，并且要在获取到数据之后，对这些数据一起进行利用的话，常规的写法是自己维护一个计数器。
先定义一个 var count = 0，然后每次抓取成功以后，就 count++。如果你是要抓取三个源的数据，由于你根本不知道这些异步操作到底谁先完成，那么每次当抓取成功的时候，就判断一下 count === 3。当值为真时，使用另一个函数继续完成操作。而 eventproxy 就起到了这个计数器的作用，它来帮你管理到底这些异步操作是否完成，完成之后，它会自动调用你提供的处理函数，并将抓取到的数据当参数传过来。假设我们不使用 eventproxy 也不使用计数器时，抓取三个源的写法是这样的：
// 参考 jquery 的 $.get 的方法
上述的代码大家都写过吧。先获取 data1，获取完成之后获取 data2，然后再获取 data3，然后 fuck 它们，进行输出。
但大家应该也想到了，其实这三个源的数据，是可以并行去获取的，data2 的获取并不依赖 data1 的完成，data3 同理也不依赖 data2。
于是我们用计数器来写，会写成这样：
丑的一逼，也不算丑，主要我写代码好看。
如果我们用 eventproxy，写出来是这样的：
好看多了是吧，也就是个高等计数器嘛。
这一句，监听了三个事件，分别是 data1_event, data2_event, data3_event，每次当一个源的数据抓取完成时，就通过 ep.emit() 来告诉 ep 自己，某某事件已经完成了。
当三个事件未同时完成时，ep.emit() 调用之后不会做任何事；当三个事件都完成的时候，就会调用末尾的那个回调函数，来对它们进行统一处理。
eventproxy 提供了不少其他场景所需的 API，但最最常用的用法就是以上的这种，即：
先 var ep = new eventproxy(); 得到一个 eventproxy 实例。
告诉它你要监听哪些事件，并给它一个回调函数。ep.all('event1', 'event2', function (result1, result2) {})。在适当的时候 ep.emit('event_name', eventData)。
eventproxy 这套处理异步并发的思路，我一直觉得就像是汇编里面的 goto 语句一样，程序逻辑在代码中随处跳跃。本来代码已经执行到 行了，突然 行的那个回调函数又开始工作了。如果你异步逻辑复杂点的话， 行的这个函数完成之后，又激活了 行的另外一个函数。并发和嵌套的问题虽然解决了，但老祖宗们消灭了几十年的 goto 语句又回来了。
至于这套思想糟糕不糟糕，我个人倒是觉得还是不糟糕，用熟了看起来蛮清晰的。不过 js 这门渣渣语言本来就乱嘛，什么变量提升（ ）啊，没有 main 函数啊，变量作用域啊，数据类型常常简单得只有数字、字符串、哈希、数组啊，这一系列的问题，都不是事儿。编程语言美丑啥的，咱心中有佛就好。
回到正题，之前我们已经得到了一个长度为 的 topicUrls 数组，里面包含了每条主题的链接。那么意味着，我们接下来要发出 个并发请求。我们需要用到 eventproxy 的 #after API。
大家自行学习一下这个 API 吧： lesson4 目录下的 app.js 文件
总结
今天介绍的 eventproxy 模块是控制并发用的，有时我们需要同时发送 N 个 http 请求，然后利用得到的数据进行后期的处理工作，如何方便地判断数据已经全部并发获取得到，就可以用到该模块了。而模块不仅可以在服务端使用，也可以应用在客户端
node.js回调函数之阻塞调用与非阻塞调用 首先，node.js作为javascript运行平台，它采用了事件驱动和异步编程的方式，通过事件注册和异步函数，开发人员可以提高资源利用率，服务器的性能也能
node.js抓取并分析网页内容有无特殊内容的js文件 nodejs获取网页内容绑定data事件，获取到的数据会分几次相应，如果想全局内容匹配，需要等待请求结束，在end结束事件里把累积起来的全局数据进行操
Node.js中使用socket创建私聊和公聊聊天室 先给大家展示效果图：在上篇文章给大家介绍使用Angular和Nodejs、socket.io搭建聊天室及多人聊天室，本文继续介绍Node.js中使用socket创建私聊和公聊聊天室
标签: node.js 10实战
本文链接地址:https://www.jiuchutong.com/biancheng/370633.html 转载请保留说明！上一篇：浅析Node.js 中 Stream API 的使用(nodejs stdin)
