alis-chat/app.js

const express = require('express'),
    app = express(),
    server = require('http').createServer(app),
    io = require('socket.io').listen(server),
    users = [];
let kit={
    isHaveUser(user){
        var flag=false;
        users.forEach(function (item) {
            if(item.name==user.name){
                flag=true;
            }
        })
        return flag;
    },
    delUser(id){
        users.forEach(function (item,index) {
            if(item.id==id){
                users.splice(index, 1);
            }
        })
    }
}
app.use('/', express.static(__dirname + '/static'));
io.sockets.on('connection', function(socket) {
    //创建用户链接
    socket.on('login', function(user) {
        if (kit.isHaveUser(user)) {
            console.log("登录失败！",user)
            socket.emit('loginFail',"登录失败,昵称已存在!");
        } else {
            socket.user = user;
            user.id=socket.id;
            console.log("登录成功！",user)
            socket.emit('loginSuccess',user,users);
            users.push(user)
            socket.broadcast.emit('system', user,'join');
        };
    });
    //用户注销链接
    socket.on('disconnect', function() {
        if (socket.user!= null) {
            kit.delUser(socket.id);
            console.log("用户退出！",socket.user)
            socket.broadcast.emit('system', socket.user, 'logout');
        }
    });
    //群发消息
    socket.on('groupMessage', function(msg,from){
        if(!socket.user){
            from.id=socket.id;
            socket.user=from;
            users.push(from);
            socket.broadcast.emit('system', from,'join');
            socket.emit('loginSuccess',from,[]);
        }
        socket.broadcast.emit('groupMessage', socket.user, msg);
    });
    //发送私信
    socket.on('message', function(id,msg,from) {
        if(!socket.user){
            from.id=socket.id;
            socket.user=from;
            users.push(from);
            socket.broadcast.emit('system', from,'join');
            socket.emit('loginSuccess',from,[]);
        }
        socket.broadcast.to(id).emit('message',socket.user,msg);
    });
});
server.listen(3000,function () {
    console.log("服务器已启动在：3000端口","http://localhost:3000`")
});