PHP并行查询MySQL
浏览量:192
还是通过例子来介绍MySQL并行查询的实施方法。假设要并行地向MySQL发出10个查询，最基本的代码应该是这样的：
$links = [];
for ($i = 0; $i !== 10; $i++) {
$links[$i] = new mysqli('127.0.0.1', 'user', 'password', 'db1');
$links[$i]->query('SELECT SLEEP(1)', MYSQLI_ASYNC);
}
$allResult = [];
while (!empty($links)) {
$reads = $links;
$errors = $reject = [];
if (!mysqli_poll($reads, $errors, $reject, null)) {
continue;
}
foreach ($reads as $read) {
$idx = array_search($read, $links, true);
$allResult[$idx] = [];
$result = $read->reap_async_query();
while ($row = $result->fetch_row()) {
$allResult[$idx][] = $row;
}
$read->close();
unset($links[$idx]);
}
}
解释下这段代码的含义：
2~5行，同时发起10个MySQL连接，并发出查询
注意query() 的第二个参数带上了 MYSQLI_ASYNC 表示非阻塞查询
10行，使用mysqli_poll 轮询10个连接的查询有无返回
mysqli_poll 的第一个参数$reads是个数组，包含需要轮询那些连接。mysqli_poll 执行完后，会改写$reads，改写后$reads包含的是那些已经有数据返回连接。
mysqli_poll的第四个参数，控制的是轮询的等待时间，单位是“秒”。如果像本例当中设置为null，那么mysqli_poll轮询是阻塞的：只有监听的连接中，任意一个连接有数据返回了，mysqli_poll才会返回。如果等待时间设置为0，那么每次执行mysqli_poll会立即返回，外层的while会频繁循环。
第11~19行，遍历已经有数据返回的连接
reap_async_query和普通query一样，返回的是mysqli_result，可以一行行fetch数据
20~21行，对于已经获得了数据的连接，下次mysqli_poll就不需要再轮询这个连接了，所以关闭连接，并从$links数组删除这个连接
当所有的连接都返回了数据，$links数组空了，while循环也就终止了。
使用并行查询的方式，可以大大缩短处理HTTP请求的时间，假设本例中的10个SQL查询，每个需要执行1秒。因为是并行，处理所有的查询，也只需要1秒左右。
感谢支持与鼓励～