在套接字事件上中断计时器

Question

我需要在套接字事件上中断计时器，我的 Nodejs Express Socket.io 应用程序如下所示：

app.js

const express = require('express') ;
const app = express();
const server = require('http').Server(app);
const io = require('socket.io')(server);
const api = require('./routes/api');

const users = io.of('/users') ;

const usersNamespace= (socket) => {
   socket.on('disconnect',()=>{
   });
}

users.on('connection',usersNamespace) ;

app.use('/api', api);
// make socket.io accessible in the express router
app.use((req,res,next)=>{
   req.io = io;
   req.users = users;
   next();
});
server.listen('8000');

我的./routes/api.js 文件看起来像：

var express = require('express');
var router = express.Router();

router.post('/test',req,res) {
    // broadcast body of request to users namespace
    req.users.emit('restreq',req.body) ;

    var timer = setInterval(()=>{
       console.log('hello');
    }, 5000);

    res.status(200).json('received') ;
}

module.exports = router;

问题是我如何做clearInterval 并在接收套接字事件时停止计时器？

Answer 1

您可以像使用users 一样传递一个函数或对象来处理间隔：

app.js

const express = require('express') ;
const app = express();
const server = require('http').Server(app);
const io = require('socket.io')(server);
const api = require('./routes/api');

const users = io.of('/drivers') ;

const timer = {
    hInterval: null,
    register: hInterval => {
        timer.hInterval = hInterval
    },
    disable: () => {
        clearInterval(timer.hInterval)
        timer.hInterval = null
    }
}

const usersNamespace = socket => {
   socket.on('disconnect', () => {
       timer.disable()
   });
}

users.on('connection', usersNamespace) ;

app.use('/api', api);
// make socket.io accessible in the express router
app.use((req, res, next)=>{
   req.io = io;
   req.users = users;
   req.timer = timer;
   next();
});
server.listen('8000');

api.js:

var express = require('express');
var router = express.Router();

router.post('/test', req,res) {
    // broadcast body of request to users namespace
    req.users.emit('restreq',req.body) ;
    req.timer.register(setInterval(() => {
       console.log('hello');
    }, 5000));

    res.status(200).json('received') ;
}

module.exports = router;