クラスター化されたノード アプリがあり、1 つの要求からすべてのワーカーの状態を取得する方法を探しています。
私は急行を使ってマステンに尋ねますが、急行とは関係ありません。1つのリクエストで、次のようなものが欲しいです:
[
{
pid: 'xxxxxx',
state: 'I\'m fine'
},
{
pid: 'xxxxxx',
state: 'I\'m sick'
},
{
pid: 'xxxxxx',
state: 'I\'m fine'
},
]
迅速な回答を送信するには、すべてのワーカーの回答を待ち、それらを連結する必要があります。しかし問題は、単純な聞き手ではなく、ワーカーからの特定の回答を待つにはどうすればよいかということです。
クラスター化されたアプリのコード サンプルを次に示します。http://localhost:8000/のリクエストで以前のJsonを取得しようとしています
import * as cluster from 'cluster';
import * as express from 'express';
if (cluster.isMaster) {
// Here is master
// we start by creating few workers
for (let i = 0; i < 4; i++) {
cluster.fork();
}
// for each worker, if we receive a message, we print it
for (const id in cluster.workers) {
if (cluster.workers.hasOwnProperty(id)) {
cluster.workers[id].on('message', (msg) => {
console.log(`[${cluster.workers[id].process.pid}] ${msg}`);
});
}
}
// create express server
const app = express();
app.get('/', (req, res) => {
// request from client
console.log('\nHow are you all?');
// for each workers
for (const id in cluster.workers) {
if (cluster.workers.hasOwnProperty(id)) {
// ask state
cluster.workers[id].send('howareyou');
// how to wait for answer?
}
}
// probably concat all answers here
// send result to client
res.setHeader('Content-Type', 'application/json');
res.json({question: 'How can I have state of all my workers?'});
});
app.listen(8000);
} else {
// Here is worker.
process.on('message', (message) => {
// When master ask state, send back random answer
if (message === 'howareyou') {
process.send(`I'm ${Math.random() * 100 < 75 ? 'fine' : 'sick'}`);
}
});
}
前もって感謝します :)