Node.js 가능한 한 자주 데이터를 처리하는 클러스터

Question

내가 클러스터에 완전히 새롭고 설명서가 나와 함께 클릭하지 않아서 맨손으로 보입니다.

if (cluster.isMaster) 
{ 
    for (let i = 0; i < numCPUs; i++) 
    { 
    cluster.fork(); 
    } 

    for (const file in files) 
    { 
    cluster.workers.send(file); //*** 
    } 
} 
else if (cluster.isWorker) 
{ 
    process.on("message", (msg) => 
    { 
    //...Process data here... 
    }); 
} 

*** 내가 원하는 것입니다. 노동자에게 메시지를 보내는 cluster.workers.send (...)와 같이 바쁘지 않은 사람은 메시지를 가져옵니다. 모든 근로자가 바쁘다면 메시지는 무료 근로자가있을 때까지 보내질 것입니다.

Answer 1

많은 수의 작업을 수행하려면 Vinay Pandya 제안과 같이 redis가 좋은 선택이 될 경우 대기열을 관리하려면 데이터베이스가 필요합니다.

추가 종속성을 방지하려면 클러스터 마스터 프로세스에서 대기열 배열을 사용하고 작업을 해당 배열로 /에서 밀어 넣을 수 있습니다. 자유 노드를 결정하기 위해 '노드'객체를 유지 관리하고 각 노드의 피드백을 받아 작업을 완료하여 업데이트 할 수 있습니다. 피드백은 process.send으로 할 수 있습니다.