我有一个 express.js 应用程序,它必须在每次有特定请求时运行一个子进程(这里是: /compute/real-time )。将有用户创建的脚本来计算数据。所以,我使用节点集群模块来创建一个工作池并选择一个可以自由执行脚本的工作。但是我在创建集群本身的过程中遇到了麻烦。这是代码 clusterPool.js
var cluster = require('cluster');
exports.setupCluster = function(){
console.log ("Setting up cluster for bot processing " )
if (cluster.isMaster){
cluster.fork(); //one is good enough at the moment
}
}
Run Code Online (Sandbox Code Playgroud)
计算.js
var async = require('async');
var clusterPool = require('.././clusterPool')
//Start the cluster
clusterPool.setupCluster();
exports.computeRealTime = function(req,res){
clusterPool.cluster.on("listening",function(worker){
//....Do something with the worker
})
}
Run Code Online (Sandbox Code Playgroud)
网络服务器.js
// Include Express
var express = require('express');
var compute = require('.././compute');
// Create a new Express application
var app = express(); …Run Code Online (Sandbox Code Playgroud)