NodeJs_javascript 기술의 비차단 방법 소개

먼저 NodeJ를 사용하여 기본 서버를 구축합니다.
index.js

코드 복사 코드는 다음과 같습니다.

var requestHandler = require(" ./requestHandler");
var server = require("./server");
var Route = {
"/hello": requestHandler.hello,
"/upload" : requestHandler.upload
};
server.start(route)

server.js

코드 복사 코드는 다음과 같습니다.

server.js

코드 복사 코드는 다음과 같습니다.

var http = require("http");
var url = require("url"); start = function(route) {
var server = http.createServer(function(req, res) {
var pathName = url.parse(req.url).pathname;
var handler = Route[pathName ];
if (handler) {
console.log("경로를 통해:" pathName ":" new Date().getTime())
handler(res)
} else {
res.writeHead(404, {"Content-Type": "text/plain"})
res.end()
}
}); 8088);
};


requestHandler.js

코드 복사 다음: exports .hello = function(res) {

res.writeHead(200, {"Content-Type": "text/plain"})

res.write ("안녕하세요.");
res .end();
};
exports.upload = function(res) {
res.writeHead(200, {"Content-Type": "text/plain"});
res .write("upload");
res.end()
};


cmd에 node index를 입력합니다. js를 시작합니다.
그러나 위의 코드는 차단됩니다. createServer의 콜백 함수에 장기 계산이 있는 경우입니다. 그런 다음 node.js의 이벤트 폴링을 차단합니다.

NodeJS에서 효율성의 핵심은 이벤트 루프로 빠르게 복귀하는 것입니다.
requestHandler.js를 다음과 같이 수정했습니다. 이벤트 루프가 sleep 함수에 의해 차단되었기 때문에 createServer의 콜백이 제때에 반환되지 않습니다.

코드 복사 코드는 다음과 같습니다. function sleep(milliSecond) {

var startTime = new Date().getTime();

console.log(startTime);
while(new Date().getTime() <= milliSecond startTime) {
}
console .log( new Date().getTime());
}
exports.hello = function(res) {
sleep(20000)
res.writeHead(200, {"Content- 유형": "text/plain"});
res.write("안녕하세요.");
res.end();
};
exports.upload = function(res) {
res.writeHead(200, {"Content-Type": "text/plain"})
res.write("upload")
res.end(); ;


먼저 http://localhost:8088/hello를 입력한 다음 http://localhost:8088/upload를 입력하세요. 업로드에 많은 시간이 걸리지는 않지만 hello가 완료될 때까지 기다려야 한다는 것을 알 수 있습니다.
비동기적으로 호출하는 방법을 찾으려고 노력 중입니다. 예를 들어, Formidable의 업로드는 비차단 테스트를 거쳤습니다. Formidable의 소스 코드를 살펴보면 가장 중요한 것은 다음 코드라는 것을 알았습니다.

코드 복사

코드는 다음과 같습니다. 다음과 같습니다:

IncomingForm.prototype.parse = function(req, cb) {
this.pause = function() {
try {
req.pause();
} catch (err) {
// 스트림이 파괴되었습니다
if (!this.ended) {
// 완료되기 전에 충돌 및 소각
this._error(err );
}
false를 반환합니다.
}
true를 반환합니다.
};
this.resume = function() {
try {
req.resume();
} catch (err) {
// 스트림이 파괴되었습니다
if (!this.ended) {
// 완료되기 전에 충돌 및 소각
this._error(err );
}
false를 반환합니다.
}
true를 반환합니다.
};
this.writeHeaders(req.headers);
var self = this;
req
.on('error', function(err) {
self._error(err);
})
.on('aborted', function() {
self.emit('aborted');
})
.on('data', function(buffer) {
self.write(buffer);
})
.on ('end', function() {
if (self.error) {
return;
}
var err = self._parser.end();
if (err) {
self._error(err)
}
});
if (cb) {
var fields = {}, files = {};
이
.on('필드', 함수(이름, 값) {
필드[이름] = 값;
})
.on('파일', 함수(이름, file) {
files[이름] = file;
})
.on('error', function(err) {
cb(err, fields, files);
})
.on('end', function() {
cb(null, 필드, 파일);
});
}
이것을 반환하세요.
};

parse中，将head信息解析流来这段是阻塞的。但是真正上传文件却是현재req.on(data)中，是利用了事件驱动，是不阻정말 좋아요.就是说，他的不阻塞模型依赖整个nodeJS事件分派架构。
那么imagesleep那样消耗大weight计算，但是又不能依赖nodeJS分派架构的时候怎么办?
现에서 介绍一种,类似于html5 WebWorker 적법.
将requestHandler.js改造如下：

复代码 代码如下:

var childProcess = require("child_process");
exports.hello = function(res) {
var n = childProcess.fork(__dirname "/subProcess.js");
n.on('message', function() {
res.writeHead(200, {"Content-Type": "text/plain"});
res.write("안녕하세요. ");
res.end();
});
n.send({});
};
exports.upload = function(res) {
res.writeHead(200, {"Content-Type": "text/plain"});
res.write("업로드");
res.end();
};

并加入subProcess.js

复主代码 代码如下:

function sleep(milliSecond) {
var startTime = new Date().getTime();
console.log(startTime);
while(new Date().getTime() <= milliSecond startTime) {
}
console.log(new Date().getTime());
}
process.on('message', function() {
sleep(20000);
process.send({});
});

测试，当hello还에서 업로드하세요. twitter.comNodeJS是异步的입니다.但是是何种程道는 异步，这个概念就没有几篇文章讲对了。
NodeJS，他是一个双层的架构。C 。并且是单线程的。这点尤其Node其实是C는 v8调用js命令，为了实现调用顺序维护了一个Event序列。因此，一个js function内部，他的调用绝对会对其他의 기능은 产生阻塞입니다. nextTick과 setTimeout은 새로운 기능을 제공하지 않으며, 더 이상 이벤트가 발생하지 않습니다.要简单的多，直接加入Event序列顶层(有个啥啥事件) . 而setTimeout이 io에 의해 결정된 콜백 이벤트에 따라 결정되었습니다.数，第二个参数是一个콜백.那么node中第一件事就是记录下callback到了c ，而不是js这块。所以，exec到callback은 http.createServer到触发callback을 사용하여 为止是异步的입니다.命令，相信这个过程速島不常快。然后等待回调的过程Node用c 隐藏了，他也是异步的。
而我这篇文章想说明的是，如果再js端有花费大时间多运算怎么办.就用我上所说的방법 ，이용 js 打开c 적 线程， 这 个 subprocess.js ， 不 in node 의 event序列 内 护 。 是 새로운 线程 ， 因此 不会阻塞其他 的 js function