nodejs 聊天室 源码下载

【核心代码】

var express = require('express');
var path = require('path');
var favicon = require('serve-favicon');
var logger = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');

var routes = require('./routes/index');
var users = require('./routes/users');
var http = require('http').Server(express);
var io = require('socket.io')(http);

var app = express();

// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'ejs');
app.engine('ejs', require('ejs-mate'));

// uncomment after placing your favicon in /public
//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));

app.use('/', routes);
app.use('/users', users);
global.userList={};

io.on('connection',function (socket) {
    console.log('监听用户');
    socket.on('login',function (obj) {
        socket.name = obj.id;
        if (!global.userList.hasOwnProperty(obj.id)) {
            global.userList[obj.id] = {username: obj.username,id:obj.id};
        }
        io.emit('loginUser', {username: global.userList});
        console.log(userList);
        console.log(obj.username   '加入了聊天室！');
    });

    //发布审核
    socket.on('checkmessage', function (obj) {
        console.log("fuck");
        if (obj.level == "66") {
            io.emit('message', obj);
        }
        else {
            io.emit('check_message', obj);
        }
    });

//监听用户发布聊天内容
    socket.on('message', function (obj) {
        io.emit('message', obj);
        console.log(obj.username   '说：'   obj.content);
    });

    //监听用户退出
    socket.on('disconnect', function () {

        //将退出的用户从在线列表中删除
        if (userList.hasOwnProperty(socket.name)) {
            //退出用户的信息
            var obj = {userid: socket.name, username: userList[socket.name].username};

            //删除
            delete userList[socket.name];

            //向所有客户端广播用户退出
            io.emit('logout', {userList: userList, user: obj});
            console.log(obj.id   '退出了聊天室');
        }
    });
    socket.on('updatename',function (obj) {
        if (global.userList.hasOwnProperty(obj.id)) {
            var id=obj.id;
            console.log();
            delete userList[obj.id];
            global.userList[obj.username] = {username: obj.username,id:id};
            io.emit('loginUser', {username: global.userList});
            console.log(obj.id "发布删除监听--------------------》");
        }


        console.log(userList);
    });

});


// catch 404 and forward to error handler
app.use(function(req, res, next) {
  var err = new Error('Not Found');
  err.status = 404;
  next(err);
});

// error handlers

// development error handler
// will print stacktrace
if (app.get('env') === 'development') {
  app.use(function(err, req, res, next) {
    res.status(err.status || 500);
    res.render('error', {
      message: err.message,
      error: err
    });
  });
}

// production error handler
// no stacktraces leaked to user
app.use(function(err, req, res, next) {
  res.status(err.status || 500);
  res.render('error', {
    message: err.message,
    error: {}
  });
});

http.listen(8687,function () {
    console.log("runnning server in 8687");
});

module.exports = app;