一纺腊、Node如何開啟多進程
cluster是一個nodejs內(nèi)置的模塊屯吊,用于nodejs多核處理。cluster模塊摹菠,可以幫助我們簡化多進程并行化程序的開發(fā)難度盒卸,輕松構(gòu)建一個用于負載均衡的集群。
我的系統(tǒng)環(huán)境:
- OS X Yosemite 10.10.5
- node V4.4.3
- npm V2.15.1
1. cluster 示例
新建文件夾
$ mkdir test_cluster && cd test_cluster
創(chuàng)建app.js
$ vim app.js
var cluster =require('cluster');
var http =require('http');
var processes = 4;
if(cluster.isMaster) {
console.log("master start...");
//Fork workers.
for(var i =0; i < processes; i++) {
cluster.fork();
}
cluster.on('listening',function(worker,address){
console.log('listening: worker '+ worker.process.pid);
});
cluster.on('exit', function(worker, code, signal) {
console.log('worker '+ worker.process.pid +' died');
});
}else{
http.createServer(function(req, res) {
res.writeHead(200);
res.end("server start!");
}).listen(3000);
}
$ node app.js
控制臺打哟伟薄:
master start...
listening: worker 92753
listening: worker 92754
listening: worker 92755
listening: worker 92756
2.cluster API
cluster對象的各種屬性和函數(shù)
cluster.setttings:配置集群參數(shù)對象
cluster.isMaster:判斷是不是master節(jié)點
cluster.isWorker:判斷是不是worker節(jié)點
Event: 'fork': 監(jiān)聽創(chuàng)建worker進程事件
Event: 'online': 監(jiān)聽worker創(chuàng)建成功事件
Event: 'listening': 監(jiān)聽worker向master狀態(tài)事件
Event: 'disconnect': 監(jiān)聽worker斷線事件
Event: 'exit': 監(jiān)聽worker退出事件
Event: 'setup': 監(jiān)聽setupMaster事件
cluster.setupMaster([settings]): 設(shè)置集群參數(shù)
cluster.fork([env]): 創(chuàng)建worker進程
cluster.disconnect([callback]): 關(guān)閉worket進程
cluster.worker: 獲得當(dāng)前的worker對象
cluster.workers: 獲得集群中所有存活的worker對象
worker對象的各種屬性和函數(shù):可以通過cluster.workers, cluster.worket獲得蔽介。
worker.id: 進程ID號
worker.process: ChildProcess對象
worker.suicide: 在disconnect()后,判斷worker是否自殺
worker.send(message, [sendHandle]): master給worker發(fā)送消息煮寡。注:worker給發(fā)master發(fā)送消息要用process.send(message)
worker.kill([signal='SIGTERM']): 殺死指定的worker虹蓄,別名destory()
worker.disconnect(): 斷開worker連接,讓worker自殺
Event: 'message': 監(jiān)聽master和worker的message事件
Event: 'online': 監(jiān)聽指定的worker創(chuàng)建成功事件
Event: 'listening': 監(jiān)聽master向worker狀態(tài)事件
Event: 'disconnect': 監(jiān)聽worker斷線事件
Event: 'exit': 監(jiān)聽worker退出事件
二幸撕、多進程間如何共享session
關(guān)于session共享有這么幾種做法:
進程通信薇组、redis存儲、本地mongodb存儲坐儿、數(shù)據(jù)庫存儲律胀。
本篇使用的是redis來存儲session,node提供了connect-redis模塊用來連接redis數(shù)據(jù)庫貌矿。
var express = require('express');
var session = require('express-session');
var RedisStore=require('connect-redis')(session);
var app = express();
// 本地redis配置參數(shù)
var options = {
host:'127.0.0.1',
port:'6379',
db:0
};
app.use(session({
secret: 'secret-string',
saveUninitialized:true,
resave:false,
store:newRedisStore(options)
}));
app.get("/", function(req, res) {
var session = req.session;session.count = session.count ||0;
var n = session.count++;
res.send('hello, session id:'+ session.id +' count:'+ n);
});
app.listen(3000);
通過應(yīng)用redis就可以保證各進程使用的session是一致的了炭菌。即使進程崩潰也能保證用戶的登錄狀態(tài)不會丟失。