一个完整的socket.io通信群聊和单聊的例子

var app = require('express')();
var path = require('path');
var http = require('http').Server(app);
var io = require('socket.io')(http);
var socketList = {};
//io.set('log level', 1);

app.get('/', function(req, res){
res.sendFile(__dirname + '/index.html');
});

io.sockets.on('connection', function (socket){
console.log('connection........');
socket.on('room', function (nn) {

try {
var roomId = nn.split('|')[0];
var isTeacher = nn.split('|')[1];
var studentId = nn.split('|')[2];
}catch(e){return false;}

socket.join(roomId);

if(socketList[roomId] == undefined) {
socketList[roomId] = {};
socketList[roomId] ['roomnum'] = roomId;
}

if(isTeacher == 'false') {

socketList[roomId] [studentId] = {};
socketList[roomId] [studentId]['socketid'] = socket.id;
socketList[roomId] [studentId]['isonline'] = 'true';
socketList[roomId] [studentId]['locked'] = 'true';
}

io.sockets.in(roomId).emit('request_list_ans',socketList[roomId] );

socket.on('send_message', function (msg){

io.sockets.in(roomId).emit('send_message', msg);
});

socket.on('request_list', function (msg){
var roomId = msg.split('|')[0];

io.to(socket.id).emit('request_list_ans',socketList[roomId] );
});

socket.on('operate_all', function (msg){
console.log(1);
var roomId = msg.split('|')[0];
var lockInfo = msg.split('|')[1];

for(var key in socketList[roomId]){
console.log('key:' + key);
if(key!='roomnum')
socketList[roomId][key]['locked']=''+lockInfo;
}
io.to(socket.id).emit('operate_all_ans','ok' );
io.sockets.in(roomId).emit('send_lockInfo', lockInfo);
});

socket.on('operate_spec', function (msg){

var roomId = msg.split('|')[0];
var studentId = msg.split('|')[1];
var lockInfo = msg.split('|')[2];

if (socketList[roomId] [studentId]) { //当前用户存在在发送锁定信息
console.log(lockInfo);
socketList[roomId] [studentId]['locked'] = lockInfo;
io.to(socket.id).emit('operate_spec_ans','ok' );
io.to(socketList[roomId] [studentId]['socketid'] ).emit('send_lockInfo',lockInfo );
}
});

socket.on('client_status', function (msg){
var roomId = msg.split('|')[0];
var studentId = msg.split('|')[1];
var onlineInfo = msg.split('|')[2];
socketList[roomId] [studentId]['isonline'] = ''+onlineInfo;

io.sockets.in(roomId).emit('request_list_ans',socketList[roomId] );
});

socket.on("disconnect",function(){
delete socketList[roomId] [studentId];
console.log(socketList[roomId]);
io.sockets.in(roomId).emit('request_list_ans','001' );
});

});

});

http.listen(8091, function(){
console.log('listening on *:8091');
});