mysql 连接闪断自动重连的方法
使用php作为后台运行程序(例如短信群发),在cli模式下执行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['host'];$dbname = $config['dbname'];$dbuser = $config['user'];$dbpasswd = $config['password'];$pconnect = $config['pconnect'];$charset = $config['charset'];$dsn = "mysql:host=$dbhost;dbname=$dbname;";try {$h_param = array(PDO::ATTR_ERRMODE => 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;}$result = $sth->fetchAll(PDO::FETCH_ASSOC);return $result;}}
?>
test.php
<?php
require 'db.php';// 数据库设定
$config = array('host' => 'localhost','dbname' => 'user','user' => 'root','password' => '','pconnect' => 0,'charset' => ''
);// 循环执行
while(true){// 创建数据连接$dbconn = DB::get_conn($config);// 执行查询$sqlstr = 'select * from user where id=?';$condparam = array(mt_rand(1,3));$data = DB::query($dbconn, $sqlstr, $condparam);print_r($data);// 延时10秒echo 'sleep 10'.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 MySQLSUCCESS!
可以看到,闪断后不能重新连接数据库,后面的程序不能执行下去。
Array
([0] => Array([id] => 3[name] => terry))
sleep 10SQLSTATE[HY000]: General error: 2006 MySQL server has gone away
Array
(
)
sleep 10SQLSTATE[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 server has gone away则清空已经存在的数据库连接,清空后下次则会重新连接mysql。
修改后的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['host'];$dbname = $config['dbname'];$dbuser = $config['user'];$dbpasswd = $config['password'];$pconnect = $config['pconnect'];$charset = $config['charset'];$dsn = "mysql:host=$dbhost;dbname=$dbname;";try {$h_param = array(PDO::ATTR_ERRMODE => 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.再次进行闪断执行
可以看到改进后的效果,闪断后,当前执行的会失败,但之后的可以重新创建新连接继续执行下去。
Array
([0] => Array([id] => 2[name] => xfdipzone))
sleep 10SQLSTATE[HY000]: General error: 2006 MySQL server has gone away
Array
(
)
sleep 10Array
([0] => Array([id] => 1[name] => fdipzone))
sleep 10
...
源码下载地址:点击查看
mysql 连接闪断自动重连的方法相关推荐
- php mysql 自动重连_PHP连接MySql闪断自动重连的方法
if(isset(self::$_instance) && !empty(self::$_instance)){ return self::$_instance; } 闪断后,因为 s ...
- 达梦数据库JDBC连接池断开自动重连设置
一.场景 在网络状况不是非常良好,经常会出现暂时性的拥塞或者断开的情况,而且当我们重启数据库时也会发生类似的情况.所以需要配置中间件的连接池来实现连接测试以及自动重连,通过重新配置连接池,成功解决了这 ...
- 关于MySQL连接Navicat Premium 12失败的解决方法
关于MySQL连接Navicat Premium 12失败的解决方法 参考文章: (1)关于MySQL连接Navicat Premium 12失败的解决方法 (2)https://www.cnblog ...
- win10间歇性闪屏_Win10系统桌面不停闪屏自动刷新的解决方法
在Win10系统中,我们都知道电脑在操作不当的情况下,可能会造成屏幕闪屏的情况,如果大家遇到这种情况,大家第一反应肯定是想到把电脑重启过,但是重启以后,发现还是没有什么改变,反复的琢磨后,小编才发现原 ...
- sftp配置导致ssh连接闪断
需求 研发同事需要用他测试服务器上的一个特定用户去连接另外一台ftp服务器,进行上传和下载文件,为了安全,这个用户连接ftp服务器后,只能访问它自己的家目录下的内容. 实现 因为sftp是ssh服务自 ...
- macbook蓝牙pan未连接_蓝牙自动重连机制
蓝牙自动重连机制的原理分析 在日常使用蓝牙的过程中,想必大家都发现了这样一个现象:连接蓝牙设备的手机在关闭再重新打开蓝牙后,会自动连接上先前连接着的那个设备,同样的场景对于安卓车机系统效果也是一致的. ...
- python断网重联_Python实现WiFi断线自动重连的方法详解
实现 WiFi 断线自动重连,原理是用 Python 监测网络是否断线,如果断线则重启网络服务.接下来给大家分享实现代码,需要的朋友参考下 1.Python 代码 autowifi.py,放在 /ho ...
- python攻击某个wifi设备使断网_Python实现WiFi断线自动重连的方法详解
实现 WiFi 断线自动重连,原理是用 Python 监测网络是否断线,如果断线则重启网络服务.接下来给大家分享实现代码,需要的朋友参考下 1.Python 代码 autowifi.py,放在 /ho ...
- php项目如何导jdbc包,JDBC-idea导入mysql连接java的jar包(mac)的方法
前言 1.本文使用的是mysql8.0版本 与5.0版本相比:导包方式相同,后面代码中的注册驱动方式不同 1.mac与pc的idea菜单和图标不是完全相同,但是步骤是差不多的 下载对应版本的jar包 ...
最新文章
- 关于java和c的选择结构和循环结构
- 华为程序员发现孩子不是自己的!怒提离婚!但老婆只要房子车子!不要孩子!绿他的竟然是个酒吧混混!...
- 关于 Nuxt.js
- 重载和引用函数编程实验
- 【语言处理与Python】1.5自动理解自然语言
- 几种常见软件过程模型的比较
- 何为真正的 FaaS ?阿里舜天平台做了四大创新
- 前端动态获取servlet虚拟路径_Day40_Servletamp;HTTPamp;Request
- ulimit常用参数介绍
- 程序员工资倒挂,IT 行业薪资潜规则如何规避?
- C# 控制台 打印输出
- ​四周第一次课(4月11日)lvm讲解
- CentOS下ELK 7.2生产安全部署
- VC中CListCtrl设置滚动条在最下边的方法(MSDN中的例子)
- 新产品、新团队、新技术
- OGG工作原理(Oracle Golden Gate)
- 走进波分 -- 16.Optix OSN9800产品介绍
- android版本4.4.2导航,天敏D8+_rk3288_Android_4.4.2_kiui7_蓝光导航极速版
- python----根据共振峰频率绘制二阶谐振曲线
- GB2312和UTF-8
热门文章
- windows 程序设计 剪切板
- P2592 [ZJOI2008]生日聚会
- duang!京东瞬间成了一只受伤的狗!
- Unity3D编辑器扩展1——批量处理资源
- 计算机新闻学phd,哥伦比亚大学新闻学与计算机科学硕士研究生Offer及录取要求...
- 【Linux】进程控制 —— 进程创建/终止/等待
- iOS 仿链家筛选(单选、多选、滑动筛选联动、多表联动)
- lyft读音_我在Lyft的远程暑期实习
- 1. Polyspace工具基本介绍
- ACIS, Parasolid和OpenCASCADE比较