1. socket.io

1.1. 特性

Socket.IO 使基于事件的实时双向通信成为可能。它包括:

一个 Node.js 服务器 (这个仓库)
一个适用于浏览器的 Javascript 客户端库 (或者一个 Node.js 客户端)

其他语言的一些可用实现：

主要的特性有:

可靠性

即使在存在的情况下，联系也会建立起来：

代理和负载平衡器。
个人防火墙和防病毒软件。

出于这个目的，它依赖于 Engine.IO，它首先建立了一个长轮询连接，然后尝试升级到更好的传输（这是在一旁“被测试的”），比如 WebSocket。请参阅 Goals 部分获得更多信息。

支持自动重连

除非另有指示，否则断开连接的客户端将尝试重新连接，直到服务器再次可用。请在这里查看可用的重新连接选项。

断开检测

在 Engine.IO 级别实现了心跳机制，允许服务器和客户端知道对方何时不再响应。

该功能是通过在服务器和客户端设置的计时器实现的，在连接握手期间共享超时值(pingInterval 和 pingTimeout 参数)。这些计时器要求任何后续的客户端调用被定向到同一个服务器，因此在使用多个节点时需要 sticky-session 必要条件。

支持二进制

任何可序列化的数据结构都可以被发射，包括:

浏览器中的 ArrayBuffer 和 Blob
Node.js 中的 ArrayBuffer 和 Buffer

简单和方便的 API

示例代码:

io.on('connection', function(socket){
  socket.emit('request', /* */); // 发射一个事件到 socket
  io.emit('broadcast', /* */); // 发射一个事件到所有已连接的 sockets
  socket.on('reply', function(){ /* */ }); // 监听事件
});

跨浏览器

在 Saucelabs 中测试浏览器:

支持多路复用（Multiplexing）

为了在应用程序中创建关注点隔离(例如每个模块，或者基于权限)，Socket.IO 允许创建多个 Namespaces，这些名称空间将充当单独的通信通道，但将共享相同的底层连接。

支持房间（Room）

在每个 Namespace 中，您可以定义任意的通道，称为 Rooms，套接字可以加入和离开。然后你可以把它广播到任何一个给定的房间，到达加入这个房间的每一个套接字。

这是向一组用户发送通知的有用功能，或者是向在多个设备上连接的给定用户发送通知。

注意: Socket.IO 不是 WebSocket 的实现。尽管 Socket.IO 确实在可能的情况下使用 WebSocket 作为传输，它为每个数据包(packet)添加了一些元数据：当需要消息确认时，包类型、名称空间和确认(ack) id。这就是为什么 WebSocket 客户端无法成功连接到 Socket.IO 服务器，并且一个 Socket.IO 客户端无法连接到 WebSocket 服务器的原因。(如:ws://echo.websocket.org)。请参阅这里的协议规范。

1.2. 安装

npm install socket.io --save

1.3. 怎么用

下面示例将 socket.io 连接到一个普通的 Node.js HTTP 服务器（运行在 3000 端口）。

var server = require('http').createServer();
var io = require('socket.io')(server);
io.on('connection', function(client){
  client.on('event', function(data){});
  client.on('disconnect', function(){});
});
server.listen(3000);

1.3.1. 独立的

var io = require('socket.io')();
io.on('connection', function(client){});
io.listen(3000);

1.3.2. 与 Eexpress 集成

从 3.0 开始，express 应用程序已经成为您传递给 http 或 http 服务器实例的请求处理函数。您需要将 Server 传递给 socket.io，而不是 express 应用程序函数。也一定要在 server 调用 .listen ，而不是app。

var app = require('express')();
var server = require('http').createServer(app);
var io = require('socket.io')(server);
io.on('connection', function(){ /* … */ });
server.listen(3000);

1.3.3. 与 Koa 集成

如同 Express.JS，Koa 的工作是暴露一个应用程序作为请求处理函数，但仅靠调用 callback 方法。

var app = require('koa')();
var server = require('http').createServer(app.callback());
var io = require('socket.io')(server);
io.on('connection', function(){ /* … */ });
server.listen(3000);