Node.js的Socket编程 ——Socket.io

本文介绍: HTTP 协议是一种无状态的、无连接的、单向的应用层协议。它采用了请求/响应模型。通信请求只能由客户端发起，服务端对请求做出应答处理，HTTP 协议无法实现服务器主动向客户端发起消息。这种单向请求的特点，注定了如果服务器有连续的状态变化，客户端要获知就非常麻烦。大多数 We b 应用程序将通过频繁的异步Ja vaScri p t 和 XML（AJAX）请求实现长轮询。轮询的效率低，非常浪费资源。We b socket应运而生，We bSoc k e t 连接允许客户端和服务器之间进行全双工通信。………

1. websocket 介绍

2. 客户端（浏览器）实现

3. 服务器端实现

4. socket.io 模块

const ws = new WebSocket(url)

事件	事件处理程序	描述
open	WebSo c ket 对象.on open	连接建立时触发
message	WebSo c ket 对象.onmessage	客户端接收服务端数据时触发
error	WebSoc ket 对象.onerror	通信发生错误时触发
close	WebSoc ket 对象.onclose	连接关闭时触发

方法	描述
WebSocket 对象.send()	向服务器发送数据

<script/&gt;
var sock = new WebSocket("ws://127.0.0.1:8080");
sock.on("open", function () {
    console.log("connect success !!!!")
})

sock.on("error", function (err) {
    console.log("error: ", err)
})

sock.on("close", function () {
    console.log("close")
});

sock.on("message", function (data) {
    console.log(data)
})

sock.send(JSON.stringify(values))
</script&gt;

npm install websocket

事件	描述
close	服务器关闭时被触发
connection	成功握手连接时触发
error	发生错误时被触发，可注入一个Er ro r对象
headers	握手前被触发，允许在发送HTTP头之前检查和修改标题
listen in g	绑定端口时被触发

//1、安装ws模块 npm install ws
//2、导入ws模块
const WebSocket=require('ws');
//3、创建WebSocket服务器
const server=new WebSocket.Server({port:8080});
//4、监听open事件
server.on('open',()=&gt;{
    console.log('建立连接');
})
//5、绑定close事件
server.on('close',()=&gt;{
    console.log('关闭连接')
})
//6、绑定connection事件 ws参数表示客户端 req表示客户端的请求信息
server.on('connection',(ws,req)=&gt;{
    //6.1获取客户端的ip port
    const ip=req.connection.remoteAddress;
    const port=req.connection.remotePort;
    const clientName=ip+port;
    console.log('%s is connect',clientName);
    //6.2向客户端发送消息
    ws.send('欢迎'+clientName);
    //监听 客户端 message 事件，转发给其他人
    ws.on('message',(msg)=&gt;{
        console.log('消息：%s 来自于 %s',msg,clientName);
        //6.3把消息广播所有客户端：clients表示所有客户端
        server.clients.forEach(function (client) {
            //若某个客户端是打开的，就把消息广播给该客户
            if (client.readyState===WebSocket.OPEN){
                client.send(clientName+'---------'+msg);
            }
        })
    })
})