javascript - 使用 socket.io 排队

Question

我使用 node.js 每 10 秒查询一次 MySQL 数据库表。使用 socket.io，每 10 秒查询一次数据库后，每个连接的浏览器都会从该查询中接收到一批唯一的行。

问题:按照我的实现方式，每隔 10 秒，就有可能有超过 1 个浏览器接收到同一组行。我使用了一些 checkout 系统(如下所示)来标记已经发送到另一个浏览器的行，但它似乎并不总是有效。我如何保证每个浏览器每次都获得一组唯一的行？

换句话说，其他浏览器同时查询数据库比锁定行更快!

实现

每 10 秒，会发生以下情况

1. Node.js 应用程序查询 MySQL 数据库表 SELECT * FROM table WHERE checkout = 0
2. 如果返回结果，node.js 服务器 io.sockets.send 向所有连接的浏览器发送一条消息，说明行可用
3. 所有连接的客户端都响应 socket.emit('ready')
4. Server 收到 ready emit，再次查询数据库选择 3 行，然后更新表将这 3 行的 checkout 列设置为 1
5. 服务器端将数据库查询结果发送给客户端

显然，与第一个浏览器使用 checkout = 1 更新行相比，第二个浏览器引发 SELECT... 查询所需的时间似乎更少.还有另一种方法可以进行这种排队吗？

截图

正如您在同时打开 2 个浏览器的屏幕截图中看到的那样，通常两个浏览器都会获得相同的行集。行的 ID 是 console.loged，如图所示。

代码

Node.js

io.sockets.on('connection', function(socket) {
    // Client ready to take jobs after receiving broadcast
    socket.on('ready', function() {
        getListings(function(listings) {
            socket.emit('job', listings);   // send jobs
        });
    });

});

var getListings = function(callback) {
    client.query('SELECT * FROM table ' + 
                'WHERE job_checkout = 0 ' +
                'ORDER BY listing_id ASC ' +
                'LIMIT 0, 3', 
                function(error ,results, fields) {
                    if (error) 
                        throw error;
                    // Checkout listing now!
                    checkoutListings(results);
                    callback(results);
                });
};

var checkoutListings = function(listings) {
    for (var i = 0; i < listings.length; i++) {
        checkoutListing(listings[i]);
    }
}

var checkoutListing = function(listing) {
    client.query('UPDATE table ' + 
                    'SET job_checkout = 1 ' +
                    'WHERE listing_id = ?',
                    [ listing.listing_id ]);
}

Answer 1

在选择它们之前更新行。例如

update table 
set job_checkout = uniqueNumber 
where job_checkout = 0
limit 10

uniqueNumber 可以是进程/线程 id，或者浏览器客户端 id，或者适合 node.js 环境的东西(我不熟悉)。现在选择具有唯一 job_checkout 的行。