Tag: asynchronous

如何通过API获取用户

我的项目有两种模式：申请人和公司。 创build，authentication和删除用户发生在相同的API。 所以，我有一个中间件，通过会话ID来parsing用户模型。 例如，它将用于获取当前用户，首先我们通过其ID接收用户，然后发送它。 我的代码如下： getUserByID(req, res, next) { if (req.session.user_id) { async.race([ (callback) => { Applicant.findOne({_id: req.session.user_id}) .catch(() => { return apiHelper.handleError(res, 'Unknown error', 'Can not find user') }) .then(callback) }, (callback) => { Company.findOne({_id: req.session.user_id}) .catch(() => { return apiHelper.handleError(res, 'Unknown error', 'Can not find user') }) .then(callback) } ], (user) => { […]

node.js是服务器响应中asynchronous函数调用的结果

对不起，这个肯定已经回答了。 我特别在这里知道这个线程： 如何返回来自asynchronous调用的响应？ 但说实话，我还是输了。 我只是不明白如何asynchronous调用一个函数，并且包含这个函数返回给客户端的响应。 我有一个相当简单的路由（在routes.js中），它将向网页提供内容。 该网站的特定元素是rfid标签列表。 这个列表是从一个函数中填充的，当然，我希望并且必须调用asynchron。 我使用帕格（以前称为玉）作为模板渲染引擎和我的tags.pug看起来像这样： extends index.pug block content h2!= subheadline p!= messagetext p!= bodyContent 看到最后的p！= bodyContent？ 这个元素应该是标签列表。 以下是我的routes.js中带有app.get（'/ tags'）的代码片段，在该代码片段中将返回该站点： // get the listing of all stored rfid tags app.get("/tags", function(req, res) { res.render('tags', { title: 'RFID Tag Startseite', headline: 'RFID Tag Startseite', subheadline: 'Verfügbare Tags', messagetext: 'Bitte ein RFID Tag […]

JavaScriptasynchronous函数的开销是多less？

问题 ：是否有（如果是的话）在引擎运行时将计算开销声明为async函数，并最终await与常规函数的返回语句相比较？ async function foo() { var x = await bar(); // <— bar() is non-blocking so await to get the return value return x; // the return value is wrapped in a Promise because of async } 与 function foo() { var x = bar(); // <— bar() is blocking inside its body so […]

具有最大并发性的asynchronous并发队列

我遇到了一个自定义asynchronous队列，一次调用10个asynchronous函数的错误。 我开始有50个工作的队列，一旦前10个工作完成，队列移动到随后的10个，直到完成全部。 我遇到的错误是，一旦它完成了50，它将重新开始前5个工作，每次2或3或1个工作。 在队列结束时，还需要less于10个工作。 请创build这两个文件，并用摩卡testing，并亲自看到输出。 注意 ：将摩卡的超时设置为0可以使testing长时间运行。 Queue.js function Queue(func, max) { this.jobs = []; this.func = func; this.max = max ? max : 10; } Queue.prototype.push = function(data) { var self = this; return new Promise(function(resolve, reject){ self.jobs.push({data: data, resolve: resolve, reject: reject}); if(!self.progress) { self.progress = true; self.run(); } }); }; Queue.prototype.run = […]

Javascript：同步到asynchronous转换器库

1）什么是更好的streamlinejs： https ： //github.com/Sage/streamlinejs或叙述： http : //www.neilmix.com/narrativejs/ ？ 任何其他库？ 2）这些图书馆如何工作？ （我阅读文档，我正在寻找一个简单的解释幕后发生的事情..）

如何在另一个asynchronous`each`方法（NodeJS）内部进行asynchronous方法调用？

如何在另一个asynchronous方法中调用asynchronous方法（NodeJS）？ 具体的例子 – 使用数据库，我需要删除所有logging。 但是我不能只删掉整个集合，我需要逐一销毁每个logging，在删除之前我需要读取logging，在应用程序中执行一些业务逻辑，然后删除它。 所以，让我们尝试实现我们的deleteAll方法（实际上它是一个来自node-mongodb-native驱动程序的真实API）： deleteAll = function(selector, callback){ collection.find(selector).each(function(err, doc){ if(err){ callback(err) }else{ if(doc === null){ // each returns null when there's no more documents, we are finished. callback(null) }else{ doSomeBusinessLogicBeforeDelete(doc) // How to delete it using asynchronous `remove` method? collection.remove({_id: doc._id}, function(err){ // What to do with this callback? // And how […]

如何从node.js中到达太快的偶数input逐个写入数据库

我使用繁琐的驱动程序接收来自MS SQL SELECT查询的input。 我已经附加了一个听众的读者“行”事件： request.on('row', function(columns) { insert_row_other_db(columns); }); 我正在将结果写入insert_row_other_db函数中的另一个数据库。 但是这些行的到达速度要比它们能够写得快得多，我只想打开一个连接。 什么是一个很好的方式去de-asyncronyze写入其他数据库？ 我想一个接一个地写行。

嵌套请求被阻塞

我对nodejs比较新。 我最近把过去几个月收集的所有集体知识汇集到一个项目中。 我相信我已经在nodejs中遇到了我的第一个“阻塞”问题。 我有一个页面加载两个request()调用，他们是asynchronous和相应嵌套。 最内层的使用来自最内层的数据来redirect用户。 request(parameters,function(error, response, data){ //the first request passes a token request(newParamters,function(error, response, data){ //the second request passes a url res.redirect(data.info.url); }); }); 错误的是，当我在许多浏览器选项卡中打开它时，它会在第一对夫妇之后结束，然后服务器说data.info.url是未定义的。 我的问题是： 我是否应该一次只提出一项要求？ 我可以保存令牌从第一个request()和redirect用户到第二个request()这将有助于？ 我一直非常良心的asynchronous，而不是阻塞，我感到震惊，这是发生。 任何反馈将是伟大的！

处理NodeJSasynchronous行为

使用NodeJS和MongoDB + Mongoose。 首先，我知道asynchronous非阻塞代码的优点。 所以我处理callback。 但最后我遇到了以下问题。 可以说我有一个可以随时被用户调用的函数。 有可能，一个超级“闪电般”的用户几乎在同一时间调用它两次。 function do_something_with_user(user_id){ User.findOne({_id:user_id}).exec(function(err,user){ // FIND QUERY // Do a lot of different stuff with user // I just cannot update user with a single query // I might need here to execute any other MongoDB queries // So this code is a set of queries-callbacks user.save() // […]

在返回之前等待asynchronous完成

mongoosejsasynchronous代码。 userSchema.static('alreadyExists',function(name){ var isPresent; this.count({alias : name },function(err,count){ isPresent = !!count }); console.log('Value of flag '+isPresent); return isPresent; }); 我知道isPresent是在this.count async函数调用callback之前返回的，所以它的值是未定义的。 但我如何等待callback改变isPresent的价值，然后安全地返回？ 什么效果呢(function(){ asynccalls() asynccall() })(); 在asynchronousstream程中。 如果var foo = asynccall() or (function(){})()会发生什么？ 可以process.nextTick()帮助？ 我知道有很多像这样的问题，但没有解释asynchronous完成之前返回的问题