对数据库和服务器使用 Promise

Question

我还在学习 js，但我正在尝试用 nodejs 编写一个基本的服务器。 服务器应该接受查询，然后从数据库返回 JSON。

我正在尝试使用 Promise，但可以解决这个问题。 我的服务器返回一个空回复。 那我做错了什么？

到目前为止我的服务器文件（简化）：

http.createServer(function (request, response) {
  if (request.method === "GET") {
    ...
    var dbRes = dbFunc.getFromDB(query);
    response.statusCode = 200;
    response.setHeader('Content-Type', 'application/json');
    response.end(JSON.stringify(dbRes));
  }
}).listen(port);

到目前为止我的数据库文件（简化）：

exports.readHandeler = function (query) {

  var promise = new Promise(function(resolve, reject) {
    db.collection('data').find(query).toArray(function(err, res) {
      if (err) {
        throw err;
        reject(-1);
      }
      resolve(res);     
    }    
  });

  promise.then(function(result) {
    return result;
  }, function(err) {
    return -1;
  });
}

Answer 1

我的服务器返回一个空回复。那我做错了什么？

您的dbRes 将是undefined，因为您期待异步承诺执行的响应。只有在 promise 解决后才需要发送响应。

对您的代码进行此更改

http.createServer(function (request, response) {
  if (request.method === "GET") {
  ...
    dbFunc.getFromDB(query).then((dbRes) => {
      response.statusCode = 200;
      response.setHeader('Content-Type', 'application/json');
      response.end(JSON.stringify(dbRes));
    }).catch((err) => {
      console.log('err', err.stack);
    });

  }
}).listen(port);

另外，你需要在db执行部分返回Promise。

exports.readHandeler = function (query) {
  return new Promise(function (resolve, reject) {
    db.collection('data').find(query).toArray(function (err, result) {
      if (err) {
        return reject(err); // or -1 based on your need
      }
      return resolve(result);
    });
  });
};