node.js + socket.io：拍卖网站开发

Posted 2023-03-07

【中文标题】node.js + socket.io：拍卖网站开发

【英文标题】：node.js + socket.io: auction website development

【发布时间】：2016-05-01 19:00:48

【问题描述】：

我目前正在使用 node.js 和 socket.io 编写拍卖脚本。但是该网站是使用 php 和 mysql 开发的。在这里，我仅将 node.js + socket.io 用于拍卖投标过程。该网站将有 500-1000 名登录用户在拍卖期间查看单个页面。只有一件物品将被拍卖，并且将在一天内出售一次。

我将向从服务器到客户端的所有用户广播（发射）一个倒数计时器。在服务器端，我将使用 setInterval()、1 秒的递归 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);
    );

Client.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);
    );
);

我正在等待您解决浏览器挂起问题的答案。

【问题讨论】：

没有有效的指标可以给你一个yes 或no 的答案。从硬件到实际的高峰时间连接，所需的带宽等，甚至没有被问到的问题太多了。在没有首先收集所有信息的情况下问这些问题是不现实的。如果您需要准确的答案，请聘请公司进行审计。如果你买不起，那就试着衡量自己。无论你多么想得到一个，你都不会得到关于 SO 的正确答案。

作为一名 NodeJS 开发人员，我可以告诉你创建模块会更好。带有原型的对象。它极大地增加了代码的可读性！

@Mijago，感谢您的建议，我也会尝试使用模块和更多的东西。因为我目前正在学习 node.js 并从事该项目。

@mjh，我不明白你对有效指标的看法

什么不清楚？你没有提供任何可用的数字？您没有提供一个数字（指标）来帮助我们告诉您您想听到什么。信息不足。

【参考方案1】：

第一个问题： 这种方法可靠吗？

不需要每秒向每个客户发送时间。只需在他们第一次访问时向他们发送时间，并使用本地计时器（在他们的本地页面上）来减少每秒的时间。

您还需要在每次出价时检查服务器时间（更安全）。

如果这对您来说不够“安全”，请发送更改出价的时间。您只需在实际出价发生变化时（使用广播）或用户加入网站时（只需将其发送给他）发送实际出价。

第二个问题： 它是否能够处理服务器上的使用情况？

是和否。

如果您的服务器足够好（每台 5 美元且流量无限的服务器都适合）， 你不应该惹上麻烦。仅当您的脚本非常糟糕并且存在内存泄漏时。

现在有一些提示：

永远不要相信用户输入 - 在使用之前先解析它！ 在服务器上重新计算您从客户端获得的所有内容。 只向客户发送他需要的东西。他不需要关于他不使用的东西的信息。

如果这是您希望的答案，请选择左侧的绿色箭头。 如果没有，请在这里写评论，我会提供更多提示。

【讨论】：

嗨 Mijago，在使用集群进程之前，站点处理 300-400 个用户正确计时器工作，让超过 400 个用户的网站挂起。在使用集群和 redis pub sub 更改流程后，无法正确处理 5 个用户。我不知道本地计时器是如何工作的，它需要根据特定的国家时区工作。

不，它不需要处理时区，你给他们拍卖结束的秒数，然后用计时器倒计时到零。

此外，我在这里解释我的网站在计时器中的投标过程少于 15 秒，如果用户下标意味着需要重置计时器，时间为 15 秒，并向所有用户提供拍卖价格和历史详细信息（谁都打开了网站）。此外，如果计时器达到 0 意味着需要关闭该拍卖的出价，它将如何完成此过程？

如果超过 500 个用户的网站挂起，则在不使用集群进程服务器的情况下仅处理 400-500 个用户的网站。但是在添加集群后，redis 方法与 server.js 然后网站 10 个用户仅处理和计时器倒计时无法正常工作。如果我们使用集群进程意味着它使用实时服务器创建 10 个子进程，那么这会导致问题吗？