javascript - 带有 node.js express 应用程序的网络 worker

Question

我是 node.js 的新手，正在尝试构建一个快速应用程序。到目前为止，我已经设置了一个应用程序并创建了一些基本路线。

我的应用程序入口点是一个文件，我在其中设置应用程序的服务器:

#!/usr/bin/env node

/**
 * Module dependencies.
 */

var app = require('../app');
var debug = require('debug')('main');
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);
}

Express 应用使用 Mongoose 在适当的 http 请求上与数据库通信。

此时，我还需要一个网络 worker ，当服务器启动时，每 5 秒生成一次随机数，如果生成的数字是 10，则将其识别为事件，并将一些结果存储在数据库中。

到目前为止，我不确定如何开始并将其包含在结构中。

我已经设置了用于写入数据库等的接口(interface)。我只是迷失了 web-worker 实现和集成部分。

Answer 1

在 node.js 中没有网络 worker 。但是我们有类似的东西叫做 child_process(更多细节请查看文档:link)

如何使用child_process？ stackoverflow里面有很多资料: https://stackoverflow.com/a/13371439/4138339有解释如何在主模块中运行其他模块(查看详细信息):在你的主模块中:

var cp = require('child_process');
var child = cp.fork('./othermodulefile');

child.on('message', function(m) {
  // Receive results from child process
  console.log('received: ' + m);
});

// Send child process some work
child.send('Please up-case this string');

或者请查看此链接以获得令人上瘾的描述 http://www.tutorialspoint.com/nodejs/nodejs_scaling_application.htm以及该页面的示例:文件:support.js

console.log("Child Process " + process.argv[2] + " executed." );

文件:master.js

const fs = require('fs');
const child_process = require('child_process');

for(var i=0; i<3; i++) {
   var workerProcess = child_process.exec('node support.js '+i,
      function (error, stdout, stderr) {
         if (error) {
            console.log(error.stack);
            console.log('Error code: '+error.code);
            console.log('Signal received: '+error.signal);
         }
         console.log('stdout: ' + stdout);
         console.log('stderr: ' + stderr);
      });

      workerProcess.on('exit', function (code) {
      console.log('Child process exited with exit code '+code);
   });
}

使用 child_process 的一些缺点:https://stackoverflow.com/a/17340465/4138339

Each thread cost memory, and this is generally why most of traditional systems is not much scalable as will require thread per client. For node it will be extremely inefficient from hardware resources point of view.

其他部分:

Count of workers is recommended to be equal of CPU Cores on hardware.

其他可能性，如果您需要运行一些基于时间的作业调度程序，请查看此模块 https://github.com/ncb000gt/node-cron .这是 node.js 的 cron 作业。安装 npm install cron 和使用示例:

var CronJob = require('cron').CronJob;
new CronJob('* * * * * *', function() {
  console.log('You will see this message every second');
}, null, true, 'America/Los_Angeles');