这篇文章给大家介绍怎么在node.js中使用socket.io实现一个实时通讯应用，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。
创新互联服务项目包括海盐网站建设、海盐网站制作、海盐网页制作以及海盐网络营销策划等。多年来，我们专注于互联网行业，利用自身积累的技术优势、行业经验、深度合作伙伴关系等，向广大中小型企业、政府机构等提供互联网行业的解决方案，海盐网站推广取得了明显的社会效益与经济效益。目前，我们服务的客户以成都为中心已经辐射到海盐省份的部分城市，未来相信会继续扩大服务区域并继续获得客户的支持与信任！
WebSocket概念
不同于HTTP半双工协议，WebSocket是基于TCP 连接的全双工协议，支持客户端服务端双向通信。
WebSocket使得客户端和服务器之间的数据交换变得更加简单，允许服务端主动向客户端推送数据。在 WebSocket API 中，浏览器和服务器只需要完成一次握手，两者之间就直接可以创建持久性的连接，并进行双向数据传输。
在WebSocket API中，浏览器和服务器只需要做一个握手的动作，然后，浏览器和服务器之间就形成了一条快速通道。两者之间就直接可以数据互相传送。
实现
原生实现
WebSocket对象一共支持四个消息 onopen, onmessage, onclose和onerror。
建立连接
通过javascript可以快速的建立一个WebSocket连接：
var Socket = new WebSocket(url, [protocol] );
以上代码中的第一个参数url, 指定连接的URL。第二个参数 protocol是可选的，指定了可接受的子协议。
同http协议使用http://开头一样，WebSocket协议的URL使用ws://开头，另外安全的WebSocket协议使用wss://开头。
当Browser和WebSocketServer连接成功后，会触发onopen消息。
Socket.onopen = function(evt) {};如果连接失败，发送、接收数据失败或者处理数据出现错误，browser会触发onerror消息。
Socket.onerror = function(evt) { };当Browser接收到WebSocketServer端发送的关闭连接请求时，就会触发onclose消息。
Socket.onclose = function(evt) { };收发消息
当Browser接收到WebSocketServer发送过来的数据时，就会触发onmessage消息，参数evt中包含server传输过来的数据。
Socket.onmessage = function(evt) { };send用于向服务端发送消息。
Socket.send();
socket
WebSocket是跟随HTML5一同提出的，所以在兼容性上存在问题，这时一个非常好用的库就登场了——Socket.io。
socket.io封装了websocket，同时包含了其它的连接方式，你在任何浏览器里都可以使用socket.io来建立异步的连接。socket.io包含了服务端和客户端的库，如果在浏览器中使用了socket.io的js，服务端也必须同样适用。
socket.io是基于 Websocket 的Client-Server 实时通信库。
socket.io底层是基于engine.io这个库。engine.io为 socket.io 提供跨浏览器/跨设备的双向通信的底层库。engine.io使用了 Websocket 和 XHR 方式封装了一套 socket 协议。在低版本的浏览器中，不支持Websocket，为了兼容使用长轮询(polling)替代。
API文档
Socket.io允许你触发或响应自定义的事件，除了connect，message，disconnect这些事件的名字不能使用之外，你可以触发任何自定义的事件名称。
建立连接
const socket = io("ws://0.0.0.0:port"); // port为自己定义的端口号
let io = require("socket.io")(http);
io.on("connection", function(socket) {})消息收发
一、发送数据
socket.emit(自定义发送的字段, data);
二、接收数据
socket.on(自定义发送的字段, function(data) {
console.log(data);
})断开连接
一、全部断开连接
let io = require("socket.io")(http);
io.close();二、某个客户端断开与服务端的链接
// 客户端
socket.emit("close", {}); // 服务端
socket.on("close", data => {
socket.disconnect(true);
});room和namespace
有时候websocket有如下的使用场景：1.服务端发送的消息有分类，不同的客户端需要接收的分类不同；2.服务端并不需要对所有的客户端都发送消息，只需要针对某个特定群体发送消息；
针对这种使用场景，socket中非常实用的namespace和room就上场了。
先来一张图看看namespace与room之间的关系：
namespace
服务端
io.of("/post").on("connection", function(socket) {
socket.emit("new message", { mess: `这是post的命名空间` });
});
io.of("/get").on("connection", function(socket) {
socket.emit("new message", { mess: `这是get的命名空间` });
});客户端
// index.js
const socket = io("ws://0.0.0.0:****/post");
socket.on("new message", function(data) {
console.log('index',data);
}
//message.js
const socket = io("ws://0.0.0.0:****/get");
socket.on("new message", function(data) {
console.log('message',data);
}room
客户端
//可用于客户端进入房间;
socket.join('room one');
//用于离开房间;
socket.leave('room one');服务端
io.sockets.on('connection',function(socket){
//提交者会被排除在外（即不会收到消息）
socket.broadcast.to('room one').emit('new messages', data);
// 向所有用户发送消息
io.sockets.to(data).emit("recive message", "hello,房间中的用户");
}用socket.io实现一个实时接收信息的例子
终于来到应用的阶段啦，服务端用node.js模拟了服务端接口。以下的例子都在本地服务器中实现。
服务端
先来看看服务端，先来开启一个服务，安装express和socket.io
安装依赖
npm install --Dev express npm install --Dev socket.io
构建node服务器
let app = require("express")();
let http = require("http").createServer(handler);
let io = require("socket.io")(http);
let fs = require("fs");
http.listen(port); //port:输入需要的端口号
function handler(req, res) {
fs.readFile(__dirname + "/index.html", function(err, data) {
if (err) {
res.writeHead(500);
return res.end("Error loading index.html");
}
res.writeHead(200);
res.end(data);
});
}
io.on("connection", function(socket) {
console.log('连接成功');
//连接成功之后发送消息
socket.emit("new message", { mess: `初始消息` });
});客户端
核心代码——index.html（向服务端发送数据）
