本文主要是介绍-----关于数据库出现的“ERROR 2006 :MySQL server has gone away“,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
1 分析
关于出现这种情况,原因可能有许多中:
- 1)有可能是传送的数据太大(例如使用insert … values的语句过长, 这种情况可以通过修改max_allowed_packed的配置参数来避免,也可以在程序中将数据分批插入(使用mysql limit进行分页,循环分批处理数据))。
- 2)有可能是应用程序(比如PHP)长时间的执行批量的MYSQL语句。
- 3)有可能是执行一个SQL,但SQL语句过大或者语句中含有BLOB或者LONGBLOB字段。比如,图片数据的处理。都容易引起MySQL server has gone away。
- 4)有可能是程序中某两次操作数据库的间隔时间超过了wait_timeout,导致数据库服务器主动关闭了该连接,此时你再查询就会报这个错误。例如你使用单例模式进行连接数据库,但是本次操作距离上一次的时间超过wait_timeout。
对于上面的错误的解决方法,我只具体讲我本次遇到的问题,也是经常遇到的问题,即可能性的第4点。
2 解决上面问题的第4点
2.1 程序产生错误的示例截图
这是我程序中报出MySQL server has gone away的错误,因为我的程序对数据库操作不算频繁只能说是刚刚好,但是多次排查,发现程序一个多小时,或者4-6个小时左右就会报出下面的错误。然后我就接着往下排查。
2.2 查看wait_timeout超时时长
接着上面,因为数据库经常几个小时就查询失败,所以应该和服务器宕机这些问题没啥关系,所以我们猜从超时入手。所以我们可以查看超时时长,确定是否是因为它的原因。可以看到,我的是300s,有些是28800。看到300,基本确定是问题4的原因造成的了,因为我的程序基本每隔一两分钟就会操作,有时候没事件触发就不会,需要根据自己的程序判断。
2.3 编写示例代码
编写该示例代码,我们解决这个错误可以将wait_timeout从300s增加,但毕竟不是长久之计,所以我们必须从代码中解决,下面我自己给出两种方法,一种是手动重连,一种是自动重连,用到的方法都是使用ping函数。我们可以根据重连前后的线程id去观察现象。
- 1)手动重连的方法。
#include <iostream>
#include "MysqlSingleton.h"
#include <mutex>
#include <thread>int main(){int ret = -1;MysqlSingleton *ins = MysqlSingleton::GetInstance();ins->Sql_Connect("192.168.1.1", "root", "123456", "test", 3306, 6);//模拟最近一次操作数据库if((ret = ins->Sql_Update("UPDATE table_test SET status = 22 WHERE channels = \"aaabbb\";")) != 0){std::cout << "ret=" << ret << std::endl;}int i = 0;while(1){std::cout << "Sleep..." << std::endl;//模拟wait_timeout没事件触发数据库的操作std::this_thread::sleep_for(std::chrono::milliseconds(300020));char sql[512] = {0};//int ret1 = ins->Sql_ReconnectWithAuto();//std::cout << "ret1=" << ret1 << std::endl;sprintf(sql, "UPDATE table_test SET status = %d WHERE channels = \"aaabbb\";", i++);ret = ins->Sql_Update(sql);if(ret != 0){std::cout << "ret=" << ret << std::endl;if(ret == 2006){if(ins->Sql_ReconnectWithHand("192.168.1.1", "root", "123456", "test", 3306, 6) == 0){ret = ins->Sql_Update(sql);std::cout << "ret=" << ret << std::endl;}}}}return 0;
}
其中,手动重连的函数代码如下,但是需要注意:
- 1)手动重连也必须要用ping函数去判断连接是否正常。
- 2)手动重连的步骤其实就是,把之前的连接先关闭,然后再重新连接一次,不过重连时可以不需要再次初始化。即我们可以直接调用mysql_real_connect函数,无需再调用mysql_init函数。
/*Mysql重连方法2:若没有设置选项mysql_options自动重连,可以调用该接口手动重连。
*/
int MysqlSingleton::Sql_ReconnectWithHand(const char* hostName, const char* user, const char* pwd, const char* database, uint32 port, uint32 timeout){printf("mysql_thread_id=%d in hand.\n", mysql_thread_id(&m_mysql));if((mysql_ping(&m_mysql)) != 0){//return mysql_errno(&m_mysql);Sql_FreeConnect();//手动重连必须关闭后再重连.还需要再初始化吗?可以不需要if (!(mysql_real_connect(&m_mysql, hostName, user, pwd, database, port, NULL, 0))) {return mysql_errno(&m_mysql);}}printf("mysql_thread_id=%d in hand.\n", mysql_thread_id(&m_mysql));return 0;
}
结果可以看到,重连前后确实线程id是改变的,并且重新更新数据也是成功的。
- 2)自动重连的方法。自动重连比手动重连效果好,因为ping函数可以帮你实现自动重连,实现自动重连很简单,只需要在初始化的函数之后,连接的函数之前设置自动重连的选项即可。注意:很多人以为只是调用ping函数就可以实现重连,实际上不是,还差一步,即设置重连选项。
看代码:
首先设置reconnect选项。
然后调用ping函数即可,若掉线,ping函数会帮你重连,而不再需要像上面需要ping一次检查是否掉线,若掉线需要关闭再连接。
#include <iostream>
#include "MysqlSingleton.h"
#include <mutex>
#include <thread>int main(){int ret = -1;MysqlSingleton *ins = MysqlSingleton::GetInstance();ins->Sql_Connect("192.168.1.1", "root", "123456", "test", 3306, 6);//模拟最近一次操作数据库if((ret = ins->Sql_Update("UPDATE table_test SET status = 22 WHERE channels = \"aaabbb\";")) != 0){std::cout << "ret=" << ret << std::endl;}int i = 0;while(1){std::cout << "Sleep..." << std::endl;//模拟wait_timeout没事件触发数据库的操作std::this_thread::sleep_for(std::chrono::milliseconds(300020));char sql[512] = {0};int ret1 = ins->Sql_ReconnectWithAuto();std::cout << "ret1=" << ret1 << std::endl;sprintf(sql, "UPDATE table_test SET status = %d WHERE channels = \"aaabbb\";", i++);ret = ins->Sql_Update(sql);std::cout << "ret=" << ret << std::endl;if(ret != 0){std::cout << "ret=" << ret << std::endl;if(ret == 2006){if(ins->Sql_ReconnectWithHand("192.168.1.1", "root", "123456", "test", 3306, 6) == 0){ret = ins->Sql_Update(sql);std::cout << "ret=" << ret << std::endl;}}}}return 0;
}
自动重连函数的代码:
/*Mysql重连方法1:该函数必须设置了选项mysql_options自动重连。
*/
int MysqlSingleton::Sql_ReconnectWithAuto(){printf("mysql_thread_id=%d in auto.\n", mysql_thread_id(&m_mysql));//判断重连前后的数据库线程id的区别,判断是否重连成功,若断开之后(即调用ping之前)能获取tid成功吗?下图看到是能的if((mysql_ping(&m_mysql)) != 0){//检查与数据库服务器是否断开连接,只要设置了重连选项调用ping就会自动重连。printf("Server connect dropped.\n");return mysql_errno(&m_mysql);}printf("mysql_thread_id=%d in auto.\n", mysql_thread_id(&m_mysql));return 0;
}
结果可以看到,自动重连貌似不线程id可能会改变,也可能不改变,这个不需要关心,反正我们关心的是超过wait_timeout后,ping已经帮我们自动重连了,因为再次更新数据库返回值为0代表成功。
下图更清晰的看到,第一次线程id没有改变,第二次改变了。
下图是之前因为我printf打印的时候没有添加\n。
这篇关于-----关于数据库出现的“ERROR 2006 :MySQL server has gone away“的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!