Tag: asynchronous

在加载Express 4.x之前启动数据库连接

我可能会错过一些东西,但在官方文档中似乎没有任何东西,所以我坚持要求在这里; 我试图设置一些东西asynchronous(连接到数据库等),当应用程序启动。 我希望在应用程序准备好接受连接之前完成此操作(出于显而易见的原因)。 有没有办法在Express 4.x中做到这一点? 下面是一个基本上我想要的例子 ,但是它不被支持,并且在这一点上已经过了4年。 任何帮助表示赞赏。 编辑:我觉得我应该指出,我使用express-generator来设置我的应用程序,所以所有的服务器侦听完成bin/www 。 我应该只是修改这个文件? 或者我可以从app.js控制它?

asynchronousin循环在node.js而不使用asynchronous库助手类

我是一个初学者node.js。 我正在尝试“learnyounode”教程中的示例。 我正在尝试编写一个程序,该程序需要三个url参数,并从这些url中获取一些数据,并按照提供url的顺序显示返回的数据。 var http = require('http'); var bl = require('bl'); var url = []; url[0] = process.argv[2]; url[1] = process.argv[3]; url[2] = process.argv[4]; var data = []; var remaining = url.length; for(var i = 0; i < url.length; i++){ http.get(url[i], function (response){ response.setEncoding('utf8'); response.pipe(bl(function (err, chunk){ if(err){ console.log(err); } else{ data[i] = chunk.toString(); console.log(data[i]); […]

如何在async.each中包含async.waterfall的外部函数中调用async.each

我在Node.JS中有一个出口模块 exports.doSomethingImportant= function(req, res) { var id = req.params.id; Demo.findOne({'_id': id}) .exec(function(err, demosReturned) { async.waterfall([ function(outerCallBack){ console.log("In the First Call Back"); firstOrderFunction(demosReturned,outerCallBack); }, function(x,outerCallBack){ var y =3 var z = x*y; console.log("In the Second Call Back"); outerCallBack(null,z); } ],function(err,z){ if(err){ console.log("Error is == " +err); }else{ console.log("The Returned Value is == "+z); } }); });//End […]

对FB和G +计数端点的批量asynchronous调用失败

我的应用程序有一个控制器,输出各种网页的总社交计数: http : //pastebin.com/MLBTb3mi 当我一次打几个电话,但是说有1000个网站的网站,我想更新每个url的社交计数时,它的工作正常,当它的音量调用asynchronous时,它会中断 – 特别是g +和fb的突破。 这是控制台错误,我得到作为对fb的graphicsid的调用的响应(这是“body”响应 – 请参阅控制器的第74行: http : //pastebin.com/MLBTb3mi facebook body is {"id":"970371719648388","created_time":"2015-04-02T07:43:09+0000","is_scrap ed":false,"type":"website","updated_time":"2015-04-02T07:43:09+0000","url":"http:\/\/www.zappos.com\/womens-clothing\/"} facebook result is undefined 有谁知道如何解决这个问题,并使控制器工作顺利? 我尝试使用sharedcount.com进行批量呼叫,并且可以毫无问题地同时拨打数千个电话。 我怎么能写我的控制器来处理这样的批量操作,而不使用像sharedcount这样的外部服务?

asynchronous数据库使用recursion调用

我有一个需要recursion下降链接列表数据库树 item 1-> item 2 -> item 3 -> item 4 -> item 5 -> item 6 -> item 7 -> item 8 我的伪代码是 var getItems = function(itemid) { db.getitem(itemid, function(item) { item.items.forEach(function(subitem) { getItems(subitem.id) }) }) getItems(1) 不过, db.getItem是一个asynchronous函数 我想返回一个JS对象与图的结构相同的顶级调用者 达到这个目标的最好方法是什么? 我不知道前面的结构(即不知道每件物品的数量,或树中任何分支的深度),所以我不知道我需要处理的物品数量 我已经尝试了asynchronous库的各种方法,但似乎没有处理recursion

meteor观察arrays服务器端

我有一个recursion函数,在服务器端asynchronous构build一棵树,我想“观察”它,每次有变化时,都会重新运行Meteor中的调用方法。 我做了一个简单的例子,用一个recursionreaddir调用来构build一棵树(在实际的应用程序中,每个节点可能需要几分钟的计算,其结果取决于已经探索的节点) 在server / methods.js中 var fs = Meteor.npmRequire('fs') var path = Meteor.npmRequire('path') var tree = function (dir, r) { try { fs.readdir (dir, function (error, files) { if (files && files.length) for (var i = 0; i < files.length; i++) { r[i] = { name : files[i], children : [] } tree(path.resolve(dir, files[i]), r[i].children) […]

Nodejs SQL连接和asynchronous模块

我一直在与Node.JS一起玩,我发现这个伟大的asynchronous库https://github.com/caolan/async 。 我想用这个replace传统的callback模型,因为它看起来更加令人愉快,而且更容易理解。 这是我的sql查询代码 function query_mssql(config, sql_string){ var connection = new sql.Connection(config, function(err) { // … error checks if (err) { console.log('connection to mssql has failed'); //throw err; }else{ // Query var request = new sql.Request(connection); // or: var request = connection.request(); request.query(sql_string, function(err, recordset) { // … error checks should go here : // […]

通过node.js使用async.js

Visit.js – 注意folloup.id引用0或“n”访问(如树) var visitSchema = new Schema({ code : {type: String, trim: true, required: false, default: ""}, Client : { id: {type: Schema.Types.ObjectId, ref: 'Client'}, }, attendant : [{ name : {type: String, trim: true, required: false, default: ""}, }], followup : [{ id : {type: Schema.Types.ObjectId, ref: 'Visit'} }], }); Client.js var clientSchema […]

nodejs创build后台任务还是subprocess来执行callback函数

NodeJS是否创build后台任务或subprocess来执行callback函数? NodeJS如何执行下面的查询? MyModel.find({}, function (err, docs) { //Do some thing });

用户inputasynchronousNode.JS

在下面的代码中,我想要一个Grid ,请求x和y 。 然后我会再次get Grid 。 但是,由于Node.JS是asynchronous的,所以在请求x之前,在给定x之前和询问y之前执行第二个get 。 在执行其余的代码之前,我应该检查先前的过程是否已经完成。 就我所知,这通常是通过callback完成的。 我目前的callback似乎不够,在这种情况下,我如何强制同步执行? 我试图保持它的MCVE,但我不想留下任何重要的东西。 "use strict"; function Grid(x, y) { var iRow, iColumn, rRow; this.cells = []; for(iRow = 0 ; iRow < x ; iRow++) { rRow = []; for(iColumn = 0 ; iColumn < y ; iColumn++) { rRow.push(" "); } this.cells.push(rRow); } } Grid.prototype.mark […]