摘自<Node.js即学即用>第3章
使用NODE中cluster利用多核CPU
- var cluster = require('cluster');
- var http = require('http');
- var numCPUs = require('os').cpus().length;
- if (cluster.isMaster) {
- // 创建工作进程
- for (var i = 0; i < numCPUs; i++) {
- cluster.fork();
- }
- cluster.on('death', function(worker) {
- console.log('worker ' + worker.pid + ' died');
- cluster.fork();//重启子进程
- });
- } else {
- // 工作进程创建http 服务器
- http.Server(function(req, res) {
- res.writeHead(200);
- res.end("hello world\n");
- }).listen(8000);
- }
通过消息传递来监控工作进程状态
- var cluster = require('cluster');
- var http = require('http');
- var numCPUs = require('os').cpus().length;
- var rssWarn = (12 * 1024 * 1024)
- , heapWarn = (10 * 1024 * 1024)
- if(cluster.isMaster) {
- for(var i=0; i<numCPUs; i++) {
- var worker = cluster.fork();
- worker.on('message', function(m) {
- if (m.memory) {
- console.log(m.memory.rss,rssWarn)
- if(m.memory.rss > rssWarn) {
- console.log('Worker ' + m.process + ' using too much memory.')
- }
- }
- })
- }
- } else {
- // 服务器
- http.createServer(function(req,res) {
- res.writeHead(200);
- res.end('hello world\n')
- }).listen(8000)
- // 每秒报告一次状态
- setInterval(function report(){
- process.send({memory: process.memoryUsage(), process: process.pid});
- }, 1000)
- }
杀死僵尸进程
- var cluster = require('cluster');
- var http = require('http');
- var numCPUs = require('os').cpus().length;
- var rssWarn = (50 * 1024 * 1024)
- , heapWarn = (50 * 1024 * 1024)
- var workers = {}
- if(cluster.isMaster) {
- for(var i=0; i<numCPUs; i++) {
- createWorker()
- }
- setInterval(function() {
- var time = new Date().getTime()
- for(pid in workers) {
- if(workers.hasOwnProperty(pid) &&
- workers[pid].lastCb + 5000 < time) {
- console.log('Long running worker ' + pid + ' killed')
- workers[pid].worker.kill()
- delete workers[pid]
- createWorker()
- }
- }
- }, 1000)
- } else {
- // 服务器
- http.Server(function(req,res) {
- // 打乱200 个请求中的1 个
- if (Math.floor(Math.random() * 200) === 4) {
- console.log('Stopped ' + process.pid + ' from ever finishing')
- while(true) { continue }
- }
- res.writeHead(200);
- res.end('hello world from ' + process.pid + '\n')
- }).listen(8000)
- // 每秒钟报告一次状态
- setInterval(function report(){
- process.send({cmd: "reportMem", memory: process.memoryUsage(),
- process: process.pid})
- }, 1000)
- }
- function createWorker() {
- var worker = cluster.fork()
- console.log('Created worker: ' + worker.pid)
- // 允许开机时间
- workers[worker.pid] = {worker:worker, lastCb: new Date().getTime()-1000}
- worker.on('message', function(m) {
- if(m.cmd === "reportMem") {
- workers[m.process].lastCb = new Date().getTime()
- if(m.memory.rss > rssWarn) {
- console.log('Worker ' + m.process + ' using too much memory.')
- }
- }
- })
- }
相关推荐
docker-nginx-nodejs-集群测试 一个具有nginx + 4个节点进程(2个单进程和2个集群进程)的Docker容器。 因此,在4个TCP端口上,后端总数为6。 Docker容器 Nginx(80) backend1(8000):1个单进程 backend2(8001...
本篇文章主要介绍了Nodejs中解决cluster模块的多进程如何共享数据问题,有需要的可以了解一下。
nodejs集群 利用节点集群的示例应用程序
nodejs进程通信--pm2 cluster方式, pm2版本 2.4.2,node 版本 v7.5.0
nodejs-集群-uri 用于从集群中选择服务节点的库,由各种图形条目 URI 定义。
nodejs-redis-cluster redis3.0 的 nodejs 扩展,支持基于 nodejs npm redis url 的集群: : 更改日志 当我们向 redis 集群的一个节点发送命令时,我们可能会收到类似“ERR: MOVED 111 127.0.0.1:6379”的返回错误...
首先郑重声明: nodeJS 是一门单线程!异步!非阻塞语言! nodeJS 是一门单线程!...但,大哥就是大哥,nodeJS在v0.8 的时候就已经加入了cluster的模块。 完全打脸php. 虽然,现在php 也开始抄袭nodeJS, 退出php7, 但
Nodejs cluster 多核处理模块cluster Nodejs+socket.io 聊天系统 Nodejs+socket.io 服务器监控 ##Nodejs+express4.x+boostrap web开发 项目地址: 详细参考: ##Nodejs cluster 多核处理模块cluster 项目地址: 详细...
了解NodeJS集群模块 统计数据显示,Node.js作为服务器端运行时环境正变得越来越流行,尤其是对于高流量的网站而言。 而且,几个框架的可用性使其成为快速原型制作的良好环境。 Node.js具有事件驱动的体系结构,利用...
簇如何使用群集模块轻松扩展和负载平衡这是一个非常小的应用程序,它演示了如何... 为了扩展和集群,还有另一个名为clusterdApp.js的文件,该文件实际上是分叉应用程序实例并使用核心nodejs的集群模块创建多个实例的。
nodejs在v0.6.x之后 增加了一个模块 cluster 用于实现多进程,利用child_process模块来创建和管理进程,增加程序在多核CPU机器上的性能表现。本文将介绍利用cluster模块创建的多线程的问题。
cluster-nodejs-example 版权所有 (c) 2014,Pablo Araya Romero 保留所有权利。 如果满足以下条件,则允许以源代码和二进制形式重新分发和使用,无论是否修改: 源代码的重新分发必须保留上述版权声明、此条件...
主要介绍了NodeJS父进程与子进程资源共享原理与实现方法,结合实例形式分析了nodejs基于cluster模块实现父进程与子进程资源共享的相关操作技巧,需要的朋友可以参考下
这个错误是在Master进程向子进程send消息时发现pipe已经关闭了的情况下由Master... at Worker.send (internal/cluster/worker.js:54:28) 经排查这个问题原因是子进程占用内存太多,触发了Linux内核的OOM Killer机制
内存缓存 一个简单的针对node.js的内存缓存 安装 npm install memory-cache --save 用法 var cache = require ( 'memory-cache' ) ; // now just use the cache cache ....console ....// that wasn't too interesting, ...
如果直接通过node app来启动,如果报错了可能直接停在整个运行,supervisor感觉只是拿来... 内建负载均衡(使用Node cluster 集群模块) 后台运行 0秒停机重载,我理解大概意思是维护升级的时候不需要停机. 具有U
共享 类似于Redis的内存数据库,用于NodeJS集群应用程序。为什么? 将Redis添加为依赖项将不可避免地增加应用程序和环境的复杂性。 如果要保持简单的体系结构,请使用此库,同时在需要时可以迁移到真实的内存数据库...
其实wind模块这次系统中没有使用。可以将它排除出去。我是出于学习wind的目的,才加入这个模块的。 本来准备使用wind模块,是为了实现同步的目的,由于后来改用了fibers模块之后,就没有使用它。这里说明一下 不是...
主要介绍了node.js中cluster的使用教程,分别介绍使用NODE中cluster利用多核CPU、通过消息传递来监控工作进程状态以及杀死僵尸进程等功能,给出了详细的示例代码供大家参考学习,需要的朋友们下面来一起看看吧。