初学者提个问题,Node Cluster 如何共享数据?
创建一个简单的 http 服务,目的是统计请求数,该例子中 fork 4 个进程,如下:
var http = require('http')
var cluster = require('cluster')
var pv = 0
if (cluster.isMaster) {
for (var i = 0; i < 4; i++) {
var worker = cluster.fork()
}
} else {
http.createServer((req, res) => {
pv++
console.log(`pid: ${process.pid}, pv: ${pv}`)
res.end('okay')
}).listen(4010)
}
结果:
pid: 70445, pv: 1
pid: 70445, pv: 2
pid: 70445, pv: 3
pid: 70445, pv: 4
pid: 70445, pv: 5
pid: 70445, pv: 6
pid: 70445, pv: 7
pid: 70445, pv: 8
pid: 70444, pv: 1
pid: 70444, pv: 2
pid: 70444, pv: 3
pid: 70444, pv: 4
pid: 70444, pv: 5
因为 fork 出来的每个进程都有自己单独的内存空间,所以这样统计 pv 显然是不行的。
所以有什么好的解决方案吗?
我看了一下 ioredis,尝试后发现它的 api 也是异步化的,并没能解决我的问题。
阿神2017-04-17 16:00:03
cluster fork的是進程,而不是線程,進程之間是互相獨立的,各自有各自的內存空間,一個進程一般是不被允許訪問另一個進程的內存空間的,所以如果要實現類似共享變量一類別的功能,只能依賴進程通訊。
而在cluster模組的官方文件其實是可以看到有進程通訊的相關API的,你可以看下Cluster
當然你也可以將資料存到資料庫(如redis)來實現共享,不過我覺得更麻煩。 。 。