html5 websocket + node.js 实现网页聊天室

var socket = io.connect(‘http://localhost:8080‘);    
socket.on(‘connect‘,function(){
    console.log(‘connected to server‘);    
    socket.on(‘login success‘,function(data){
        console.log(‘login success‘);
        username = data.username;
            
        refreshOnlineUsers(data.allusers);
    });
        
    socket.on(‘disconnect‘,function(){
        console.log(‘disconnect‘);
        username = null;    
    });
    
    socket.on(‘login failed‘,function(){
        username = null;    
    });
    
    socket.on(‘new message‘,function(data){
        console.log(‘receiver message from ‘+data.fromUser +‘ ‘+data.date+ ‘ ‘+data.msg);
    });
        
    socket.on(‘update myself‘,function(data){
    });
    
    socket.on(‘enter chat‘,function(data){
        console.log(data.username+‘ has entered the chat‘);
        refreshOnlineUsers(data.allusers);
    });
    
    socket.on(‘leave chat‘,function(data){
        console.log(data.username + ‘ has leaved the chat‘);
        refreshOnlineUsers(data.allusers);
    });
});

var express = require(‘express‘);
var app = express();
var server = require(‘http‘).Server(app);
var io = require(‘socket.io‘)(server);

app.use(‘/‘, express.static(__dirname + ‘/www‘));
 
var users = {
    fanglin:{
        socket:null,
        online:false
    },
    xingtianyu:{
        socket:null,
        online:false
    }
};

io.on(‘connection‘, function(socket){
    socket.on(‘new message‘,function(data){
        var i,user;
        
        socket.emit(‘update myself‘,{fromUser:data.fromUser,msg:data.msg,date:new Date()});
        
        if(data.broadcast===true){
            socket.broadcast.emit(‘new message‘,{fromUser:data.fromUser,msg:data.msg,date:new Date()});
        }else{
            for(i=0;i<data.tousers.length;i++){
                user = users[data.tousers[i]];
                if(user.online==true && user.socket!=null){
                    user.socket.emit(‘new message‘,{fromUser:data.fromUser,msg:data.msg,date:new Date()});
                }
            }
        }
    });
    
    socket.on(‘login‘,function(data){
        if(data.username in users){
            users[data.username].online = true;
            users[data.username].socket = socket;
            socket.emit(‘login success‘,{username:data.username,allusers:getOnlineUsers()});
            socket.broadcast.emit(‘enter chat‘,{username:data.username,allusers:getOnlineUsers()});
        }else{
            socket.emit(‘login failed‘);
        }
    });
    
    socket.on(‘disconnect‘,function(){
        var user;
        for (user in users){
            if(users[user].socket == socket){
                users[user].online = false;
                socket.broadcast.emit(‘leave chat‘,{username:user,allusers:getOnlineUsers()});
                return;
            }
        }
    });
});

server.listen(8080);
console.log(‘server is listenering on port 8080‘);