【从头到脚】撸一个社交聊天系统(vue + node + mongodb)

发布时间:2022-06-08 发布网站:脚本宝典
脚本宝典收集整理的这篇文章主要介绍了【从头到脚】撸一个社交聊天系统(vue + node + mongodb)脚本宝典觉得挺不错的,现在分享给大家,也给大家做个参考。

项目开始是因为工作需要一个聊天室功能,但是因为某些原因最终选用的是基于XMpp协议的Strophe.jS写的。于是就想用node自己写一套,本来只是想简单的写个聊天页面,但是写完了又不满意,所以不断的重构(似乎可以理解产品经理为什么老是改需求了๑乛◡乛๑)。

很多东西,比如mongodb,我也是第一次用,以前只接触过MySQL。所以都是一边学一边写,利用工作之余的时间,断断续续的写了几个月,包含了一整套的前后端交互。uI是按照自己的感觉来的,没有设计天分(话说主题切换到现在还只有一套主题,实在是不好设计啊~),轻喷---。项目还有很多需要优化完善的地方,欢迎大家提到issues(文末有q群,欢迎一起学习交流)。

闲话少说,本文主要讲项目的设计流程,以及部分功能实现思路。对项目感兴趣的同学请移步码 Vchat — 从头到脚,撸一个在线聊天的web应用(vue + node + mongodb)。

这是分隔线---------------------------------------深夜码字,最近真冷

项目架构

 

【从头到脚】撸一个社交聊天系统(vue + node + mongodb)

 

 

前端主要采用了vue全家桶,没什么多说的,脚手架构建项目,vuex状态管理,vue-router控制路由,axios进行前后端交互。后端是基于node搭的服务,用的是exPress。我为什么不用koa呢,纯粹是图方便,因为koa不熟(捂脸)。聊天最重要的当然是通信,项目用socket.io来进行前后端通信。

数据库是mongoDB,主要有用户、好友、群聊、消息、表情、号码池等。

功能概览

【从头到脚】撸一个社交聊天系统(vue + node + mongodb)

 

 

功能设计

登录注册

【从头到脚】撸一个社交聊天系统(vue + node + mongodb)

 

 

Vchat中用户注册时,会随机指定一个code号码,而这个code号是从预先生成的一个号码池(号码池存在mongodb)中取的。初始指定10000001-10001999的号码段为用户code, 100001-100999的号码段为群聊code。用户可以凭借code号或者账号登录
    // 号码池设计
    * code 号码
    * status 1 已使用 0 未使用
    * tyPE  1 用户 2 群聊
    * random   随机数索引,用于随机查找某一条
    // user表主要字段
    * name 账号
    * pass 密码
    * avatar 头像
    * signature 个性签名
    * nickname 昵称
    * email 邮件
    * phone 手机
    * sex 性别
    * bubble 气泡
    * PRojectTheme 项目主题
    * wallpaper 聊天壁纸
    * signUpTime 注册时间
    * lastLoginTime 最后一次登录时间
    * chatColor 聊天文字颜色
    * province 省
    * cITy 市
    * town 县
    * conversationsList 会话列表
    * cover 封面列表

注册时,需要判断账号是否已存在,以及随机取得的code需要在号码池中标记为已被使用,用户密码用Md5加密等。

    // md5 密码加密
    const md5 = pass => { // 避免多次调用MD5报错
        let md5 = crypto.createHash('md5');
        return md5.update(pass).digest("hex");
    };

登录同样需要判断用户是否已注册,以及支持账号和code两种方式登录。

    const LOGin = (params, callback) => { // 登录
        baseList.users
            .find({ // mongodb中可以直接用$or表示或关系
                $or: [{"name": params.name}, {"code": params.name}]
            })
            .then(r => {
                if (r.length) {
                    let pass = md5(params.pass);
                    if (r[0]['pass'] === pass) {
                        //更新最后一次登录时间 此处直接写Date.now 会报错 需要Date.now()!!!;
                        baseList.users.update({name: params.name}, {lastLoginTime: Date.now()}).then(raw => {
                            console.log(raw);
                        });
                        callback({code: 0, data: {name: r[0].name, photo: r[0].photo}});
                    } else {
                        callback({code: -1});
                    }
                } else {
                    callback({code: -1});
                }
        })
    };

登录权限管理

  • 后端设置全局中间件,将没有登录的api请求统一返回status: 0
  •     app.use('/v*', (req, res, next) => {
            if (req.session.login) {
                next();
            } else {
                if (req.originalUrl === '/v/user/login' || req.originalUrl === '/v/user/signUp') {
                    next();
                } else {
                    res.json({
                        status: 0
                    });
                }
            }
        });
  • 前端用axios统一设置拦截器
  • // http response 服务器响应拦截器,这里拦截未登录和401错误,并重新跳入登页重新获取token
    instance.interceptors.response.use(
        response => { // 拦截未登录
            if (response.data.status === 0) {
                router.replace('/');
            }
            return response;
        },
        error => {
            if (error.response) {
                switch (error.response.status) {
                    case 401:
                        // 这里写清除token的代码
                        router.replace('/');
                }
            }
            return Promise.reject(error.response.data)
        });

    消息

    vchat中,消息种类包括好友或者加群申请、回复申请(同意or拒绝)、入群通知、聊天消息(文字、图片、表情、文件)

     

    【从头到脚】撸一个社交聊天系统(vue + node + mongodb)

     

     

    【从头到脚】撸一个社交聊天系统(vue + node + mongodb)

     

    在实现消息发送之前,需要大体的了解一些socket.io的api。详细api文档可以查看socket.io

  • // 所有的消息请求都是建立在已连接的基础上的
        io.on('connect', onConnect);
        // 发送给当前客户端
        socket.emit('hello', 'can you hear me?', 1, 2, 'abc');
        // 发送给所有客户端,除了发送者
        socket.broadcast.emit('broadcast', 'hello friends!');
        // 发送给同在 'game' 房间的所有客户端,除了发送者
        socket.to('game').emit('nice game', "let's play a game");
        // 发送给同在 'game' 房间的所有客户端,包括发送者
        io.in('game').emit('Big-announcement', 'the game will start soon');
  • 加入房间
  • 加入会话列表中的房间,会话列表在好友申请成功或者加群成功时会自动添加。但是你也可以手动移除或添加,移除后将不会再收到被移除会话的消息(类似于屏蔽)。

    // 前端 发起加入房间的请求
    this.conversationsList.foreach(v => {
        let val = {
            name: this.user.name,
            time: utils.formatTime(new Date()),
            avatar: this.user.photo,
            roomid: v.id
        };
        this.$socket.emit('join', val);
    });
    // 后端 接受请求后执行加入操作,记录每个房间加入的成员,以及回信告知指定房间已上线成员
    socket.on('join', (val) => {
        socket.join(val.roomid, () => {
            if (OnlineUser[val.name]) {
                return;
            }
            OnlineUser[val.name] = socket.id;
            io.in(val.roomid).emit('joined', OnlineUser); // 包括发送者
        });
    });
多房间 同时加入多个聊天房间会出现一个问题,socket可以加入多个房间并给指定房间发送消息,但是接受消息的时候并不会区分房间。换句话说,所有房间的消息,会一起发送给客户端。所以我们需要自己区分哪条消息是哪个房间的并进行分发。这样就需要一个房间标识来过滤,Vchat用的是房间id。
    mes(r) { // 只有本房间的消息才展示
        if (r.roomid === this.currSation.id) {
            this.chatList.push(Object.assign({}, r, {type: 'other'}));
        }
    }
  • 发消息
  • // 前端
        send(params, type = 'mess') { // 发送消息
            if (!this.message && !params) {
                return;
            }
            let val = {
                name: this.user.name,
                mes: this.message,
                time: utils.formatTime(new Date()),
                avatar: this.user.photo,
                nickname: this.user.nickname,
                read: [this.user.name],
                roomid: this.currSation.id,
                style: 'mess',
                userM: this.user.id
            };
            this.chatList.push(Object.assign({},val,{type: 'mine'})); // 更新视图
            this.$socket.emit('mes', val);
            this.message = '';
        }
        // 后端 接收消息后存储到数据库,并转发给房间内其他成员,不包括发送者。
        socket.on('mes', (val) => { // 聊天消息
            apiList.saveMessage(val);
            socket.to(val.roomid).emit('mes', val);
        });
  • 消息记录 所有的消息都会存到mongodb中,当切换房间的时候,会获取历史消息。而处在当前房间时,只会把最新消息追加到dom中,不会从数据库获取。聊天窗口默认只展示最新100条消息,更多消息可在聊天记录中查看。
  •     // 前端 获取指定房间的历史消息
        this.$socket.emit('getHistoryMessages', {roomid: v.id, offset: 1, limit: 100});
        // 后端 关联表、分页、排序
        messages.find({roomid: params.roomid})
            .populate({path: 'userM', select: 'signature photo nickname'}) // 关联用户基本信息
            .sort({'time': -1})
            .skip((params.offset - 1) * params.limit)
            .limit(params.limit)
            .then(r => {
                r.forEach(v => { // 止用户修改资料后,信息未更新
                    if (v.userM) {
                        v.nickname = v.userM.nickname;
                        v.photo = v.userM.photo;
                        v.signature = v.userM.signature;
                    }
                });
                r.reverse();
                callback({code: 0, data: r, count: count});
            }).catch(err => {
            console.log(err);
            callback({code: -1});
        });

    项目展示

    主页

     

    【从头到脚】撸一个社交聊天系统(vue + node + mongodb)

     

    聊天窗口,可拖拽或缩放,聊天壁纸及文字颜色设置。

     

    【从头到脚】撸一个社交聊天系统(vue + node + mongodb)

     

    个人设置

     

    【从头到脚】撸一个社交聊天系统(vue + node + mongodb)

     

    应用空间

     

    【从头到脚】撸一个社交聊天系统(vue + node + mongodb)

     

    相关阅读

    • Mongoose基础入门
    • socket.io文档
    • Vchat主题切换实现方案来自于 d2-admin
      • 作者:江三疯链接:https://juejin.cn/post/6844903734145712135来源:稀土掘金著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

脚本宝典总结

以上是脚本宝典为你收集整理的【从头到脚】撸一个社交聊天系统(vue + node + mongodb)全部内容,希望文章能够帮你解决【从头到脚】撸一个社交聊天系统(vue + node + mongodb)所遇到的问题。

如果觉得脚本宝典网站内容还不错,欢迎将脚本宝典推荐好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。