node.js http服务器并发问题

每当我尝试发送连续快速的HTTP POST,服务器有时崩溃(java.net.ConnectException:连接被拒绝:连接),有时会冻结(没有错误,但不能再使用它),有时工作….

如果我将HTTP Post慢慢发送到服务器,似乎没有任何问题。

我在node.js中有一个http服务器的简单代码 – 我的猜测是有时NodeJS服务器会收到一个请求,然后在发送响应之前接收到另一个请求,从而导致各种问题。 如何让我的服务器能够同时接受多个请求?

var server = http.createServer(function (req, res) { if (req.method != 'POST') { res.end(); } else { req.on('data', function(chunk) { //Do some stuff here file1=JSON.parse(chunk.toString()); console.log("Hello World") ; } req.on('end', function() { res.writeHead(200, "OK", {'Content-Type': 'text/html'}); res.end(); }); } } server.listen(9000); 

编辑这里是发送HTTP POST的Java程序

  public static String httpUrlRequest(String requestURL, String json) { URL url; String response = ""; HttpURLConnection connection = null; InputStream is = null; try { url = new URL(requestURL); connection = (HttpURLConnection) url.openConnection(); connection.setDoOutput(true); connection.setRequestMethod("POST"); connection.getOutputStream().write(json.getBytes()); connection.getOutputStream().flush(); connection.getOutputStream().close(); int code = connection.getResponseCode(); System.out.println("code" + code); } catch (Exception e) { e.printStackTrace(); } finally { connection.disconnect(); } return response; } public static void main(String[] args) { Date date = new Date(); Gson gson = new Gson(); Map<String, Object> tempMap = gson.fromJson(json, new TypeToken<Map<String, Object>>(){}.getType()); for(int i = 0; i < 10; i++){ date = new Date(); tempMap.put("GetOn", getDateString(date)); httpUrlRequest("http://111.111.11.111:9000" ,gson.toJson(tempMap)); } } 

更新:如果我在nodejs服务器中parsingJSON,那么有时我会在连接被拒绝的地方出现错误。

所以,当我parsing请求数据,出于某种原因,nodejs无法接收发送的整个json文件(5KB)。 相反,它只接收它的一半,我的Java控制台说连接错误。 并且在nodejs正确分析大约3到5个请求之后发生此问题。 然后在下一个请求,一切都出错了。 如何判断java是否断开连接,只发送一半的JSON,或者只发送了一半的JSON导致nodejs崩溃,最终导致连接错误。

如果我注释掉所有的parsing,那么我再也不会得到错误了。 我甚至不明白为什么nodejs中的JSON.Parse会导致java连接错误….

你的问题在于:

  req.on('data', function(chunk) { //Do some stuff here file1=JSON.parse(chunk.toString()); console.log("Hello World") ; } 

由于主体可以被发送多个数据包,您可能会收到多个'data'事件,因此试图parsing不完整的JSON。 试试这个:

 var chunks = []; req.on('data', function(chunk) { chunks.push(chunk); } req.on('end', function () { // assemble all chunks var body = Buffer.concat(chunks).toString(), file1 = JSON.parse(body); res.writeHead(200, "OK", {'Content-Type': 'text/html'}); res.end(); }); 

在这种testing中,通过连接端口很容易达到最大吞吐量。

  1. http://www.slideshare.net/sh1mmer/a-million-connections-and-beyond-nodejs-at-scale
  2. https://groups.google.com/forum/#!topic/nodejs/cRRS7ZJkyzc

在运行node.js之前,简单的解决scheme是ulimit -n 100000 。 但是不要在生产中这样做,如果需要处理的话,最好考虑集群的真正的大连接。

  • 如何在没有冲突的节点中创build一个tmp目录
  • 使用Express中间件进行每个请求的模块configuration?
  • nodejs Async:concurency worker在队列中再次推送相同的任务
  • 如何在Node Js应用程序的多个实例之间同步对象
  • Node.jsdebugging跟踪似乎意味着多个线程的执行 – 如何正确解释这个?
  • 我应该在node.js中fork多less个child_processes()?
  • testing同一个函数的并发调用
  • node.js上的heroku爱好dynamic,限制
  • 什么是通过HTTP POST处理大量数据的有效方法?
  • 作为一个单独的node.js进程运行一个函数?
  • 保护Node.js中的竞争条件