如何使函数等到使用node.js调用回调

Question

如何使函数等到使用node.js调用回调我有一个简化的功能，如下所示：function(query) {   myApi.exec('SomeCommand', function(response) {     return response;   });}基本上我希望它调用myApi.exec，并返回回调lambda中给出的响应。但是，上面的代码不起作用，只是立即返回。只是为了一个非常hackish尝试，我尝试了下面没有工作，但至少你明白了我想要实现的目标：function(query) {   var r;   myApi.exec('SomeCommand', function(response) {     r = response;   });   while (!r) {}   return r;}基本上，什么是一个好的'node.js /事件驱动'的方式来解决这个问题？我希望我的函数等到调用回调，然后返回传递给它的值。

Answer 1

“good node.js / event driven”这样做的方法就是不要等待。

与使用像节点这样的事件驱动系统几乎所有其他内容一样，您的函数应该接受一个回调参数，该参数将在计算完成时调用。调用者不应该等待正常意义上的“返回”值，而是发送将处理结果值的例程：

function(query, callback) {
  myApi.exec('SomeCommand', function(response) {
    // other stuff here...
    // bla bla..
    callback(response); // this will "return" your value to the original caller
  });}

所以你不要这样使用它：

var returnValue = myFunction(query);

但是像这样：

myFunction(query, function(returnValue) {
  // use the return value here instead of like a regular (non-evented) return value});

Answer 2

实现此目的的一种方法是将API调用包装到promise中，然后使用await等待结果。

// let's say this is the API function with two callbacks,// one for success and the other for errorfunction apiFunction(query, successCallback, errorCallback) {
    if (query == "bad query") {
        errorCallback("problem with the query");
    }
    successCallback("Your query was <" + query + ">");}// myFunction wraps the above API call into a Promise// and handles the callbacks with resolve and rejectfunction apiFunctionWrapper(query) {
    return new Promise((resolve, reject) => {
        apiFunction(query,(successResponse) => {
            resolve(successResponse);
        }, (errorResponse) => {
            reject(errorResponse)
        });
    });}// now you can use await to get the result from the wrapped api function// and you can use standard try-catch to handle the errorsasync function businessLogic() {
    try {
        const result = await apiFunctionWrapper("query all users");
        console.log(result);

        // the next line will fail
        const result2 = await apiFunctionWrapper("bad query");
    } catch(error) {
        console.error("ERROR:" + error);
    }}// call the main functionbusinessLogic();

输出：

Your query was <query all users>ERROR:problem with the query