Express Node.JS - 接收 Redis 回调,执行 promises
Express Node.JS - Receiving Redis callback, executing promises
我有一个 Node/Express 路由函数,它在另一个模块中执行 Redis 调用。我想在一个节点模块中执行一个复杂的 Redis 函数,并向路由模块发送一个简单的回调,说明它是成功的。 Redis 调用执行,但我无法执行任何同步函数,这些函数甚至无法从 Redis 调用中检索一个简单的真值。这是我的 Redis 函数:
doctorDB.js
var addDoctor = function addDoctor(id, doc){
var fields = Object.keys(doc.fields);
return client.multi()
.sadd("Doctors", id)
.hmset(id, "lastName", doc.lastName, "firstName", doc.firstName)
.hmset(id, "email", doc.email, "university", doc.university, "work", doc.work)
.sadd(id + ":fields", fields)
.exec(function(err, replies){
console.log("It's in this");
if (doc.middleName){
console.log("Now here");
client.hset(id, "middleName", doc.middleName);
return true;
} else {
console.log("Or here");
return true;
}
});
};
一切都在朝着这个方向努力。现在我想将回调发送到 Express 路由器以向客户端发送响应。我希望它采用同步函数的形式,我已经尝试过很多使用 Q 和 Async 的方法,但没有任何效果。所以要么 A. 我没有完全掌握 promise 函数,要么 B. 我没有完全掌握将值返回到另一个模块。任何帮助将不胜感激。
作为参考,这里有许多在 express router 端失败的尝试:
routes.js
app.post('/addDoctorInfo', ensureLoggedIn('/login'), function(req, res, next){
// function getThis(req){
// var deferred = Q.defer();
// doctorDB.addDoctor(req.body.id, req.body.doc).then(function(response){
// deferred.resolve(response);
// }, function(err){
// console.log(err);
// return deferred.resolve(err);
// });
// return deferred.promise;
// }
// var x = getThis(req);
// console.log(x);
doctorDB.addDoctor(req.body.id, req.body.doc).then(function(x){
console.log(x);
}).catch(function(err){
console.log(err);
}).finally(function(){
console.log("We made it!");
});
// function sendMsg(info){
// console.log(info);
// res.send({success: true});
// }
// async.waterfall([
// doctorDB.addDoctor(req.body.id, req.body.doc),
// sendMsg(info)
// ], function(err){
// console.log(err)
// });
// var DBCALL = doctorDB.addDoctor(req.body.id, req.body.doc);
// Q.fcall(DBCALL).then(function(x){
// return console.log(x);
// }).catch(function(err){
// console.log(err);
// });
});
我想通了。我使用 Q 库来执行所有功能,而不是 client.multi().exec()。这允许干净地执行所有 redis post 命令,然后允许我检索信息。
在routes.js文件中,我只有一小段代码。一切都在 doctorDB.js 文件中执行。
routes.js
app.post('/addDoctorInfo', ensureLoggedIn('/login'), function(req, res, next){
return doctorDB.addDoctor(req.body.id, req.body.doc, req, res, next);
});
doctorDB.js
var addDoctor = function addDoctor(id, doc, req, res, next){
var fields = Object.keys(doc.fields);
function middleName(id, doc){
if (doc.middleName){ return client.hset(id, "middleName", doc.middleName); }
else { return; }
}
return Q.all([Q.ninvoke(client, 'sadd', 'Doctors', id),
Q.ninvoke(client, 'hmset', id, "lastName", doc.lastName, "firstName", doc.firstName, "email", doc.email, "university", doc.university, "work", doc.work),
Q.ninvoke(client, 'sadd', id + ':fields', fields),
middleName(id, doc)]).then(function(x){
return getInfo(id, req, res, next);;
}, function (err) { res.status(404); });
};
这将传递给函数 getInfo(),后者向客户端发送响应:
var redisHGetAll = Q.nbind(client.hgetall, client);
var getInfo = function getInfo(id, req, res, next){
return redisHGetAll(id).then(function(x){
return findByMatchingProperties(x);
}, function (err) { res.status(404); }).then(function(){
return client.smembers(id + ':fields', function(err, reply){
data['fields'] = reply;
res.setHeader('Content-Type', 'application/json');
res.end(JSON.stringify(data));
});
}, function (err) { res.status(404); })
};
function findByMatchingProperties(x) {
for (var y in x){
checkData(y, x[y]);
}
function checkData(y, z){
for (var d in data){
if (d === y){
data[d] = z;
}
}
}
}
var data = {
lastName: null,
firstName: null,
middleName: null,
email: null,
university: null,
work: null,
fields: null
};
我有一个 Node/Express 路由函数,它在另一个模块中执行 Redis 调用。我想在一个节点模块中执行一个复杂的 Redis 函数,并向路由模块发送一个简单的回调,说明它是成功的。 Redis 调用执行,但我无法执行任何同步函数,这些函数甚至无法从 Redis 调用中检索一个简单的真值。这是我的 Redis 函数:
doctorDB.js
var addDoctor = function addDoctor(id, doc){
var fields = Object.keys(doc.fields);
return client.multi()
.sadd("Doctors", id)
.hmset(id, "lastName", doc.lastName, "firstName", doc.firstName)
.hmset(id, "email", doc.email, "university", doc.university, "work", doc.work)
.sadd(id + ":fields", fields)
.exec(function(err, replies){
console.log("It's in this");
if (doc.middleName){
console.log("Now here");
client.hset(id, "middleName", doc.middleName);
return true;
} else {
console.log("Or here");
return true;
}
});
};
一切都在朝着这个方向努力。现在我想将回调发送到 Express 路由器以向客户端发送响应。我希望它采用同步函数的形式,我已经尝试过很多使用 Q 和 Async 的方法,但没有任何效果。所以要么 A. 我没有完全掌握 promise 函数,要么 B. 我没有完全掌握将值返回到另一个模块。任何帮助将不胜感激。
作为参考,这里有许多在 express router 端失败的尝试:
routes.js
app.post('/addDoctorInfo', ensureLoggedIn('/login'), function(req, res, next){
// function getThis(req){
// var deferred = Q.defer();
// doctorDB.addDoctor(req.body.id, req.body.doc).then(function(response){
// deferred.resolve(response);
// }, function(err){
// console.log(err);
// return deferred.resolve(err);
// });
// return deferred.promise;
// }
// var x = getThis(req);
// console.log(x);
doctorDB.addDoctor(req.body.id, req.body.doc).then(function(x){
console.log(x);
}).catch(function(err){
console.log(err);
}).finally(function(){
console.log("We made it!");
});
// function sendMsg(info){
// console.log(info);
// res.send({success: true});
// }
// async.waterfall([
// doctorDB.addDoctor(req.body.id, req.body.doc),
// sendMsg(info)
// ], function(err){
// console.log(err)
// });
// var DBCALL = doctorDB.addDoctor(req.body.id, req.body.doc);
// Q.fcall(DBCALL).then(function(x){
// return console.log(x);
// }).catch(function(err){
// console.log(err);
// });
});
我想通了。我使用 Q 库来执行所有功能,而不是 client.multi().exec()。这允许干净地执行所有 redis post 命令,然后允许我检索信息。
在routes.js文件中,我只有一小段代码。一切都在 doctorDB.js 文件中执行。
routes.js
app.post('/addDoctorInfo', ensureLoggedIn('/login'), function(req, res, next){
return doctorDB.addDoctor(req.body.id, req.body.doc, req, res, next);
});
doctorDB.js
var addDoctor = function addDoctor(id, doc, req, res, next){
var fields = Object.keys(doc.fields);
function middleName(id, doc){
if (doc.middleName){ return client.hset(id, "middleName", doc.middleName); }
else { return; }
}
return Q.all([Q.ninvoke(client, 'sadd', 'Doctors', id),
Q.ninvoke(client, 'hmset', id, "lastName", doc.lastName, "firstName", doc.firstName, "email", doc.email, "university", doc.university, "work", doc.work),
Q.ninvoke(client, 'sadd', id + ':fields', fields),
middleName(id, doc)]).then(function(x){
return getInfo(id, req, res, next);;
}, function (err) { res.status(404); });
};
这将传递给函数 getInfo(),后者向客户端发送响应:
var redisHGetAll = Q.nbind(client.hgetall, client);
var getInfo = function getInfo(id, req, res, next){
return redisHGetAll(id).then(function(x){
return findByMatchingProperties(x);
}, function (err) { res.status(404); }).then(function(){
return client.smembers(id + ':fields', function(err, reply){
data['fields'] = reply;
res.setHeader('Content-Type', 'application/json');
res.end(JSON.stringify(data));
});
}, function (err) { res.status(404); })
};
function findByMatchingProperties(x) {
for (var y in x){
checkData(y, x[y]);
}
function checkData(y, z){
for (var d in data){
if (d === y){
data[d] = z;
}
}
}
}
var data = {
lastName: null,
firstName: null,
middleName: null,
email: null,
university: null,
work: null,
fields: null
};