PHP訪問MySQL查詢超時處理的方法

2020-01-19 00:09:20

字體：大中小

來源：轉載

供稿：網友

目前兩個客戶端擴展庫連接超時可以設置選項來操作，比如mysqli：

 
<?php 
//創建對象 
$mysqli = mysqli_init(); 
//設置超時選項 
$mysqli->options(MYSQLI_OPT_CONNECT_TIMEOUT, 5); 
//連接 
$mysqli->real_connect('localhost', 'my_user', 'my_password', 'world'); 
//如果超時或者其他連接失敗打印錯誤信息 
if (mysqli_connect_errno()) { 
printf("Connect failed: %s/n", mysqli_connect_error()); 
exit(); 
} 
//成功輸出連接信息 
printf ("Connection: %s/n.", $mysqli->host_info); 
$mysqli->close(); 
?> 

這個是連接超時，但是有些時候我們需要查詢讀寫超時，比如說我們一個數據庫壓力很大，或者連接很多，那么數據庫查詢就很緩慢，但是我希望某些不重要的數據，比如說文章點擊數這種如果查詢超時了就不顯示，至少能夠保證主體頁面正確顯示，但是查遍PHP手冊沒有發現這個操作選項或者函數。

手冊里只有這么四個選項

跟蹤 mysqli 的擴展源代碼發現它底層調用的是 libmysqlclient 的 mysql_options：

php-5.2.8/ext/mysqli/mysqli_api.c

并且在mysqli的PHP擴展中就只導出了幾個變量：

php-5.2.8/ext/mysqli/mysqli.c

大概看了一下 libmysqlclient 的代碼，發現其實它自帶是有讀寫超時設置的：

mysql-5.1.30/sql-common/client.c

因為它自己定義了很多操作選項，只是php擴展里沒有：

mysql-5.1.30/include/mysql.h

看看mysql中的讀寫超時是如何實現的：

mysql-5.1.30/sql-common/client.c

讀寫超時真正操作的地方，超時處理這里重試了兩次，還是寫死了：

mysql-5.1.30/sql/net_serv.cc

現在基本得出了結論：

按照上面查看代碼來看，目前PHP針對MySQL查詢超時以下限制：

1. 超時設置單位為秒，最少配置1秒

2. 但mysql底層的read會重試兩次，所以實際會是 3 秒

重試兩次 +　自身一次 = 3倍超時時間。

那么就是說最少超時時間是3秒，不會低于這個值，對于大部分應用來說可以接受，但是對于小部分應用需要優化。
現在我們來看看如果我們自己要設置超時，我們自己壓入 MYSQL_OPT_READ_TIMEOUT 也是可以達到讀寫超時效果的，寫一段代碼來測試一下：

復制代碼代碼如下:

 
<?php 
//自己定義讀寫超時常量 
if (!defined('MYSQL_OPT_READ_TIMEOUT')) { 
define('MYSQL_OPT_READ_TIMEOUT', 11); 
} 
if (!defined('MYSQL_OPT_WRITE_TIMEOUT')) { 
define('MYSQL_OPT_WRITE_TIMEOUT', 12); 
} 

//設置超時 
$mysqli = mysqli_init(); 
$mysqli->options(MYSQL_OPT_READ_TIMEOUT, 3); 
$mysqli->options(MYSQL_OPT_WRITE_TIMEOUT, 1); 

//連接數據庫 
$mysqli->real_connect("localhost", "root", "root", "test"); 
if (mysqli_connect_errno()) { 
printf("Connect failed: %s/n", mysqli_connect_error()); 
exit(); 
} 

//執行查詢 sleep 1秒不超時 
printf("Host information: %s/n", $mysqli->host_info); 
if (!($res=$mysqli->query('select sleep(1)'))) { 
echo "query1 error: ". $mysqli->error ."/n"; 
} else { 
echo "Query1: query success/n"; 
} 

//執行查詢 sleep 9秒會超時 
if (!($res=$mysqli->query('select sleep(9)'))) { 
echo "query2 error: ". $mysqli->error ."/n"; 
} else { 
echo "Query2: query success/n"; 
} 

$mysqli->close(); 
echo "close mysql connection/n"; 
?> 