Node js从不同的进程获取和设置数据

Question

我有节点应用程序，它完成了生成（子进程）到应用程序， 应用程序有主机和端口：

var exec = require('child_process').spawn;
var child = exec('start app');
console.log("Child Proc ID " + child.pid)
child.stdout.on('data', function(data) {
    console.log('stdout: ' + data);
});
child.stderr.on('data', function(data) {
    console.log('stdout: ' + data);
});
child.on('close', function(code) {
    console.log('closing code: ' + code);
});

一些应用程序将立即启动，而一些应用程序将需要一些时间 10 - 20 秒才能启动。

现在我使用节点 http 代理来运行应用程序，问题是当用户想要在应用程序启动和运行之前运行应用程序时出现错误。 知道如何解决这个问题吗？

proxy.on('error', function (err, req, res) {
    res.end('Cannot run app');
});

顺便说一句，由于我们框架的限制，我无法在代理错误中发送响应 500。任何其他想法我如何跟踪应用程序可能有一些超时以查看它发送响应 200 的天气。

更新 - 我的逻辑示例

httpProxy = require('http-proxy');
var proxy = httpProxy.createProxyServer({});
http.createServer(function (req, res) {
    console.log("App proxy new port is: " + 5000)
    res.end("Request received on " + 5000);
}).listen(5000);

function proxyRequest(req, res) {
    var hostname = req.headers.host.split(":")[0];
    proxy.web(req, res, {
        target: 'http://' + hostname + ':' + 5000
    });  

    proxy.on('error', function (err, req, res) {
        res.end('Cannot run app');
    });
}

Answer 1

为什么不使用事件发射器或信使？

var eventEmitter = require('event-emitter')
var childStart = require('./someChildProcess').start()

if (childStart !== true) {
        eventEmitter.emit('progNotRun', {
            data: data
        })
} 

function proxyRequest(req, res) {

    var hostname = req.headers.host.split(":")[0];
    proxy.web(req, res, {
        target: 'http://' + hostname + ':' + 5000
    });  

    eventEmitter.on('progNotRun', function(data) {
        res.end('Cannot run app', data);
    })
}

Answer 2

如果您知道（大约）应用启动和运行所需的时间，只需添加 setTimeout(proxyRequest, <Time it takes the app to start in MS>)

（很可能有更智能/更复杂的解决方案，但这个是最简单的。）

Answer 3

我不确定我是否正确理解了这个问题，但是您想等待子进程根据请求旋转并且您希望此请求等待该子进程然后发送给它？ 如果这是一个简单的解决方案，那就是使用这样的东西

    var count = 0;//Counter to check
    var maxDelay = 45;//In Seconds
    var checkEverySeconds = 1;//In seconds
    async.whilst(
        function () {
            return count < maxDelay;
        },
        function (callback) {
            count++;
            self.getAppStatus(apiKey, function (err, status) {
                if (status != 200) {
                    return setTimeout(callback, checkEverySeconds * 1000);

                } 
                continueWithRequest();

            });
        },
        function (err) {
            if (err) {
                return continueWithRequest(new Error('process cannot spin!'));
            }
        }
    );

函数 continueWithRequest() 会将请求转发给子进程，当子进程启动时 getAppStatus 将返回 200，否则返回一些其他代码。一般的想法是，如果进程正在运行，while 将每秒检查一次，如果没有，则在 45 秒后返回错误。等待时间和检查间隔可以轻松调整。这有点粗略，但适用于延迟请求，setTimeout 将启动一个新堆栈并且不会阻塞。希望这会有所帮助。

Answer 4

不确定是否有意义，在您的主应用程序中，体验应该从一个 html 页面开始，每个子进程应该有自己的加载器。

所以基本上，您需要一个 http 处理程序，它会在子进程准备好之前等待请求。因此，只需从 html 进行 ajax 调用，并显示加载动画，直到服务准备好。

//Ajax call for each process  and update the UI accordingly   
$.get('/services/status/100').then(function(resp) {
   $('#service-100').html(resp.responseText);
})

//server side code (express syntax)
app.get('/services/status/:id ', function(req,res) {
     // Check if service is ready 
     serviceManager.isReady(req.params.id, function(err, serviceStats) {
         if(err) {
            //do logic err here , maybe notify the ui if an error occurred
            res.send(err);
            return;
         }
         // notify the ui , that the service is ready to run , and hide loader
         res.send(serviceStats);
     });
})

Answer 5

您需要在代理上侦听第一个响应并查看其状态代码以确定您的应用是否成功启动。这样做的方法如下：

proxy.on('proxyRes', function (proxyRes, req, res) {
  // Your target app is definitely up and running now because it just sent a response;
  // Use the status code now to determine whether the app started successfully or not
  var status = res.statusCode;
});

希望这会有所帮助。