php-mysql异步查询

昨天下午把php中的curl_multi_*封装了一下(Yun_Curl_Multi/curl_multi的使用方法详解)，避免了网上很多demo中的一些问题，推荐给bigpipe及相关用户们。 之后有朋友问mysql是否也能异步的并发查询，答案当然是可以的，这里我给出了个demo，还没有封装成 正式的类，大家先看一下。

php5.3之后，mysqlnd驱动为php提供了异步请求mysql服务器的功能（mysql的驱动必须是mysqlnd才行）。

下面列出我的demo，以及异步查询和平常查询的时间消耗。我这只能说明使用方法，数据有点简单，欢迎大家使用线上数据做更详细的测试。

这个异步查询接口无法复用同一个链接，对于每一个query，需要使用一个完全独立的连接，对服务器 来说，这是一个资源消耗。

<?php

$host       = '127.0.0.1';
$user       = 'root';
$password   = '';
$database   = 'test';

/**
 * 期望得到额结果
 * array(
 *  1 => int,
 *  2 => int,
 *  3 => int
 * )
 */
$result = array(1=>0, 2=>0, 3=>0);

//异步方式[并发请求]
$time_start = microtime(true);
$links = array();

foreach ($result as $key=>$value) {
    $obj = new mysqli($host, $user, $password, $database);
    $links[spl_object_hash($obj)] = array('value'=>$key, 'link'=>$obj);
}
$done = 0;
$total = count($links);

foreach ($links as $value) {
    $value['link']->query("SELECT COUNT(*) AS `total` FROM `demo` WHERE `value`={$value['value']}", MYSQLI_ASYNC);
}

do {

    $tmp = array();
    foreach ($links as $value) {
        $tmp[] = $value['link'];
    }

    $read = $errors = $reject = $tmp;
    $re = mysqli_poll($read, $errors, $reject, 1);
    if (false === $re) {
        die('mysqli_poll failed');
    } elseif ($re < 1) {
        continue;
    }

    foreach ($read as $link) {
        $sql_result = $link->reap_async_query();
        if (is_object($sql_result)) {
            $sql_result_array = $sql_result->fetch_array(MYSQLI_ASSOC);//只有一行
            $sql_result->free();
            $hash = spl_object_hash($link);
            $key_in_result = $links[$hash]['value'];
            $result[$key_in_result] = $sql_result_array['total'];
        } else {
            echo $link->error, "n";
        }
        $done++;
    }

    foreach ($errors as $link) {
        echo $link->error, "1n";
        $done++;
    }

    foreach ($reject as $link) {
        printf("server is busy, client was rejected.n", $link->connect_error, $link->error);
        //这个地方别再$done++了。
    }
} while ($done<$total);
var_dump($result);
echo "ASYNC_QUERY_TIME:", microtime(true)-$time_start, "n";

$link = end($links);
$link = $link['link'];
echo "n";

//平常顺序执行的时间
$time_start = microtime(true);
$result = array(1=>0, 2=>0, 3=>0);
foreach ($result as $key=>$value) {
    $sql_result = $link->query("SELECT COUNT(*) AS `total` FROM `demo` WHERE `value`={$key}");
    if (is_object($sql_result)) {
        $sql_result_array = $sql_result->fetch_array(MYSQLI_ASSOC);
        $sql_result->free();
        $result[$key] = $sql_result_array['total'];
    } else {
        echo "error.n";
    }
}
var_dump($result);
echo "COMMON_QUERY_TIME:", microtime(true)-$time_start, "n";

结果数据

测试结果实在我的mac air上跑的，只能反应一个对比情况，并不代表线上服务器的实际性能。

完

转载请注明：爱开源 » php-mysql异步查询