在 Koa 发送响应后运行代码

Question

为了优化响应延迟，有必要在响应发送回客户端后执行工作。但是，在发送响应后，我似乎可以让代码运行的唯一方法是使用setTimeout。有没有更好的办法？也许在响应发送后插入代码的地方，或者异步运行代码的地方？

这是一些代码。

koa                  = require 'koa'
router               = require 'koa-router'

app = koa()

# routing
app.use router app

app
  .get '/mypath', (next) ->
    # ...
    console.log 'Sending response'

    yield next

    # send response???

    console.log 'Do some more work that the response shouldn\'t wait for'

Answer 1

不要调用ctx.res.end()，它很hacky并且绕过了koa的响应/中间件机制，这意味着你最好只使用express。 这是正确的解决方案，我也发布到https://github.com/koajs/koa/issues/474#issuecomment-153394277

app.use(function *(next) {
  // execute next middleware
  yield next
  // note that this promise is NOT yielded so it doesn't delay the response
  // this means this middleware will return before the async operation is finished
  // because of that, you also will not get a 500 if an error occurs, so better log it manually.
  db.queryAsync('INSERT INTO bodies (?)', ['body']).catch(console.log)
})
app.use(function *() {
  this.body = 'Hello World'
})

不需要ctx.end()
所以简而言之，做

function *process(next) {
  yield next;
  processData(this.request.body);
}

不是

function *process(next) {
  yield next;
  yield processData(this.request.body);
}

Answer 2

我也有同样的问题。

koa只有在所有中间件完成后才会结束响应（application.js，respond是响应中间件，它结束响应。）

app.callback = function(){
  var mw = [respond].concat(this.middleware);
  var gen = compose(mw);
  var fn = co.wrap(gen);
  var self = this;

  if (!this.listeners('error').length) this.on('error', this.onerror);

  return function(req, res){
    res.statusCode = 404;
    var ctx = self.createContext(req, res);
    onFinished(res, ctx.onerror);
    fn.call(ctx).catch(ctx.onerror);
  }
};

但是，我们可以通过调用response.end节点的api函数来解决问题：

exports.endResponseEarly = function*(next){
    var res = this.res;
    var body = this.body;

    if(res && body){
        body = JSON.stringify(body);
        this.length = Buffer.byteLength(body);
        res.end(body);
    }

    yield* next;
};

Answer 3

你可以使用setTimeout在异步任务中运行代码，就像：

 exports.invoke = function*() {
  setTimeout(function(){
    co(function*(){
      yield doSomeTask();
    });
  },100);
  this.body = 'ok';
};