如何按指定队列顺序循环查询数据并限制总数（含SQL/PHP方案）

这个需求完全可以实现，下面提供两种可行方案：

SQL 查询方案 #

适合队列顺序相对固定的场景，通过窗口函数实现轮询逻辑：

SELECT item_id, name, data, priority, expire
FROM (
    SELECT 
        item_id, name, data, priority, expire,
        -- 给每个队列内的记录按优先级+ID排序并编号
        ROW_NUMBER() OVER (PARTITION BY name ORDER BY priority DESC, item_id) AS rn,
        -- 定义队列的轮询优先级，序号越小越先被取到
        CASE name
            WHEN 'decimal_queue' THEN 1
            WHEN 'single_queue' THEN 2
            WHEN 'three_queue' THEN 3
            -- 后续新增队列时，在这里添加对应的名称和序号即可
            ELSE 999
        END AS queue_priority
    FROM your_table_name
    -- 可选：过滤未过期的记录
    WHERE expire > NOW()
) AS ranked_records
-- 先按记录编号升序，再按队列优先级升序，实现轮询效果
ORDER BY rn, queue_priority
LIMIT 10;

逻辑说明：

• 内层查询给每个队列的记录单独编号，保证同一队列内优先取出优先级高的记录；
• 外层通过rn（记录编号）和queue_priority（队列优先级）排序，让同一编号下先取优先级高的队列，不同编号按顺序轮询；
• 新增队列时只需修改CASE语句，扩展性较好。

PHP 后端实现方案 #

适合队列顺序需要动态调整的场景（比如从配置/数据库读取队列列表），逻辑更灵活：

// 队列顺序，可从配置文件或数据库动态获取
$queueOrder = ['decimal_queue', 'single_queue', 'three_queue'];
$maxResultCount = 10;
$finalResult = [];

// 初始化数据库连接
$pdo = new PDO('mysql:host=localhost;dbname=your_database', 'username', 'password');
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

// 预加载每个队列的有效记录（按优先级排序）
$queueRecords = [];
foreach ($queueOrder as $queueName) {
    $stmt = $pdo->prepare("
        SELECT item_id, name, data, priority, expire 
        FROM your_table_name 
        WHERE name = ? AND expire > NOW() 
        ORDER BY priority DESC, item_id
    ");
    $stmt->execute([$queueName]);
    $queueRecords[$queueName] = $stmt->fetchAll(PDO::FETCH_ASSOC);
}

// 循环轮询取数
$currentQueueIndex = 0;
while (count($finalResult) < $maxResultCount) {
    $currentQueue = $queueOrder[$currentQueueIndex % count($queueOrder)];
    
    // 当前队列还有记录的话，取出第一条加入结果
    if (!empty($queueRecords[$currentQueue])) {
        $finalResult[] = array_shift($queueRecords[$currentQueue]);
    }
    
    $currentQueueIndex++;
    
    // 检查所有队列是否都无数据，提前终止循环
    $allQueuesEmpty = true;
    foreach ($queueRecords as $records) {
        if (!empty($records)) {
            $allQueuesEmpty = false;
            break;
        }
    }
    if ($allQueuesEmpty) break;
}

// 输出结果（可根据业务需求调整返回格式）
print_r($finalResult);

逻辑说明：

• 先预加载每个队列的有效记录，避免多次重复查询数据库；
• 通过索引取模的方式，依次从每个队列中取出一条记录，直到凑够10条或所有队列无数据；
• 新增/删除队列只需修改$queueOrder数组，完全支持动态变化。

两种方案各有优势：SQL方案性能更优（一次查询搞定），PHP方案灵活性更强，可根据实际业务场景选择。

内容的提问来源于stack exchange，提问作者Susobhan Das