Nodejs 미니멀리스트 입문 튜토리얼(3): Process_node.js

Node에는 여러 스레드가 있지만 v8에서 실행되는 JavaScript는 단일 스레드입니다. Node의 child_process 모듈은 자식 프로세스를 생성하는 데 사용되며, 자식 프로세스를 통해 CPU를 최대한 활용할 수 있습니다. 예:

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

var 포크 = require('child_process').fork;
// 현재 머신의 CPU 수를 가져옵니다
var CPUs = require('os').cpus();
for (var i = 0; i // 새로운 프로세스 생성
포크('./worker.js');
}

다음은 포크를 포함한 몇 가지 프로세스 생성 방법입니다.

1.spawn(command, [args], [options]), 명령 명령을 실행하기 위해 새 프로세스를 시작합니다. args는 명령줄 매개변수입니다
2.exec(command, [options], callback), 명령 명령을 실행하기 위해 새로운 프로세스를 시작하고, 콜백은 프로세스 종료 시 표준 입력, 표준 출력 및 오류 정보를 얻기 위해 사용됩니다
3.execFile(file, [args], [options], [callback]), 실행 파일 파일을 실행하기 위해 새로운 프로세스를 시작하고, 콜백은 프로세스 종료 시 표준 입력, 표준 출력 및 오류 정보를 얻기 위해 사용됩니다
4.fork(modulePath, [args], [options])는 JavaScript 파일 모듈을 실행하기 위해 새 프로세스를 시작하며 이때 Node 하위 프로세스가 생성됩니다

노드간 프로세스 통신

상위 프로세스

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

// parent.js
var 포크 = require('child_process').fork;
// 포크는 하위 프로세스 객체 n을 반환합니다
var n = 포크('./child.js');
// 이벤트 메시지 처리
n.on('메시지', function(m) {
// 자식 프로세스가 보낸 메시지를 받습니다
console.log('메시지를 받았습니다: ' m);
});

//자식 프로세스에 메시지 보내기
n.send({hello: 'world'});

하위 프로세스

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

// child.js
// 이벤트 메시지 처리
process.on('메시지', function(m) {
console.log('메시지를 받았습니다: ' m);
});

// 상위 프로세스에 메시지를 보내는 데 사용되는 send 메소드가 프로세스에 있습니다.
process.send({foo: 'bar'});

여기서 전송 방법은 동기식이므로 많은 양의 데이터를 전송하는 것은 권장되지 않습니다(대신 파이프를 사용할 수 있습니다. 자세한 내용은 http://nodejs.org/api/를 참조하세요). 모두.html#child_process_child_process_spawn_command_args_options).
특수한 경우 메시지의 cmd 속성 값에 NODE_ 접두사가 포함된 경우(예: {cmd: 'NODE_foo'} 메시지) 이 메시지는 메시지 이벤트(그러나 InternalMessage 이벤트)에 제출되지 않습니다. Node에서 내부적으로 사용됩니다.

send 메소드의 프로토타입은 다음과 같습니다:

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

보내기(메시지, [sendHandle])

여기에서 sendHandle(handle)을 사용하여 다음을 보낼 수 있습니다.

1.net.Native, 네이티브 C TCP 소켓 또는 파이프
2.net.Server, TCP 서버
3.net.Socket, TCP 소켓
4.dgram.Native, 네이티브 C UDP 소켓
5.dgram.Socket, UDP 소켓

send가 sendHandle을 보낼 때 실제로는 JavaScript 개체를 직접 보내지 않고 보낼 수 없지만 파일 설명자를 보냅니다(결국 JSON 문자열로 전송됨). 다른 프로세스는 이 파일 설명자를 사용하여 해당 개체를 복원할 수 있습니다.

이제 예를 살펴보겠습니다.

상위 프로세스

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

// parent.js
var 포크 = require('child_process').fork;

var n = 포크('./child.js');

var 서버 = require('net').createServer();
server.listen(7000, function() {
//TCP 서버를 자식 프로세스로 보내기
n.send('서버', 서버);
}).on('연결', function() {
console.log('연결 - 상위');
});

하위 프로세스

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

process.on('메시지', function(m, h) {
If (m === '서버') {
          h.on('connection', function() {
console.log('연결 - 하위');
        });
}
});

포트 7000을 통해 이 프로그램에 액세스하면 연결 – 상위 또는 연결 – 하위가 출력될 수 있습니다. 여기서 하위 프로세스와 상위 프로세스는 동시에 포트 7000을 수신하고 있습니다. 일반적으로 동일한 포트를 수신하는 여러 프로세스는 EADDRINUSE 예외를 발생시킵니다. 이 경우 두 개의 서로 다른 프로세스가 동일한 파일 설명자를 사용하며 Node의 최하위 계층은 포트에서 수신할 때 소켓에 SO_REUSEADDR 옵션을 설정합니다. 이 소켓을 다른 프로세스에서 재사용할 수 있습니다. 여러 프로세스가 동일한 포트를 수신하는 경우 파일 설명자는 동시에 하나의 프로세스에서만 사용할 수 있으며 이러한 프로세스의 소켓 사용은 선점형입니다.

클러스터 모듈

Node v0.8에는 클러스터 모듈이 추가되었습니다. 클러스터 모듈을 통해 물리적 머신에서 동일한 포트를 수신하는 프로세스 그룹을 쉽게 구축할 수 있습니다. 예:

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

var 클러스터 = require('클러스터');
var http = require('http');
var numCPUs = require('os').cpus().length;

// 해당 프로세스가 마스터 프로세스인지 확인
if (cluster.isMaster) {
for (var i = 0; i // 새로운 작업자 프로세스 생성(마스터 프로세스만 호출 가능)
        Cluster.fork();

Cluster.on('exit', function(작업자, 코드, 신호) {
console.log('worker ' 작업자.process.pid ' 사망');
});
} 그 밖의 {
http.createServer(함수(req, res) {
           res.writeHead(200);
          res.end('hello worldn');
}).listen(8000);
}

작업자 프로세스에서 듣기 메소드를 호출하면 듣기 요청이 마스터 프로세스로 전달됩니다. 마스터 프로세스에 작업자 프로세스의 요구 사항을 충족하는 수신 서버가 이미 있는 경우 이 서버의 핸들이 작업자에게 전달됩니다. 존재하지 않는 경우 마스터 프로세스는 서버를 생성한 다음 해당 핸들을 작업자에게 전달합니다. 작업자 프로세스.

클러스터에 대한 자세한 문서: http://www.nodejs.org/api/cluster.html