1

クラスター化されたノード アプリがあり、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'}`);
        }
    });
}

前もって感謝します :)

4

0 に答える 0