php使用异步非阻塞通过PDO进行高并发向数据库发起多个请求的示例代码

好的，以下是一个使用异步非阻塞通过PDO进行高并发向数据库发起多个请求的示例代码:

// 创建一个连接池，并设置最大连接数为10
$pool = new \Swoole\Coroutine\Channel(10);

// 创建10个连接，存入连接池
for ($i = 0; $i < 10; $i++) {
    $pdo = new \PDO('mysql:host=127.0.0.1;dbname=test;charset=utf8mb4', 'root', 'password');
    $pool->push($pdo);
}

// 协程函数，用于从连接池中获取一个连接
function getConnection($pool) {
    $pdo = $pool->pop();
    defer(function() use ($pool, $pdo) {
        // 协程结束时，将连接归还给连接池
        $pool->push($pdo);
    });
    return $pdo;
}

// 协程函数，用于发起数据库查询请求
function query($sql) {
    $pdo = getConnection($GLOBALS['pool']);
    $stmt = $pdo->query($sql);
    $result = $stmt->fetchAll();
    return $result;
}

// 协程函数，用于并发发起多个数据库查询请求
function batchQuery($sqls) {
    $result = [];
    foreach ($sqls as $sql) {
        $result[] = query($sql);
    }
    return $result;
}

// 1000个并发请求示例
$sqls = [];
for ($i = 0; $i < 1000; $i++) {
    $sqls[] = "SELECT * FROM users WHERE id = " . rand(1, 100);
}

// 并发发起1000个数据库查询请求，并输出结果
$GLOBALS['pool'] = $pool;
$result = batchQuery($sqls);
var_dump($result);

注意：以上示例使用了 Swoole 扩展，在使用前需要先安装 Swoole 扩展。