socket.io與cluster

在線上系統(tǒng)中，需要使用node的多進(jìn)程模型，我們可以自己實(shí)現(xiàn)簡(jiǎn)易的基于cluster模式的socket分發(fā)模型，也可以使用比較穩(wěn)定的pm2這樣進(jìn)程管理工具。在常規(guī)的http服務(wù)中，這套模式一切正常，可是一旦server中集成了socket.io服務(wù)就會(huì)導(dǎo)致ws通道建立失敗，即使通過(guò)backup的polling方式仍會(huì)出現(xiàn)時(shí)斷時(shí)連的現(xiàn)象，因此我們需要解決這種問(wèn)題，讓socket.io充分利用多核。

在這里之所以提到socket.io而未說(shuō)websocket服務(wù)，是因?yàn)閟ocket.io在封裝websocket基礎(chǔ)上又保證了可用性。在客戶(hù)端未提供websocket功能的基礎(chǔ)上使用xhr polling、jsonp或forever iframe的方式進(jìn)行兼容，同時(shí)在建立ws連接前往往通過(guò)幾次http輪訓(xùn)確保ws服務(wù)可用，因此socket.io并不等于websocket。再往底層深入研究，socket.io其實(shí)并沒(méi)有做真正的websocket兼容，而是提供了上層的接口以及namespace服務(wù)，真正的邏輯則是在“engine.io”模塊。該模塊實(shí)現(xiàn)握手的http代理、連接升級(jí)、心跳、傳輸方式等，因此研究engine.io模塊才能清楚的了解socket.io實(shí)現(xiàn)機(jī)制。

場(chǎng)景重現(xiàn)

服務(wù)端采用express+socket.io的組合方案，搭配pm2的cluster模式，實(shí)現(xiàn)一個(gè)簡(jiǎn)易的b/s通信demo：

app.js

var path = require('path');var app = require('express')(),
    server = require('http').createServer(app),
    io = require('socket.io')(server);

io
  .on('connection', function(socket) {
      socket.on('disconnect', function() {          console.log('/: disconnect-------->')