PHP가 MySql에 연결할 때 자동으로 다시 연결하는 방법

mysql 연결이 중단되면 이후 루프 실행이 실패합니다. 이번 글에서는 PHP가 MySql에 접속할 때 자동으로 재연결되는 방법을 주로 소개합니다. 매우 훌륭하고 참고할만한 가치가 있습니다. 관심있는 친구들은 함께 배워보세요

Cli 모드에서 PHP를 백그라운드 실행 프로그램(예: 그룹 문자 메시지)으로 사용하세요. PHP를 실행하려면 PHP가 mysql에 연결하여 루프에서 데이터베이스 처리를 수행해야 합니다.

mysql 연결이 중단되면 이후 루프 실행이 실패합니다.

후속 프로그램이 정상적으로 실행될 수 있도록 mysql 연결이 끊길 때 자동으로 다시 연결할 수 있는 방법을 설계해야 합니다.

1. 테스트 데이터 테이블 만들기

CREATE TABLE `user` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`name` varchar(20) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

2. 테스트 데이터 삽입

insert into user(name) values('fdipzone'),('xfdipzone'),('terry');
mysql> select * from user;
+----+-----------+
| id | name |
+----+-----------+
| 1 | fdipzone |
| 2 | xfdipzone |
| 3 | terry |
+----+-----------+

3. 백그라운드에서 실행되는 PHP 파일

db.php

<?php
// 数据库操作类
class DB{
// 保存数据库连接
private static $_instance = null;
// 连接数据库
public static function get_conn($config){
if(isset(self::$_instance) && !empty(self::$_instance)){
return self::$_instance;
}
$dbhost = $config[&#39;host&#39;];
$dbname = $config[&#39;dbname&#39;];
$dbuser = $config[&#39;user&#39;];
$dbpasswd = $config[&#39;password&#39;];
$pconnect = $config[&#39;pconnect&#39;];
$charset = $config[&#39;charset&#39;];
$dsn = "mysql:host=$dbhost;dbname=$dbname;";
try {
$h_param = array(
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
);
if ($charset != &#39;&#39;) {
$h_param[PDO::MYSQL_ATTR_INIT_COMMAND] = &#39;SET NAMES &#39; . $charset; //設置默認編碼
}
if ($pconnect) {
$h_param[PDO::ATTR_PERSISTENT] = true;
}
$conn = new PDO($dsn, $dbuser, $dbpasswd, $h_param);
} catch (PDOException $e) {
throw new ErrorException(&#39;Unable to connect to db server. Error:&#39; . $e->getMessage(), 31);
}
self::$_instance = $conn;
return $conn;
}
// 执行查询
public static function query($dbconn, $sqlstr, $condparam){
$sth = $dbconn->prepare($sqlstr);
try{
$sth->execute($condparam);
} catch (PDOException $e) {
echo $e->getMessage().PHP_EOL;
}
$result = $sth->fetchAll(PDO::FETCH_ASSOC);
return $result;
}
}
?>

test.php

<?php
require &#39;db.php&#39;;
// 数据库设定
$config = array(
&#39;host&#39; => &#39;localhost&#39;,
&#39;dbname&#39; => &#39;user&#39;,
&#39;user&#39; => &#39;root&#39;,
&#39;password&#39; => &#39;&#39;,
&#39;pconnect&#39; => 0,
&#39;charset&#39; => &#39;&#39;
);
// 循环执行
while(true){
// 创建数据连接
$dbconn = DB::get_conn($config);
// 执行查询
$sqlstr = &#39;select * from user where id=?&#39;;
$condparam = array(mt_rand(1,3));
$data = DB::query($dbconn, $sqlstr, $condparam);
print_r($data);
// 延时10秒
echo &#39;sleep 10&#39;.PHP_EOL.PHP_EOL;
sleep(10);
}
?>

4. 단계 수행

php cli 모드에서 test.php 실행 , 그런 다음 즉시 mysql.server stop 및 mysql.server start를 실행하여 플래시 중단을 시뮬레이션합니다

mysql.server stop
Shutting down MySQL
.. SUCCESS! 
mysql.server start
Starting MySQL
SUCCESS!

. 플래시 중단 후 데이터베이스를 다시 연결할 수 없고 후속 프로그램을 실행할 수 없는 것을 볼 수 있습니다.

Array
(
[0] => Array
(
[id] => 3
[name] => terry
)
)
sleep 10
SQLSTATE[HY000]: General error: 2006 MySQL server has gone away
Array
(
)
sleep 10
SQLSTATE[HY000]: General error: 2006 MySQL server has gone away
Array
(
)
sleep 10
...

5. 재연결 메커니즘 추가

if(isset(self::$_instance) && !empty(self::$_instance)){
return self::$_instance;
}

중단 후에는 self::$_instance 값이 존재하므로 get_conn을 호출하면 다시 연결되지 않습니다. 대신, 저장된 연결은 처리에 사용됩니다.

실제로는 연결이 존재하면 mysql 연결을 다시 생성할 필요가 없으므로 mysql 연결 수가 줄어듭니다.

그러므로 생성되었으나 실패한 데이터베이스 연결을 사용하지 않고 다음에 연결을 다시 얻을 수 있도록 중단 후 self::$_instance 값을 지워야 합니다.

개선 사항은 다음과 같습니다.

오류 발생 시 호출되는 Reset_connect 메소드를 추가합니다. 오류가 MySQL 서버가 사라진 것으로 판단되면 기존 데이터베이스 연결이 지워지고 다음에 MySQL이 다시 연결됩니다.

수정된 php 파일은 다음과 같습니다.

db.php

 PDO::ERRMODE_EXCEPTION,
);
if ($charset != '') {
$h_param[PDO::MYSQL_ATTR_INIT_COMMAND] = 'SET NAMES ' . $charset; //設置默認編碼
}
if ($pconnect) {
$h_param[PDO::ATTR_PERSISTENT] = true;
}
$conn = new PDO($dsn, $dbuser, $dbpasswd, $h_param);
} catch (PDOException $e) {
throw new ErrorException('Unable to connect to db server. Error:' . $e->getMessage(), 31);
}
self::$_instance = $conn;
return $conn;
}
// 执行查询
public static function query($dbconn, $sqlstr, $condparam){
$sth = $dbconn->prepare($sqlstr);
try{
$sth->execute($condparam);
} catch (PDOException $e) {
echo $e->getMessage().PHP_EOL;
self::reset_connect($e->getMessage()); // 出错时调用重置连接
}
$result = $sth->fetchAll(PDO::FETCH_ASSOC);
return $result;
}
// 重置连接
public static function reset_connect($err_msg){
if(strpos($err_msg, 'MySQL server has gone away')!==false){
self::$_instance = null;
}
}
}
?>

6. 플래시 실행을 다시 수행해 보세요

플래시 이후 개선된 효과를 보실 수 있습니다. 실행됨 실패하지만 새 연결을 다시 생성하여 실행을 계속할 수 있습니다. ㅋㅋㅋ

위 내용은 PHP가 MySql에 연결할 때 자동으로 다시 연결하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!