如何正确使用Redis与Koa(node.js)

Question

我尝试从redis db获取信息并将其作为响应主体返回给用户.首先,这是一个失败的代码:

var redis = require("redis"),
    koa = require("koa");

var app = koa(),
    port = process.argv[2] || 3000,
    client = redis.createClient();

app.use(function* (next) {

    client.get("test", function (err, res) {
        this.body = res;
    });

    yield next;
});

app.listen(port);
console.log("listen on port " + port)

当然,因为yield调用在调用回调之前结束.

然后这是一个成功的代码:

function askRedit (callback) {
    client.get("test", callback);
}

app.use(function* (next) {
    this.body = yield askRedit;
    yield next;
});

但我显然误解了为什么第二个工作正常.是否yield在yield askRedit具有比在同一个行为yield next？

编辑:我刚刚看到一个似乎有点回答的页面:https://github.com/visionmedia/co/blob/master/examples/redis.js

所以现在我将尝试理解这些神奇的产量..这是一种用异步调用做同步事情的方法吗？

Answer 1

这是正确的解决方案:

"Use strict";

var redis = require("redis"),
    coRedis = require("co-redis"),
    koa = require("koa");

var app = koa(),
    port = process.argv[2] || 3000,
    db  = redis.createClient(),
    dbCo = coRedis(db);

app.use(function* () {
    yield dbCo.set("test", 42);
    this.body = yield dbCo.get("test");
});


app.listen(port);
console.log("listen on port " + port)

这些链接帮助:

https://github.com/koajs/workshop/tree/master/01-co

http://www.jongleberry.com/koa.html

当然还有"共同复兴"

谢谢你!