Socket.io服务器 - 暂停监听和恢复

Question

我需要一个机制来启动和停止socket.io服务器。当停止命令到达时，所有客户端都会断开连接，服务器停止添加新的连接。当调用启动函数时，socket服务器以正常模式添加新的客户端连接。

我正在尝试以下代码：

var app = require('http').createServer(function() {}),
io = require('socket.io').listen(app);

app.listen(25544);

io.set('log level', 1);
io.set('close timeout', 240);
io.set('heartbeat timeout', 240);
io.set('heartbeat interval', 120);

io.startServer = function() {
    app.listen(25544);
};

io.stopServer = function() {
    app.close()
};

但是当我调用app.close()时，出现错误：

net.js:1236
    throw new Error('Not running');
          ^
Error: Not running
    at Server.close (net.js:1236:11)
    at Manager.module.exports.io.stopServer (/home/streamuser/nodejs/data/io.js:22:10)
    at process.<anonymous> (/home/streamuser/nodejs/data/app.js:146:7)
    at process.EventEmitter.emit (events.js:98:17)
    at handleMessage (child_process.js:318:10)
    at Pipe.channel.onread (child_process.js:345:11)

- user2024300

---

执行以下代码：app.listen(25544, function(){console.log("server running")}); 并检查控制台是否输出'server running'。 - M Omayr

Answer 1

如果有人需要，我公开解决方案：

module.exports = (function() {
    var https = require("https"),
    fs = require("fs"),
    app = https.createServer({
        key: fs.readFileSync(BASE_DIR + '/private.pem').toString(),
        cert: fs.readFileSync(BASE_DIR + '/public.pem').toString()
    }),
    io = require("socket.io").listen(app);

    io.listeningClients = false;

    var oldListeners = app.listeners('request').splice(0);
    app.removeAllListeners('request');

    app.on('request', function (req, res) {
        if (! (io.listeningClients || req.url.indexOf('.js') !== -1)) {
            res.writeHead(404, {"Content-Type": "text/plain"});
            res.write('Socket.io stop listening. Try again later.');
            res.end();
            return;
        }

        for (var i = oldListeners.length; i--; ) {
            oldListeners[i].call(app, req, res);
        }
    });

    io.set('log level', 1);
    io.set('reconnect', false);
    io.set('reconnection limit', 20000);
    io.set('max reconnection attempts', Infinity);
    io.set('close timeout', 240);
    io.set('heartbeat timeout', 240);
    io.set('heartbeat interval', 120);


    io.startListeningClients = function() {
        if (io.listeningClients) {
            return;
        }

        io.listeningClients = true;
        app.listen(25544, function() {});
    };

    io.stopListeningClients = function() {
        if (! io.listeningClients) {
            return;
        }

        io.listeningClients = false;
        app.close();

        var clients = io.sockets.clients();
        for (var i in clients) {
            clients[i].disconnect();
        }
    };

    return io;
})();

- user2024300