node.js - 同じアプリ内の Express ノード モジュールとクラスター ノード モジュール

Question

ユーザーがブラウザのファイルをサーバーにアップロードできるアプリを作成しています。

expressプロジェクトのフォルダーに入力することから始めました。その速達ですべてのフォルダなどを作成しました。ポートのような多くのものを開始する www ファイルを含む bin フォルダーを作成しました。

最初はコアが1つしかなかったので、次のようにしていました：

var express = require('express');

var multer = require('multer');

var app = express();

var done = false;
var fileSize = 0;

app.use(multer({ dest: './uploads/',
    rename: function (fieldname, filename){
        return filename;
    },
    onFileUploadStart: function(file){
        console.log(file.originalname + ' is starting...');
    },
    onFileUploadComplete: function(file){
        console.log(file.fieldname + ' uploaded to ' + file.path);
        done = true;
    },
    onFileUploadData: function(file, data){
        fileSize += data.length;
        console.log("FileUpload " + fileSize);
    }
}));

app.get('/', function(request, response){
    response.sendFile(__dirname + '/index.html');
});

app.post('/upload/', function(request, response){
    console.log(request.body);
    if (done == true)
        response.end('file uploaded');
});
module.exports = app;

最終的に、より多くのクライアント要求に応答できるようにするために、複数のコアを備えたマシンを使用する必要がありました。だから私はクラスターモジュールを使用しようとしています。

それに応じてコードを変更しました：

var cluster = require('cluster');

if(cluster.isMaster){
    var numCPUS = require('os').cpus().length;
    for(var i=0; i<numCPUS; i++)
        cluster.fork();

    cluster.on('exit', function(worker, code, signal) {
        console.log('worker ' + worker.process.pid + ' died');
    });

    cluster.on('online', function(worker) {
        console.log('worker ' + worker.process.pid + ' started');
    });

}else{
    var express = require('express');
    var multer = require('multer');

    var app = express();

    var done = false;
    var fileSize = 0;

    app.use(multer({ dest: './uploads/',
        rename: function (fieldname, filename){
            return filename;
        },
        onFileUploadStart: function(file){
            console.log(file.originalname + ' is starting...');
        },
        onFileUploadComplete: function(file){
            console.log(file.fieldname + ' uploaded to ' + file.path);
            done = true;
        },
        onFileUploadData: function(file, data){
            fileSize += data.length;
            console.log("FileUpload " + fileSize);
        }
    }));

    app.get('/', function(request, response){
        response.sendFile(__dirname + '/index.html');
    });

    app.post('/upload/', function(request, response){
        console.log(request.body);
        if (done == true)
            response.end('file uploaded');
    });
    module.exports = app;
}

問題は、これを行うと、コンソールに次のエラーが表示されることです。

実行: node ./bin/www 結果:

app.set('port', port);

TypeERror: Cannot call method 'set' of undefined at Object.<anonymous> 

これは、マスターのフォークされた子の中にコード全体を配置したために発生します。なぜこれが起こるのか、どうすれば修正できるのか誰でも知っていますか?

編集: ここでは、ポートとその他の構成が設定されている bin/www ファイルを確認できます。

#!/usr/bin/env node

/**
 * Module dependencies.
 */

var app = require('../app');
var debug = require('debug')('dropbox:server');
var http = require('http');

/**
 * Get port from environment and store in Express.
 */

var port = normalizePort(process.env.PORT || '3000');
app.set('port', port);

/**
 * Create HTTP server.
 */

var server = http.createServer(app);

/**
 * Listen on provided port, on all network interfaces.
 */

server.listen(port);
server.on('error', onError);
server.on('listening', onListening);

/**
 * Normalize a port into a number, string, or false.
 */

function normalizePort(val) {
  var port = parseInt(val, 10);

  if (isNaN(port)) {
    // named pipe
    return val;
  }

  if (port >= 0) {
    // port number
    return port;
  }

  return false;
}

/**
 * Event listener for HTTP server "error" event.
 */

function onError(error) {
  if (error.syscall !== 'listen') {
    throw error;
  }

  var bind = typeof port === 'string'
    ? 'Pipe ' + port
    : 'Port ' + port

  // handle specific listen errors with friendly messages
  switch (error.code) {
    case 'EACCES':
      console.error(bind + ' requires elevated privileges');
      process.exit(1);
      break;
    case 'EADDRINUSE':
      console.error(bind + ' is already in use');
      process.exit(1);
      break;
    default:
      throw error;
  }
}

/**
 * Event listener for HTTP server "listening" event.
 */

function onListening() {
  var addr = server.address();
  var bind = typeof addr === 'string'
    ? 'pipe ' + addr
    : 'port ' + addr.port;
  debug('Listening on ' + bind);
}