websocket记录页面的停留时间(ip/进入页面时间/离开时间/访客时长等)

【实例截图】

前端界面只需引用如下脚本即可：

数据库统计到的结果如下：

【核心代码】

const Sequelize = require('sequelize')
var express = require('express'),
    app = express(),
    server = require('http').createServer(app),
    io = require('socket.io')(server),
    port = process.env.PORT || 8000,
    sequelize = new Sequelize('mysql://root:root@localhost:3306/visitordb');
const User = sequelize.define('visitlog', {
    socketId: {type: Sequelize.STRING, allowNull: false, primaryKey: true},
    ip: {type: Sequelize.STRING, allowNull: false},
    area: {type: Sequelize.STRING, allowNull: false},
    enterTime: {type: Sequelize.DATE, allowNull: false},
    leaveTime: {type: Sequelize.DATE, allowNull: true},
    cookieId: {type: Sequelize.STRING, allowNull: false},
}); // 时间戳默认为 false
app.use(express.static(__dirname   '/client'));//通过 express 加载前端部分的静态资源文件
io.on('connection', (socket) => {
    let user = '游客'   socket.id, area = '';
    let ip = (socket.handshake.headers['x-forwarded-for'] != null) ? socket.handshake.headers['x-forwarded-for'] : socket.handshake.address;
    User.create({socketId: socket.id, ip: ip, area: area, enterTime: new Date().toUTCString(), leaveTime: null, cookieId: socket.handshake.query.cookieId});
    //sequelize.sync().then(() => {onsole.log('init db ok')}).catch(err => {console.log('init db error', err)});
    console.log(user   '进来了');
    //通知用户离开
    socket.on('disconnect', () => {
        sequelize.query('update visitlogs set leaveTime=NOW() WHERE socketId = :socketId ', {replacements: {socketId: socket.id}, type: sequelize.QueryTypes.UPDATE}
        ).then(projects => {
            console.log(projects)
        })
        console.log(user   '离开了');
    });
});

server.listen(port, () => {
    console.log('listening on %d...', port);
});