我有一个简化的函数,看起来像这样:
function(query) {
myApi.exec('SomeCommand', function(response) {
return response;
});
}
我想让它调用myApi。Exec,返回回调lambda中给出的响应。然而,上面的代码不能工作,只是立即返回。
只是为了一个非常hack的尝试,我尝试了下面的工作,但至少你知道我想要实现什么:
function(query) {
var r;
myApi.exec('SomeCommand', function(response) {
r = response;
});
while (!r) {}
return r;
}
基本上,“node.js/事件驱动”的好方法是什么?我希望我的函数等待,直到回调被调用,然后返回传递给它的值。
注意:这个答案可能不应该在产品代码中使用。这是一个黑客,你应该知道它的含义。
有uvrun模块(这里更新了较新的Nodejs版本),您可以在其中执行libuv主事件循环(这是Nodejs主循环)的单个循环。
你的代码应该是这样的:
function(query) {
var r;
myApi.exec('SomeCommand', function(response) {
r = response;
});
var uvrun = require("uvrun");
while (!r)
uvrun.runOnce();
return r;
}
你也可以使用uvrun.runNoWait()。这可以避免一些阻塞问题,但占用100%的CPU。)
注意,这种方法在某种程度上否定了Nodejs的整个目的,即让所有内容都是异步和非阻塞的。此外,它可能会大大增加调用堆栈的深度,因此可能会导致堆栈溢出。如果你递归地运行这样的函数,你肯定会遇到麻烦。
请参阅其他关于如何重新设计代码以使其“正确”的答案。
这里的解决方案可能只在您进行测试时有用,特别是当您想要同步和串行代码时。
注意:这个答案可能不应该在产品代码中使用。这是一个黑客,你应该知道它的含义。
有uvrun模块(这里更新了较新的Nodejs版本),您可以在其中执行libuv主事件循环(这是Nodejs主循环)的单个循环。
你的代码应该是这样的:
function(query) {
var r;
myApi.exec('SomeCommand', function(response) {
r = response;
});
var uvrun = require("uvrun");
while (!r)
uvrun.runOnce();
return r;
}
你也可以使用uvrun.runNoWait()。这可以避免一些阻塞问题,但占用100%的CPU。)
注意,这种方法在某种程度上否定了Nodejs的整个目的,即让所有内容都是异步和非阻塞的。此外,它可能会大大增加调用堆栈的深度,因此可能会导致堆栈溢出。如果你递归地运行这样的函数,你肯定会遇到麻烦。
请参阅其他关于如何重新设计代码以使其“正确”的答案。
这里的解决方案可能只在您进行测试时有用,特别是当您想要同步和串行代码时。
实现这一点的一种方法是将API调用封装到promise中,然后使用await来等待结果。
// Let's say this is the API function with two callbacks,
// one for success and the other for error.
function apiFunction(query, successCallback, errorCallback) {
if (query == "bad query") {
errorCallback("problem with the query");
}
successCallback("Your query was <" + query + ">");
}
// Next function wraps the above API call into a Promise
// and handles the callbacks with resolve and reject.
function 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 errors.
async 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 function.
businessLogic();
输出:
Your query was <query all users>
ERROR:problem with the query