使用NODEJS搭建的私信系统

2024-05-11 21:18
文章标签 系统 使用 搭建 nodejs 私信

本文主要是介绍使用NODEJS搭建的私信系统，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

由于工作关系，日志并不能实时保存，因此记录在博客上，需要的时候自取：

NODEJS  server部分

使用PM2运行


//引入http模块
var socketio = require('socket.io'),http     = require('http'),domain   = require('domain');var d = domain.create();
d.on("error", function(err) {console.log(err);
}); 
//var numscount=0;// 在线人数统计
var sockets = {};
var chat_history={};
var chat_interval={};var server = http.createServer(function(req, res) {res.writeHead(200, {'Content-type': 'text/html;charset=utf-8'});//res.write("人数: " + numscount );res.end();
}).listen(19965, function() {//console.log('服务开启19965');
});var io = socketio.listen(server,{pingTimeout: 60000,pingInterval: 25000
});setInterval(function(){//global.gc();//console.log('GC done')
}, 1000*30); io.on('connection', function(socket) {console.log('连接成功');var interval;//进入房间socket.on('conn', function(data) {if(typeof data != 'object'){		try{				data  = evalJson(data);}catch(err){					console.log('-----------------broadcast JSON解析错误---'+data+'\r\n' );return !1;					}	}	if(!data || !data.uid){console.log('验证失败',data);			return !1;}userid=data.uid;old_socket = sockets[userid];if (old_socket && old_socket != socket) {//console.log("删除老的socket"+old_socket.id , old_socket);old_socket.disconnect()}	console.log('握手成功',data);	socket.roomnum  = data.uid;			socket.nickname = data.nickname;socket.avatar   = data.avatar;					socket.uid      = data.uid;socket.join(data.uid);sockets[userid] = socket;	socket.emit('conn',['ok']);		return;});//私聊// data = {uid:10021,msg:'你好'}socket.on('sendmsg',function(data){if(typeof data != 'object'){		try{				data  = evalJson(data);}catch(err){					console.log('--sendmsg JSON解析错误--',data);return !1;					}	}	var timestamp = Date.now();	var rand =  parseInt(Math.random()*1000);		var id = socket.uid + '' + data.uid +  ''  + timestamp + '' + rand;var str = {		_method_  : "SendMsg",action    : "3",msgid     : id,nickname  : socket.nickname,avatar    : socket.avatar,uid       : socket.uid,ct        : data.msg,		extra     : data.extra || ''}	process_msg(io,data.uid,JSON.stringify(str));	//此处可以调用AJAX接口请求后台保存记录//....略});//私聊删除消息通知// data = {uid:10021,msgid:'id'}socket.on('delmsg',function(data){if(typeof data != 'object'){		try{				data  = evalJson(data);}catch(err){					console.log('--sendmsg JSON解析错误--',data);return !1;					}	}		var str = {		_method_  : "DelMsg",action    : "4",msgid     : data.msgid,			}	process_msg(io,data.uid,JSON.stringify(str));		    });/* 系统信息 */socket.on('systemadmin',function(data){console.log("--后台系统信息--",data);if(data['token'] == "1234567"){console.log("后台系统信息",data.content);if(data.uid){var str = {				_method_  : "SystemNot",action    : "1",msgtype   : data.msgtype || 0,ct        : data.content,	msgid     : data.msgid || 0,event     : data.event || ''					}process_msg(io,data.uid,JSON.stringify(str));				}else{var str = {				_method_ : "SystemNot",action   : "1",msgtype  : data.msgtype || 0,ct       : data.content,msgid    : data.msgid || 0,	event    : data.event || ''					};				io.emit('broadcastingListen',[JSON.stringify(str)]);}		}});//资源释放socket.on('disconnect', function() {d.run(function() {socket.leave(socket.roomnum);delete io.sockets.sockets[socket.id];sockets[socket.uid] = null;delete sockets[socket.uid];});});});
function sendSystemMsg(socket,msg){	var str = {		_method_  : "SystemNot",action    : "1",ct        : msg		}socket.emit('broadcastingListen',[JSON.stringify(str)]);						
}function evalJson(data){return eval("("+data+")");
}function process_msg(io,roomnum,data){console.log("------process_msg:------\r\n");console.log(data);if(!chat_history[roomnum]){chat_history[roomnum]=[];}chat_history[roomnum].push(data);chat_interval[roomnum] || (chat_interval[roomnum]=setInterval(function(){if(chat_history[roomnum].length>0){send_msg(io,roomnum);}else{clearInterval(chat_interval[roomnum]);chat_interval[roomnum]=null;}},200));
}function send_msg(io,roomnum){var data=chat_history[roomnum].splice(0,chat_history[roomnum].length);io.sockets.in(roomnum).emit("broadcastingListen", data);
}

以下是客户端使用文档：

第一节，连接SOCKET

使用SOCKET.IO组件连接

例：socket = new IO(“http://localhost:19965”);

 

第二节，消息监听

使用socket.on 监听事件，使用回调函数接受消息，

例如，我们监听连接是否成功

socket.on('connect', function() {

        console.log("连接成功");

        //开始握手

        //参考本文第三节第一部分

    });

监听连接是否断开

    socket.on('disconnect', function() {

        console.log("断开连接");   

        //SOCKET会自动重连

    });

监听重连

    socket.on('reconnect', function() {

        console.log("重连成功");

        //SOCKET会自动重连

    });

监听服务器广播消息

    socket.on('broadcastingListen', function (data) {

        //socket会将成千条消息一并返回，所以需要遍历处理

        for(i=0;i<data.length;i++){

            //执行消息分拣程序

            //参考本文第三节第二部分   

        }

        //console.log( 'broadcastingListen : ------' )

        //console.log( data)

    });

 

监听握手是否成功

    socket.on('conn', function (data) {        

        console.log('握手成功')

        //console.log(data)

    });

第三节，消息处理

 

3.1 握手/注册私信

用户只要登录APP，即开始注册私信，注册事件是conn，注册参数即是登录的会员ID，昵称和头像

例：

socket.emit(‘conn’,{

uid      :  10001,

            nickname : ‘张三’,

            avatar  : ‘https://localhost/images/face.png',

})

 

关于传递的对象内容 解释如下

参数名

类型

说明

uid

Int

会员ID

nickname

String

会员昵称

avatar

String

头像

 

3.2 消息分拣

 

当监听到消息后,我们会得到MESSAGE内容，如下

socket.on('broadcastingListen', function (data) {

        //socket会将成千条消息一并返回，所以需要遍历处理

        for(i=0;i<data.length;i++){

            Message = data[i];  //得到MESSAGE

        }  

    });

    解析JSON后，获取MSG数组的第一个对象，取_method_ 进行分拣监听，支持不同的逻辑，下面将监听端消息具体内容按照 _method_ 类型列出来

 

 _method_  ： SendMsg  聊天/私信监听

键名

键值

描述

_method_

SendMsg 

必填

action

3

必填

msgid

100211032113321111111113355

消息ID

ct

聊天内容

必填

uid

10001

必填，发送者会员ID

nickname

张三

必填，发送者昵称

avatar

string

必填，发送者头像

extra

自定义内容

选填，额外透传内容

      

        接收到聊天信息时 应根据uid进行分拣，放到各自的聊天队列中存储

 _method_  ： DelMsg  聊天/私信删除通知监听

键名

键值

描述

_method_

DelMsg 

必填

action

4

必填

msgid

100211032113321111111113355

消息ID

   

_method_  ：SystemNot 站内信/通知信息监听     

键名

键值

描述

_method_

SystemNot

必填

action

1

必填

ct

消息内容

必填

event

 

自定义事件

第四节，消息发送

 

私信发送

发送私信的socket事件 是sendmsg

socket.emit('sendmsg',jsonString)

 

其中jsonString 就是包装好的 消息数据

内容如下

{uid:10021,msg:'你好',extra:''}

参数说明

键名

键值

描述

uid

10001

接收者会员ID

msg

hello

消息内容

extra

自定义

额外透传内容

 

删除私信通知

删除私信的socket事件 是delmsg

socket.emit('delmsg',jsonString)

 

其中jsonString 就是包装好的 消息数据

内容如下

{uid:10021,msgid:'id'}

参数说明

键名

键值

描述

uid

10001

接收者会员ID

msgid

Id

消息ID

删除私信必须先请求API接口删除,再给对方发一个通知

第五节：UI界面以及后台业务逻辑：

接收到私信

将其根据来源用户ID分别存放，如果用户自己与来源ID的聊天界面未在前台显示，只要累计未读数字即可，无需保存消息内容

如果聊天界面是前台显示的，需要将私信内容显示在聊天界面内，不累计未读数字

接受到站内信

无论何时，接收到站内信，直接弹出提示层，在APP头部弹出，点击会有相应事件

私聊界面拉取聊天记录

打开私聊界面后，首先从后台API接口获取两人的聊天记录，聊天记录后台会保存7天，每次只返回50条，需要分页获取，实时通讯的聊天记录后台会自动保存，APP无需处理保存逻辑

站内信界面拉取消息记录

也是从相应接口获取，实时站内信直接展示

这篇关于使用NODEJS搭建的私信系统的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

原文地址:
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.chinasem.cn/article/980678。

相关文章

python使用try函数详解

python使用try函数详解

《python使用try函数详解》Pythontry语句用于异常处理,支持捕获特定/多种异常、else/final子句确保资源释放,结合with语句自动清理,可自定义异常及嵌套结构,灵活应对错误场景... 目录try 函数的基本语法捕获特定异常捕获多个异常使用 else 子句使用 finally 子句捕获所
阅读更多...
Python极速搭建局域网文件共享服务器完整指南

Python极速搭建局域网文件共享服务器完整指南

《Python极速搭建局域网文件共享服务器完整指南》在办公室或家庭局域网中快速共享文件时,许多人会选择第三方工具或云存储服务,但这些方案往往存在隐私泄露风险或需要复杂配置,下面我们就来看看如何使用Py... 目录一、android基础版：HTTP文件共享的魔法命令1. 一行代码启动HTTP服务器2. 关键参
阅读更多...
C++11右值引用与Lambda表达式的使用

C++11右值引用与Lambda表达式的使用

《C++11右值引用与Lambda表达式的使用》C++11引入右值引用,实现移动语义提升性能,支持资源转移与完美转发；同时引入Lambda表达式,简化匿名函数定义,通过捕获列表和参数列表灵活处理变量... 目录C++11新特性右值引用和移动语义左值 / 右值常见的左值和右值移动语义移动构造函数移动复制运算符
阅读更多...
Python对接支付宝支付之使用AliPay实现的详细操作指南

Python对接支付宝支付之使用AliPay实现的详细操作指南

《Python对接支付宝支付之使用AliPay实现的详细操作指南》支付宝没有提供PythonSDK,但是强大的github就有提供python-alipay-sdk,封装里很多复杂操作,使用这个我们就... 目录一、引言二、准备工作2.1 支付宝开放平台入驻与应用创建2.2 密钥生成与配置2.3 安装ali
阅读更多...
C#中lock关键字的使用小结

C#中lock关键字的使用小结

《C#中lock关键字的使用小结》在C#中,lock关键字用于确保当一个线程位于给定实例的代码块中时,其他线程无法访问同一实例的该代码块,下面就来介绍一下lock关键字的使用... 目录使用方式工作原理注意事项示例代码为什么不能lock值类型在C#中，lock关键字用于确保当一个线程位于给定实例的代码块中时
阅读更多...
MySQL 强制使用特定索引的操作

MySQL 强制使用特定索引的操作

《MySQL强制使用特定索引的操作》MySQL可通过FORCEINDEX、USEINDEX等语法强制查询使用特定索引,但优化器可能不采纳,需结合EXPLAIN分析执行计划,避免性能下降,注意版本差异... 目录1. 使用FORCE INDEX语法2. 使用USE INDEX语法3. 使用IGNORE IND
阅读更多...
C# $字符串插值的使用

C# $字符串插值的使用

《C#$字符串插值的使用》本文介绍了C#中的字符串插值功能,详细介绍了使用$符号的实现方式,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习吧... 目录$ 字符使用方式创建内插字符串包含不同的数据类型控制内插表达式的格式控制内插表达式的对齐方式内插表达式中使用转义序列内插表达式中使用
阅读更多...
flask库中sessions.py的使用小结

flask库中sessions.py的使用小结

《flask库中sessions.py的使用小结》在Flask中Session是一种用于在不同请求之间存储用户数据的机制,Session默认是基于客户端Cookie的,但数据会经过加密签名,防止篡改,... 目录1. Flask Session 的基本使用(1) 启用 Session(2) 存储和读取 Se
阅读更多...
Linux系统中查询JDK安装目录的几种常用方法

Linux系统中查询JDK安装目录的几种常用方法

《Linux系统中查询JDK安装目录的几种常用方法》：本文主要介绍Linux系统中查询JDK安装目录的几种常用方法,方法分别是通过update-alternatives、Java命令、环境变量及目... 目录方法 1：通过update-alternatives查询（推荐）方法 2：检查所有已安装的 JDK方
阅读更多...
Java Thread中join方法使用举例详解

Java Thread中join方法使用举例详解

《JavaThread中join方法使用举例详解》JavaThread中join()方法主要是让调用改方法的thread完成run方法里面的东西后,在执行join()方法后面的代码,这篇文章主要介绍... 目录前言1.join()方法的定义和作用2.join()方法的三个重载版本3.join()方法的工作原
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2