Tag: 非阻塞

事件循环与Node.js主要在同一个线程中？: 所以Node.js使用事件循环来实现非阻塞IO。我想知道如果事件循环与Node.js主要处理请求是在同一个线程？

非阻塞Node.js ClientRequest.write（）: 根据http.js ，node的http模块的ClientRequest.write(chunk,encoding)方法是阻塞的：控制stream暂停，直到所有的数据（当前的一个和所有的缓冲数据）被发送。我想同时使用几个并行连接发送更大量的数据。是否有任何（直接）创build方法的非阻塞版本的方法，就像ClientRequest.write(chunk,encoding,callback)在“后台”发送数据，并在callback处理程序（或事件）被触发时发送已完成？提前致谢！

非阻塞的MongoDB + NodeJS: 我正在尝试在NodeJS环境中的MongoDB集合中find文档。有什么办法可以做到以下几点？这不工作： var foo = function (id) { // find document var document = database.find(id); // do whatever with the document … } 这样就创build了一个块： var foo = function (id) { // find document var document = database.find(id); while (!database.find.done) { //wait } // do whatever with the document … } 我想做的事： var foo […]

在node.js应用程序中完成并行http获取请求: 我想要并行执行一些HTTP请求，映射到结果上，然后在所有结果都准备好的情况下重新同步（join），以便呈现结果页面。伪代码： var value_needed_to_render_page = async.parallel([array of values to iterate over], function to call in parralel on array).join() return page_render(value_needed_to_render_page); 我一直在寻找asynchronous和FutureJS，但没有find一个好方法。

Node.js中的asynchronous代码和循环？: 我已经在asynchronous编程方面做了好几个小时的研究，但我似乎无法在Node中掌握这个单一的概念，所以我想知道这里有人能帮助我。我已经写了下面的代码示例来返回/输出一个简单的string，这是一个对象string的串联： var itemCollection = { item1 : [{ foo : "bar" }, { foo : "bar" }, { foo : "bar" }], item2 : [{ foo : "bar" }, { foo : "bar" }, { foo : "bar" }], item3 : [{ foo : "bar" }, { foo : "bar" }, { foo : […]

如何使一些同步代码在其他asynchronous代码之前运行？: 我有这样的function： var download = function(url, name) { http.get(url, function(response) { // part1 : create a new folder if it doesn't exist dir = './name'; if (!fs.existsSync(dir)){ fs.mkdirSync(dir); } // part 2: download and save file into that folder response.on('data', function (data) { fs.appendFileSync(dir, data); }); }) } 我希望第1部分在第2部分运行之前完成（这样我可以为第2部分指定目录）。我怎样才能做到这一点？（在上面的代码中，就我所知（到目前为止，我是node.js的新手），两个部分将同时运行，所以我不确定部分1会在部分2运行之前总是完成）。

了解Node中的非阻塞IO: 这些代码有什么区别？ ***第一* var express = require('express'); var app = express(); app.post('/', function (req, res) { console.log('Procesando abastecimiento…'); var rawData = ''; req.on('data', function (chunk) { rawData += chunk; }); req.on('end', function(){ console.log('Data recibida: ' + rawData); res.end(); }); }); 第二 var express = require('express'); var app = express(); app.post('/', function (req, res) { console.log('Procesando abastecimiento…'); […]

非阻塞在Node.js循环和池？: 我开始玩node.js，我有一个应用程序，它基本上遍历了几十个对象，并为它们执行一些各种asynchronoushttp请求，并使用从http请求返回的各种数据填充对象。问题更多地涉及Node.js的最佳实践，非阻塞操作，可能与池化有关。原谅我如果我使用了错误的术语，因为我是新手，请不要犹豫，纠正我。所以下面是一个简单的总结，我有一个循环的代码循环数千 //Loop briefly summarized for (var i = 0; i < arrayOfObjects.length; i++) { do_something(arrayOfObjects[i], function (error, result){ if(err){ //various log }else{ console.log(result); } }); } //dosomething briefly summarized function do_something (Object, callback){ http.request(url1, function(err, result){ if(!err){ insert_in_db(result.value1, function (error,result){ //Another http request with asynchronous }); }else{ //various logging error } }); http.request(url2, […]

当我使用node.js时，我应该使用循环asynchronous方式吗？: 我用express来testingnode.js。从理论上讲，如果我在没有任何callback的情况下对“for循环”执行一些非常繁重的计算，它被阻塞，其他请求应该被忽略。但就我而言，定期的“for循环” for(var i=0;i<300000;i++) { console.log( i ); } 不做任何请求块，但只是高CPU负载。它也接受其他请求。但为什么我应该使用其他一些方法来使这些非阻塞如 process.nextTick() 或者，node.js是否使用process.nextTick（）作为默认函数来处理基本循环函数（for，while）？

什么是通过HTTP POST处理大量数据的有效方法？: 我正在编写一个应用程序，将用于绘制和分析海量的日志数据。基本上，我们的应用程序（网站，Tomcat，控制台等）将有自定义的log4j appender发送日志条目到我们的远程服务器。现在我想通过普通的HTTP POST来接受这些日志条目。在这一点上，Web服务将logging到数据库中。我在Node.js和Akka之间的栅栏上。主要是因为我有Java和JavaScript的经验。但是我对Akka的演员模式是新的，我读过Node并不是真正的并行，除非你运行多个节点服务器？我的逻辑是这样的： 1）应用程序POST日志条目到服务器 2）服务器采取HTTP请求，并创build一个Amazon SQS条目（或Azure服务总线…没有决定） 3）工作人员清理队列并将条目存储在数据库中。我认为这将允许真正快速的input，但调用SQS操作将是一个长期的IO过程。我的另一个想法是接受POST请求，将其存储在memcached或Redis中，然后让工作人员从caching中拉出，发送到SQS，然后清除队列中的数据库插入。这将具有HTTP请求尽可能快地传递数据的优点，并让其他工作人员处理logging。这听起来像Akka的工作，因为我可以不分配每个请求的演员，然后让它产生其他演员来处理它进/出caching？在testing阶段，我一次可以轻松看到20-500个请求。取决于我们在testing中打开多less个应用程序。但是一旦完全运行，我们可以看到来自所有应用程序的每秒数千个请求。所以我的问题是如何最好地处理我将得到的海量数据。我关心线程locking，http阻塞等