php mysql 异步, php mysql 异步并发查询

mysqli提供了异步执行sql的功能，类似于select轮询机制。先提交SQL到预发布，再去轮询查询是否ok。query的时候加上MYSQLI_ASYNC选项，query就直接提交到mysql，但是本身不等待执行结果。mysqli不亏是加强版的mysql扩展，可惜不是pdo

<?php
/**
 * 执行SQL
 * @param $sql
 * @return mysqli
 */
function query($sql)
{
    // 1.创建连接
    $servername = "localhost";
    $username = "root";
    $password = "root";
    $database = "test";
    $conn = new mysqli($servername, $username, $password, $database);
    if ($conn->connect_error) {
        die("连接失败: " . $conn->connect_error);
    }

    // 2.异步提交SQL
    $conn->query($sql, MYSQLI_ASYNC);

    // 3.返回SQL连接
    return $conn;
}

// 1.保存全部的Conn变量
$all_conn = [];

// 2.循环提交异步SQL
$i = 4;
while ($i--) {
    $sql = "select scenes_name_cn from erp_allocation_scenes where id = $i";
    $all_conn [] = query($sql, MYSQLI_ASYNC);
}

// 3.循环等待全部的结果
$allResult = [];
do {
    $links = $errors = $reject = $all_conn;
    if (!mysqli_poll($links, $errors, $reject, 1)) {
        continue;
    }
    foreach ($all_conn as $conn) {
        if ($result = $conn->reap_async_query()) {
            $allResult[] = $result->fetch_row();
            if (is_object($result)) {
                $result->free();
            }
        } else {
            throw new mysqli_sql_exception(sprintf("MySQLi Error: %s", mysqli_error($conn)));
        }
    }
} while (count($allResult) == 5);

// 4.输出查询结果
print_r($allResult);