姜天意利用yield与koa解决nodejs异步回调嵌套问题.ppt

1,Todo,异步回调问题 解决方案 Yield与generator 实现一个流程控制器-koa的核心 Koa。,2,开始的问题,某天，你邂逅了一个美女。他给你提了个要求。 请200毫秒后亲我一下，再等3000毫秒后亲我一下，再等1000毫秒后亲我一下。,3,如何解决？,以下是宇宙号js引擎核心设计代码最后一页,4,从一个函数看起,var copy = function(src, dst) var fd_src = fs.open(src, “r”); var fd_dst = fs.open(dst, “w”); while (true) var bytes_read = fs.read(fd_src, buffer, 0, buffer_size); fs.write(fd_dst, buffer, bytes_read); ; 但这是实现不了的,5,6,解决方案1 eventproxy,var ep = EventProxy.create(“template”, “data”,function (template, data) _.template(template, data); ); $.get(“template“, function (template) / something ep.emit(“template“, template); ); $.get(“data“, function (data) / something ep.emit(“data“, data); ); /源码分析/855176/983391,7,解决方案2 Promises/A,/zh/tutorials/es6/promises/ 文章已经全面的不能再全面了。（es6部分支持，需要polyfill）,缺点：重,8,解决方案3 asynceach,var arr = 1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20 var asyncEach = function (fn, arr) var l = arr.length, i = -1; var run = function() i += 1; if (i = l) return; fn(arri, run);/需要fn第二个参数为callback，callback必须要传到run里面 ; run(); /jtyjty99999/astral/blob/master/src/more/parallel.js,缺点：没有流程跟逻辑性,9,还有很多的解决方案。,但你考虑过这种写法么？ exports.updateById = function *(id, task) yield db.open(config); var row = yield db.get(id); /异步操作 for (var key in task) rowkey = taskkey; yield db.put(id, row); /异步操作 ;,10,yield&generator,ES6 中的生成器函数（generator function），目前浏览器中只有 Chrome 29+ 支持它，不过还是先要在 about:flags 中启用实验性JavaScript（Enable Experimental JavaScript ） function* foo1() ; function *foo2() ; function * foo3() ; foo1.toString(); / “function* foo1() “ foo2.toString(); / “function* foo2() “ foo3.toString(); / “function* foo3() “ foo1.constructor; / function GeneratorFunction() native code 注意，函数并不执行！,11,yield&generator,调用生成器函数会产生一个生成器（generator）。生成器拥有的最重要的方法是 next()，用来迭代： function* foo() ; var bar = foo();/注意，函数并不执行！ bar.next(); / Object value: undefined, done: true,12,举个栗子,生成器函数通常和 yield 关键字同时使用。函数执行到每个 yield 时都会中断并返回 yield 的右值（通过 next 方法返回对象中的 value 字段）。下次调用 next，函数会从 yield 的下一个语句继续执行。等到整个函数执行完，next 方法返回的 done 字段会变成 true。 function *test() yield 1; yield 2; yield 3; yield 4; console.log(11111); ,value:1,done:false,13,这尼玛啥用啊？,14,举个栗子，整体控制流程,返回一个生成器，这个生成器可以自己去不断的调用next()方法，从而控制内部函数的执行。我们用整体 runOneByOne函数来控制整个流程。,15,How to?,16,这个函数有什么问题？,并未真正关注整体与个体的关系,17,这个函数有什么问题？,虽然我们可以用整体控制流程，代替了javascript自己去执行的过程。但是，个体的执行结果，仍然对整体是不可见的。 解决方法： 整体提供执行方法(“下一步-nextStep”)，个体，提供执行反馈，在个体执行完毕后，个体的反馈(callback)中，去运行整体的“下一步”执行方法。 还记得value方法吗？ Value返回yield的右值，因此只需要把右值变成一个可以接收反馈的函数即可。,18,第一步，改造亲嘴函数,亲嘴函数作为yield右边，执行后可以返回一个函数，这个函数接收一个callback。,19,第二步，修改nextStep的调用,20,补充：错误处理(来自小乔),通常的错误捕获需要把异步函数的错误一层层向上传递。 yield只需要捕获某一步next的错误即可,21,我们到底实现了什么？,通过整体控制流程，个体只需要改造一下，返回一个函数即可。 书写方式变化，不再需要关注无穷无尽的回调。 runOneByOne- co koa 框架的核心。,runOneByOne(function* () yield 亲嘴(200) yield 亲嘴(3000) yield 亲嘴(1000) )(),22,yieldable and thunk 需要将所有的 callback 都转换成 thunk： function (args) return function 亲嘴(done) fn(args, done); ; ,23,callback to thunk Thunkify thunkify-wrap fs.stat(filename, callback); / = function stat(filename) return function (done) fs.stat(filename, done); / = function *() yield stat(./README.md); ,24,基于 generator 的异步编程 var thunkify = require(thunkify); var co = require(co); /刚才我们实现的runOneByOne var fs = require(fs); var stat = thunkify(fs.stat); var readFile = thunkify(fs.readFile); co(function *() var stat = yield stat(./README.md); var content = yield readFile(./README.md); )();,25,Co需要什么？,可以被 yield 的有： thunk, promise, generator, generatorFunction, object, array 所有的 node 形式的 callback 都需要转换成 thunk object,array,promise 自动识别并转换成 thunk generator, generatorFunction 自动识别并展开执行,26,Koa TJ 和 express 团队的新作品 基于 generator 和 co 的异步解决方案 setter / getter 带来了更方便的 http 辅助方法 更人性化的错误处理 更灵活的中间件形式,27,koa VS express 不提供默认路由 不提供默认的模版渲染 不支持 node 原生的 request 和 response 不支持 express 中间件 提供默认的异步解决方案（generator） 更有表现力的中间件形式 对 request / response 提供更好体验的中间件,28,中间件技术是什么,29,Express的中间件,var http = require(http); var connect = require(connect); var app = connect(); app.use(function(req, res) res.end(Hello!); ); http.createServer(app).listen(3000); 更厚一层的洋葱皮,30,koa的中间件,var koa = require(koa); var ejs = require(koa-ejs); var app = koa(); ejs(app, /*options*/); / 挂载 function* render() 在 totype上 app.use(function* () return yield this.render(index); ); 作为一个洋葱皮上的工具,31,koa的中间件,var koa = require(koa); var session = require(koa-sess); var app = koa(); app.use(session( defer: true ); / 挂载 session(getter 作为一个洋葱皮上的属性,32,koa的异步 舒爽。,var fs = require(co-fs); app.use(function *() var paths = yield fs.readdir(docs); / parallel var files = yield paths.map(function(path) return fs.readFile(docs/ + path, utf8); ); this.type = markdow