nodejs实如今线群聊
2021-06-22 00:04
阅读:633
YPE html>
这不是一个项目而是一个适合刚開始学习的人学习的样例。主要实现了下面基本功能:
1:群聊。每个人都能够收到其它人的消息,以及能够发消息给其它人,每个人用ip地址标识。
2:显示当前在线用户。
3:每个用户登入登出。其它人都能够看到。
4:每个用户能够看到其它人是否正在输入消息。
实现方式没有选择低效的轮询方式,而是採用基于websocket协议的socket.io模块,websocket协议同意在client与服务端之间建立一个全双工的通信通道。因此服务端能够主动推消息给client。相比传统的轮询,实时性更好。
前端代码例如以下:
Socket.IO chat
服务端代码:
/**
* Created by luzhen on 14-11-10.
*/
var express = require('express');
var app=express();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var ips={};
app.use(express.static(__dirname + '/public'));
app.get('/', function (req, res) {
res.sendFile(__dirname + '/index.html');
});
var onlineNum=0;
io.on('connection', function (socket) {
console.log(socket.request.connection.remoteAddress);
ips[socket.request.connection.remoteAddress]=socket.request.connection.remoteAddress;//clientip
//socket.handshake.address 服务端ip
onlineNum++;
socket.broadcast.emit('join', {'ip':socket.request.connection.remoteAddress});//广播新用户增加
io.emit('online num',onlineNum);//广播当前在线人数
socket.on('chat message', function (msg) {
io.emit('chat message', {ip:socket.request.connection.remoteAddress,'content':msg});
console.log('message: ' + msg);
});
socket.on('typing', function (msg) {
socket.broadcast.emit('typing', {'ip':socket.request.connection.remoteAddress});
});
socket.on('stop typing', function (msg) {
socket.broadcast.emit('stop typing', {'ip':socket.request.connection.remoteAddress});
});
socket.on('disconnect',function(){
delete ips[socket.request.connection.remoteAddress];
onlineNum--;
socket.broadcast.emit('user left', {'ip':socket.request.connection.remoteAddress,'onlineNum':onlineNum});
});
});
http.listen(3000, function () {
console.log('listening on *:3000');
});
新增了防止刷屏功能,完整代码开源在GitHub上。
Demo演示 查看效果
评论
亲,登录后才可以留言!