-
Notifications
You must be signed in to change notification settings - Fork 193
/
app.js
106 lines (81 loc) · 2.88 KB
/
app.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
"use strict";
const express = require('express');
const app = express();
const router = require('./router');
const bodyParser = require('body-parser');
const path = require('path');
const session = require('express-session');
const config = require('./config');
const server = require('http').createServer(app);
const io = require('socket.io').listen(server); // 引入socket.io模块, 并且绑定到服务器
const log4js = require('./utils/log');
const process = require('child_process');
const logger = log4js.getLogger();
let usernum = 0; // 定义一个全局变量
// 日志相关
log4js.useLogger(app, logger)
// 配置静态资源文件中间服务
app.use('/www', express.static('www'));
// 挂载session中间件
app.use(session({
secret: config.secretKey, // 每一次在生成Cookie的时候,通过一个私钥生成一个字符串然后再交给客户端(读取我的配置文件里面的私钥key)
resave: false,
saveUninitialized: true,
// cookie : {secure : true }
}));
// 配置解析POST请求体的中间件
app.use(bodyParser.urlencoded({extended: false}));
// 配置模板引擎中间件
app.set('views', path.join(__dirname, 'views'));
app.engine('.html', require('xtpl').__express);
app.set('view engine', 'html');
// 挂载配置文件中的数据信息(密匙)
app.locals.config = config;
// 加载路由中间件(最后进入到路由)
app.use(router);
// 错误信息处理机制
if (config.isDebug) {
app.use(function (err, req, res, next) {
// res.send('500, Interal Server Error'+ err);
console.log(err)
})
} else {
app.use(function (err, req, res, next) {
// res.send('500, Interal Server Error'+ err);
logger.info(err);
})
}
// 开启监听端口 server
server.listen(config.port, config.host, function () {
console.log(`Server is listening at port ${config.port}, http://${config.host}:${config.port}`);
process.exec('start http://127.0.0.1');
})
// websocket server
io.on('connection', function (socket) {
//let usernum = app.locals.config.userlist;
//接收并处理客户端发送的foo事件
socket.on('foo', function (data) {
//将消息输出到控制台
if (data === 'login') {
usernum++;
io.sockets.emit('system', 'num', usernum);
}
})
// 发布所有用户数量信息
socket.on('publish', function (data) {
if (!data || data === '') {
return;
}
// console.log('开始广播消息', data);
io.sockets.emit('message', data);
});
//断开连接的事件
socket.on('disconnect', function () {
if (usernum >= 2) {
usernum--;
//通知除自己以外的所有人
// socket.broadcast.emit('system', '提示消息', '消息内容');
io.sockets.emit('system', 'num', usernum);
}
});
});