本文主要是介绍使用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搭建的私信系统的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
