express+socket简易聊天室

简易聊天室

前置知识

在我们平常的时候,ajax发送的都是短连接,get完成或者post完成之后连接就断开,并且当服务器数据更新的时候,必须再次发送ajax请求才可以获取到最新的数据
在没有socket之前,要实时获取服务器的数据,必须要轮询,也就是每隔一段时间发送ajax
所以现在有了服务端主动向前端推送消息的东东——长连接socket
实现的二种方式
1. socket.io
2. websocket(H5新增)

这里使用socket.io实现

socket.io的具体使用并没有想象的难记,而是on和emit这二个关键字贯穿始终
on就用来订阅服务器发送的消息(服务端当中的理解就是监听用户发送服务端的信息)
emit就用来用户向服务器发送信息(服务端当中的理解就是向用户发送信息)
socket.io大概过程

前端设置

引入<script src="./socket.io.js"></script>
使用io.connect(url)连接socket服务器
使用on监听和emit发送

前端代码

index.html

<!DOCTYPE html>
<html lang="en">

<head>
    <meta charset="UTF-8">
    <meta http-equiv="X-UA-Compatible" content="IE=edge">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>Document</title>
    <script src="./jquery-3.6.0.js"></script>
    <script src="./socket.io.js"></script>
    <style>
        * {
            margin: 0;
            padding: 0;
        }

        .wrap {
            width: 400px;
            height: 450px;
            margin: 50px auto;
            box-shadow: 0 0 4px rgba(0, 0, 0, 0.4);
        }

        .wrap>.content {
            width: 100%;
            height: 300px;
            box-sizing: border-box;
            padding: 20px 10px 8px 10px;
            background-color: #e2e1e2;
            overflow-x: auto;
            overflow-x: hidden;
        }

        .wrap>.content .left {
            font-size: 15px;
            padding: 5px 4px;
            border-radius: 4px;
            clear: both;
            margin: 5px 0;
            background-color: #c5cdd6;
            max-width: 300px;
            float: left;
        }

        .wrap>.content .right {
            font-size: 15px;
            padding: 5px 4px;
            border-radius: 4px;
            clear: both;
            margin: 5px 0;
            background-color: #8dcced;
            max-width: 300px;
            float: right;
        }

        .wrap>.input {
            width: 100%;
            height: 100px;
        }

        .wrap>.input #ipt {
            width: 100%;
            height: 100%;
        }

        .wrap>.ope {
            height: 50px;
        }

        .wrap>.ope #send {
            padding: 10px;
            float: right;
        }
    </style>
</head>

<body>
    <div class="wrap">
        <div class="content">
            <!-- <p class="left">你好,我叫</p> -->
            <!-- <p class="right">hello</p> -->
        </div>
        <div class="input">
            <textarea id="ipt"></textarea>
        </div>
        <div class="ope">
            <button id="send">发送</button>
        </div>
    </div>

    <script>
        var $inputs = $("#ipt"); //文本输入框
        var $send = $("#send"); //发送按钮
        var $content = $(".content").eq(0);
        // socket连接
        var socket = io.connect("http://localhost:8888");
        //监听自定义的serverInfo事件,data参数为服务器传送的数据
        //监听服务器的信息
        socket.on("serverInfo", (data) => {
            //收到从服务器发送的信息
            $('<p class="left">' + data + '</p>').appendTo($content);
        })
        //用户在输入框按下回车
        $inputs.keyup(function (e) {
            if ($inputs.val().trim() && e.keyCode == 13) {
                $send.click();
            }
        })
        //发送按钮被单击
        $send.click(function () {
            var value = $inputs.val();
            if (value) {
                // 不为空,添加
                //自己发送的消息,添加到右边
                $('<p class="right">' + value + '</p>').appendTo($content);
                //先服务端发送消息,key为userMessage
                socket.emit("userMessage", value);
                //清空输入框
                $inputs.val("");
            } else {
                alert("输入框为空!");
            }
        })
    </script>
</body>

</html>

后端代码

server.js

const express = require("express");
const app = express();
//这里是为了解决跨域
app.use("/", express.static(__dirname));
const server = require("http").Server(app);
const websocket = require("socket.io")(server);
//上面的可以说的固定的~

var clientCache = []; //用户暂存列表,为了后面可以向所有用户发送数据
//连接监听
websocket.on("connection", (client) => {
    clientCache.push(client); //添加用户到缓存列表
    //监听用户请求 key为userMessage
    client.on("userMessage", (data) => {
        //收到用户发送的信息,批量发送给其他人
        clientCache.forEach((ele) => {
            if (ele != client) {
                //避免自己收到
                ele.emit("serverInfo", data);
            }
        })
    })

})

//服务启动
server.listen("8888", () => {
    console.log("---------server start--------------");
});