問題
通常一個web應用的性能瓶頸在數據庫。因為，通常情況下php中mysql查詢是串行的。也就是說，如果指定兩條sql語句時，第二條sql語句會等到第一條sql語句執行完畢再去執行。這個時候，如果執行2條sql語句，每條執行時間為50ms，全部執行完畢可能需要100ms。既然，主要原因是sql的串行執行導致。那我們是不是可以改變執行方式來提高性能呢？答案是，可以的。我們可以通過異步執行的方式來提高性能。
異步
如果通過異步的方式去執行，可能性能會有很大提升。如果是采用異步的方式，兩條sql語句會並發執行，可能就需要60ms就可以執行完畢。
實現
mysqli + mysqlnd。php官方實現的mysqlnd中提供了異步查詢的方法。分別是：
mysqlnd_async_query 發送查詢請求
mysqlnd_reap_async_query 獲取查詢結果
這樣就可以不必每次發送完查詢請求后，一直阻塞等待查詢結果了。
實現代碼如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
<?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,
"1\n"
;
$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"
;
|
結語
mysql數據庫對於每個查詢請求都是單獨啟動一個線程進行處理。如果mysql服務器啟動線程過多，必然會造成線程切換引起系統負載過高。如果在mysql數據庫負載不高的情況下，使用異步查詢還是不錯的選擇。