nodejs_node.js에서 차단 인스턴스 구현

node.js의 고유한 단일 스레드 프로그래밍과 콜백 함수 비동기식 스타일은 우리를 때로는 기쁘게 하고 때로는 걱정하게 만듭니다. 먼저 단일 스레드에 대해 이야기해 보겠습니다. 많은 사람들이 node.js의 단일 스레드가 어떻게 높은 동시성을 달성할 수 있는지 궁금해합니까? 이 문제는 이 기사의 초점이 아니므로 여기서 멈추겠습니다. 명확히 말하면 node.js의 단일 스레드는 단일 스레드 JavaScript 엔진만을 참조합니다. 어쨌든 우리는 JavaScript에서 멀티스레딩 및 차단을 구현할 방법이 없습니다(이 기사에서 사용된 방법도 V8 엔진); 그러나 노드의 경우 .js의 다른 측면이 IO와 같은 멀티스레드가 불가능하다는 의미는 아닙니다. node.js가 이제 많은 수의 요청을 받고 이러한 요청이 IO 집약적이라면 노드가 요청을 수락할 때마다 자바스크립트 스레드는 긴 IO 작업이 발생할 때 항상 여기에서 기다리지 않고 대신 제어권을 넘겨줍니다. 콜백 스택에 IO 작업이 완료된 후 수행할 작업을 추가합니다. (콜백 레벨이 너무 많고 액세스 수가 너무 많으면 콜백 체인 수가 많아지면 스택이 버스트될 수 있습니다.) 이 시간 동안 node.js는 다른 요청을 처리할 수 있습니다. 따라서 node.js의 경우 javascript는 단일 스레드이고 한 번에 하나의 요청만 처리할 수 있지만 javascript가 요청을 처리하는 데 걸리는 시간은 처리할 수 있는 한 더 짧은 경우가 많습니다. 비동기적으로 처리하는 동안 이 요청은 제어를 해제하여 node.js가 다른 요청을 처리할 수 있도록 합니다. 이 동시 요청 중에 IO는 실제로 항상 동시 상태에 있으므로 요청을 처리하는 스레드 수를 줄이고 IO 스레드 수를 늘리기 위해 리소스를 절약합니다. 일반적으로 시간이 오래 걸리는 IO 집약적 요청의 경우 의심할 여지 없이 성능이 향상됩니다. . 홍보하다.

예전에도 IO 집약성을 강조해 왔지만 사실은 node.js의 강점을 강조하는 것입니다. 그에 따라 단점은 CPU 집약적인 요청입니다. 그 이유는 매우 간단합니다. JavaScript는 동시 실행되지 않으며 다른 요청은 하나의 요청이 완료된 후에만 처리될 수 있습니다. 한 요청을 처리하는 데 시간이 오래 걸릴수록 다른 요청도 기다려야 하는 시간이 길어집니다. 동시에 하나의 요청만 처리되며 동시성 성능이 매우 낮습니다.

분명히 말씀드리고 싶은 점은 node.js를 차단하면 안 된다는 것입니다. 비동기적으로 처리할 수 있는 메서드는 비동기적으로 처리됩니다(예: fs.syncReadFile() 대신 fs.readFile() 사용) () 방법) .

노드 내에서 차단할 수 없다고 해서 노드 외부에서 차단할 수 없다는 의미는 아닙니다. 앞서 섬유에 대해 이야기했습니다. 이제 섬유에 차단을 구현해 보겠습니다. 예를 들어 http 요청을 처리해 보겠습니다.

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

var Fiber = require('섬유');
var http = require("http");
섬유(함수 () {
var httpFiber = Fiber.current;
var html = "";
http.get("http://www.baidu.com", 함수(res) {
        var dataFiber = Fiber.current;
res.on("data", 함수(데이터) {
               html = 데이터;
        });
          res.on("end", 함수(데이터) {
httpFiber.run();
        });
});
Fiber.yield();
console.log(html);
}).run();

yield(), run() 메소드에 익숙하지 않은 학생들은 "fibres in node"를 직접 확인해보시기 바랍니다.

파이버는 노드 프로세스에서 실행되지 않으므로 파이버 내 차단은 노드의 전체 성능에 영향을 미치지 않습니다. 그리고 구현하기가 매우 쉽습니다. 차단하려는 경우에만 광섬유를 양보하면 됩니다. 계속 실행해야 하는 경우 run()을 실행하여 파이버를 복원하십시오. 위의 예에서는 http.get 요청이 시작될 때 현재 프로그램을 차단하고 모든 데이터 수신이 완료되면 프로그램을 다시 시작하려고 합니다. 따라서 우리는 http.get을 호출한 후 Fiber.yield()를 사용하여 이 Fiber를 중단합니다. 응답을 모니터링할 때 종료 이벤트가 트리거되면 데이터 전송이 완료되었음을 나타내므로 종료 콜백 함수에서 Fiber.current.run()을 호출하여 광섬유를 복원하면 후속 코드가 가져옵니다. http.get을 동기식으로 요청한 데이터입니다.

위의 예는 단지 아이디어를 제공하기 위한 것입니다. 예를 들어 이 아이디어를 추상적으로 캡슐화하는 경우 콜백 함수를 매개 변수로 받아들이는 비동기 메서드에 대해 1단계 커링을 수행하고, 호출 후 이를 중단하고, 콜백 함수를 하이재킹하여 프로그램 코드를 콜백으로 복원합니다. 기능. 비동기 데이터를 획득한 후 프로그램은 미리 결정된 콜백 함수를 트리거하여 기본적으로 비동기 메서드의 동기화를 실현할 수 있습니다. 이 문단은 꽤 헷갈리지만 기본적으로 Fibers/future의 구현 아이디어입니다. 관심이 있으시면 해당 소스 코드를 참조하세요.