MySQL 异步查询提高查询速度-白红宇

MySQL 异步查询提高查询速度

阅读量：432 次

发布时间：2019-03-05

本文共 1420 字，大约阅读时间需要 4 分钟。

MySQL 异步查询概述

MySQL 异步查询是一种高效的数据处理方式，通过同时处理多个查询请求来提升性能。这种机制特别适合需要快速响应的应用场景。

MySQL 异步查询的优缺点

优点

提升查询速度：异步查询通过并行处理减少了等待时间，能够显著缩短响应时间。

扩展能力强：支持大量并发请求，适合高并发场景。

缺点

资源占用：每次启动异步查询会创建新的线程，可能增加 CPU 和内存负载。

复杂性增加：开发和维护异步查询需要更高的技术门槷。

MySQL 异步查询的实战示例

背景

在处理 100 万数据的 40 张分表时，传统的Union All视图需要 20 多秒，而异步查询能够在 1 秒内完成。

实现方法

主要使用 mysqli_poll 和 reap_async_query 扩展方法。通过循环执行多个查询，立即返回处理。

$table_separate_cnt = 40;$sqls = [];for ($i = 0; $i < $table_separate_cnt; $i++) {    $sql = 'select * from news' . $i;    array_push($sqls, $sql);}$links = [];foreach ($sqls as $sql) {    $link = mysqli_connect($hostname, $username, $password, 'test', '3306');    $link->query($sql, MYSQLI_ASYNC);    $links[$link->thread_id] = $link;}$process = 0;$res = [];do {    $r_array = $e_array = $reject = $links;    if (!($ret = mysqli_poll($r_array, $e_array, $reject, 2))) {        continue;    }    foreach ($r_array as $link) {        if ($result = $link->reap_async_query()) {            $r = $result->fetch_array();            if ($r) {                $res[] = $r;            }            if (is_object($result)) {                mysqli_free_result($result);            }            unset($links[$link->thread_id]);            $link->close();            $process++;        }    }    foreach ($e_array as $link) {        die;    }    foreach ($reject as $link) {        die;    }} while ($process < $llen);