最新赞助活动温馨提示:自愿赞助服务器费用,学生和没有工作的整站资源免费下载!
头像

html5新技术socket.io实现聊天室的方法-H5教程

来源:http://erdangjiade.com/topic/131601.html H5程序员 2017-10-31 22:20浏览(102)

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>1</title>
    <link rel="stylesheet" href="https://cdn.bootcss.com/bootstrap/3.3.7/css/bootstrap.min.css">
    <style>
        .user{
            color:lightskyblue;
            cursor: pointer;
        }
    </style>
</head>
<body>
<p>
    <p>
        <p>
            <p class="panel panel-default">
                <p>
                    <h4>欢迎来老王聊天室</h4>
                </p>
                <p>
                    <ul id="messageUl">
                    </ul>
                </p>
                <p>
                    <p>
                        <p>
                            <input id="txtMsg" type="text" onkeydown="handleKeyDown(event)">
                        </p>
                        <p>
                            <button class="btn btn-default" onclick="send()">发送
                                <span class="glyphicon glyphicon-send"></span>
                            </button>
                        </p>
                    </p>
                </p>
            </p>
        </p>
        <p>
            <p class="panel panel-default">
                <p>
                    <h4>在线用户</h4>
                </p>
                <p>
                    <ul id="userUl"></ul>
                </p>
                <p>
                    <h4 id="onlineUsers">在线人数 0</h4>
                </p>
            </p>
        </p>
    </p>
</p>
<script src="/socket.io/socket.io.js"></script>
<script>
    let txtMsg = document.querySelector('#txtMsg');
    let onlineUsers = document.querySelector('#onlineUsers');
    //此脚本会在window上增加一个io的属性
    //http://localhost:8080/=/=空
    let socket = io();
    //当客户端连接服务器成功之后,向后台发送一个消息,问一下现在有哪些在线用户
    socket.on('connect',function(){
        socket.emit('users');
    });
    let messageUl = document.querySelector('#messageUl');
    let userUl = document.querySelector('#userUl');
    //监听服务器发过来的消息
    socket.on('message',function(msgObj){
        let li = document.createElement('li');
        li.className = 'list-group-item';
        li.innerHTML = `${msgObj.username}:${msgObj.content} <span>${new Date(msgObj.createAt).toLocaleString()}</span>`;
        messageUl.appendChild(li);
    });
    socket.on('userList',function(userList){
        userUl.innerHTML =  userList.map(item=>(
            `<li>${item}</li>`
        )).join('');
        countUser();
    });
    socket.on('user-added',function(username){
        let li = document.createElement('li');
        li.className = 'list-group-item';
        li.innerHTML = `<span>${username}</span>`;
        userUl.appendChild(li);
        countUser();
    });
    function countUser(){
        onlineUsers.innerHTML = `在线人数 ${userUl.children.length}`;
    }
    //发送事件
    function send(){
        let content = txtMsg.value;//先拿到聊天的内容
        socket.send(content);
        txtMsg.value = '';
    }
    function handleKeyDown(event){
        if(event.keyCode == 13)
            send();
    }
    //给父级绑定点击事件 事件委托
    //要判断点的是span而非别的元素
    userUl.addEventListener('click',function(event){
        //如果事件源的类名是user的话
        if(event.target.className == 'user'){
            let username = event.target.innerHTML;
            txtMsg.value = `@${username} `;
        }
    })
</script>
</body>
</html>
<!--npm i express socket.io -S -->

后台node

let express = require('express');
let path = require('path');
let app = express();
app.get('/',function(req,res){
    res.sendFile(path.resolve('index.html'));
});
let server = require('http').createServer(app);
//socket.io是依赖http服务器
let io = require('socket.io')(server);
//声明一个对象,保存所有的客户端用户名和它们的socket对应关系
let clients = {};
//监听客户端的连接,当连接到来的时候执行此回调函数
io.on('connection',function(socket){
    //在函数的内部声明一个变量,叫username
    let username;
    //监听客户端的发过来的消息,当消息发过来的时候执行回调函数
    socket.on('message',function(data){
        if(username){
            //判断是公聊还是私聊
            let reg = /@([^ ]+) (.+)/;
            let result = data.match(reg);
            if(result){//如果result有值则匹配上了
                //此处是私聊
                let toUser = result[1];
                let content = result[2];
                clients[toUser] && clients[toUser].send({
                    username,
                    content,
                    createAt:new Date()
                });
            }else{//没匹配上
                //正常发言,向所有的客户端进行广播
                io.emit('message',{
                    username,content:data,createAt:new Date()
                });
            }
        }else{
            username = data;//把这个消息当成用户名
            //关联起来
            clients[username]= socket;
            //向所有的客户端广播说有新的用户加入聊天室
            io.emit('message',{
                username:'系统',content:`欢迎 ${username} 加入聊天室`,createAt:new Date()
            });
            //事件的名字可以自定义
            io.emit('user-added',username);
        }
    });
    //监听客户端发过来的请求,把用户数组返回
    socket.on('users',function(){
        let userList = Object.keys(clients);
        socket.emit('userList',userList);
    });
});
server.listen(8080);
/**
 * 1.实现匿名聊天
 *   1. 在客户端里连接上服务器
 *   2. 给发送按钮绑定点击事件,当点击此按钮的时候先获取文本框的内容,把文本框的内容发送到后台
 *   3. 后台服务器把此消息广播给所有的客户端。
 *   4. 所有的客户端收到消息后把此消息在ul列表里显示出来
 * 2.实现具名聊天
 *   1. 当此用户第一次向服务器发消息的时候
 *   2. 服务器会判断此客户端的用户名是否设置过,如果没设置的话就把这个消息当成用户名,以后再发消息的话都会以这个作为用户名,如果设置过了就是正常发言
 * 3. 私聊
 *   1. 点击某个在线用户,点击后会在输入框里出现  @xxx yyy
 *   2. 服务收到私聊的请求后会找到xxx对应的客户端向他单个发消息
 *   3
 *
*/

以上就是html5新技术socket.io实现聊天室的方法的详细内容,更多请关注二当家的素材网其它相关文章!

评论0
头像

友情提示:垃圾评论一律封号 加我微信:826096331拉你进VIP群学习群

1 2