javascript - node.js + socket.io: オークションサイト開発

Question

現在、node.js と socket.io を使用してオークション スクリプトを作成していますが、サイトは PHP と MySQL を使用して開発されています。ここでは node.js + socket.io をオークション入札プロセスのみに使用しています。このサイトでは、オークション中に 500 ～ 1000 人のログイン ユーザーが 1 ページを閲覧します。出品は1点のみで、1日1回の出品となります。

サーバーからクライアントまで、すべてのユーザーにカウントダウン タイマーをブロードキャスト (送信) します。サーバー側では、オークション終了時刻までのカウントダウンに 1 秒の setInterval(),recursive setTimeout() を使用します。これとは別に、送信される他の唯一のメッセージは、単一のクライアントからサーバーに渡され、すべてにブロードキャストされる現在の入札です。この方法は、信頼できることを行うには？そして、サーバーでの使用を処理できますか?. ここでは、500 人のユーザーでテストしましたが、これはブラウザーでタイマーが停止することを意味します。

サーバー.js

var cluster = require('cluster');
var app = require('express')();
//var http = require('http');
var https = require('https');
var socket = require('socket.io');
var redis = require('redis');
var redisAdapter = require('socket.io-redis');
var request = require('request');
var fs = require('fs');

var options = {
    key: fs.readFileSync('keys/e1317_0f2c9_71565598d419e37e376ccef5c2827113.key'),
    cert: fs.readFileSync('certs/e1317_0f2c9_1468152279_2dc46c1f2cc135a.crt'),
    ca: fs.readFileSync('cabundles/90490a5c829d2aca24f22b5820864c6e_1935558000.cabundle')
};

//var server = http.createServer( app );
var server = https.createServer(options, app);
var io = socket.listen(server);

var port = process.env.PORT || 8080;
var workers = process.env.WORKERS || require('os').cpus().length;

var redisUrl = process.env.REDISTOGO_URL || 'redis://127.0.0.1:6379';
var redisOptions = require('parse-redis-url')(redis).parse(redisUrl);
var pub = redis.createClient(redisOptions.port, redisOptions.host, {
    detect_buffers: true,
    return_buffers: true,
    auth_pass: redisOptions.password
});
var sub = redis.createClient(redisOptions.port, redisOptions.host, {
    detect_buffers: true,
    return_buffers: true,
    auth_pass: redisOptions.password
});

io.adapter(redisAdapter({
    pubClient: pub,
    subClient: sub
}));

console.log('Redis adapter started with url: ' + redisUrl);

io.sockets.on('connection', function(client) {
    //console.log('first');
    client.on('nauction', function(data) {
        io.sockets.emit('nauction', data);
    });
});

io.on('connection', function(socket) {
    //console.log('in');
    console.log('connected client count:' + io.sockets.sockets.length);
    var recursive = function() {
        //console.log("It has been one second!");
        if (io.sockets.sockets.length > 0) {
            request('https://www.example.com/file.php', function(error, response, body) {
                if (!error && response.statusCode == 200) {
                    data = JSON.parse(body);
                    socket.volatile.emit('auction_data', {
                        'auction_data': data
                    });
                    //console.log(data);
                } else {
                    //console.log('else');
                    console.log(error);
                }
            });
        } //else{
        //console.log('No clients connected now');
        //}
        setTimeout(recursive, 1000);
    }
    recursive();
    socket.on("disconnect", function() {
        console.log('clear interval')
            //clearInterval(interval);
        clearTimeout(recursive);
    });
});

if (cluster.isMaster) {
    console.log('start cluster with %s workers', workers - 1);
    workers--;
    for (var i = 0; i < workers; ++i) {
        var worker = cluster.fork();
        console.log('worker %s started.', worker.process.pid);
    }

    cluster.on('death', function(worker) {
        console.log('worker %s died. restart...', worker.process.pid);
    });
} else {
    start();
}

function start() {
    server.listen(port, function() {
        console.log('listening on *:' + port);
    });
}

クライアント.js

socket.on('auction_data', function(auction_details) {
    //console.log(auction_details);
    $.each(auction_details, function(keys, values) {
        //countdwon formation
        var tm, days, hrs, mins, secs;
        days = value.auction_data.time.days;
        if (value.auction_data.time.hours < 10) {
            hrs = ("0" + value.auction_data.time.hours);
        } else {
            hrs = value.auction_data.time.hours;
        }
        if (value.auction_data.time.mins < 10) {
            mins = ("0" + value.auction_data.time.mins);
        } else {
            mins = value.auction_data.time.mins;
        }
        if (value.auction_data.time.secs < 10) {
            secs = ("0" + value.auction_data.time.secs);
        } else {
            secs = value.auction_data.time.secs;
        }
        if (days == 0) {
            tm = '' + hrs + '' + '' + mins + '' + '' + secs + '';
        } else {
            tm = '' + days + '' + '' + hrs + '' + '' + mins + '' + '' + secs + '';
        }
        $('#auction_' + value.auction_data.product_id + " .countdown").html(tm);
    });
});

ブラウザのハングの問題を解決するための回答をお待ちしています。