gearman中worker常驻后台,导致MySQL server has gone away的解决方法

吾爱主题 阅读:133 2021-09-30 13:34:00 评论:0

本文实例讲述了gearman中worker常驻后台,导致MySQL server has gone away的解决方法。分享给大家供大家参考,具体如下:

产生这个原因主要有如下几点:

  1. 1mysql服务宕机了
  2. 2、长时间没有操作,超过了wait_timeout的设置,mysql自动断开
  3. 3mysql请求链接被主动kill
  4. 4、发送的请求或返回结果过大,可设置max_allowed_packet的值
  5. 5、程序中你都是通过单例来操作数据库,如果两个操作时间超过wait_timeout

为了演示的方便,设置wait_timeout时间为10秒

  1. > set global wait_timeout=10;
  2. > show global variables like 'wait_timeout';

worker.php代码如下:

  1. <?php
  2. //创建一个worker
  3. $worker = new GearmanWorker();
  4. //添加一个job服务
  5. $worker->addServer('127.0.0.1', 4730);
  6. //注册一个回调函数,用于业务处理
  7. $worker->addFunction('longTime', function($job) {
  8. //workload()获取客户端发送来的序列化数据
  9. $data = json_decode($job->workload(), true);
  10.  
  11. $db = new mysqli('192.168.1.100', 'root', '', 'test');
  12. if($db->connect_error) {
  13. die('connect error');
  14. }
  15.  
  16. //等待15秒,我们设置mysql的wait_timeout为10秒
  17. sleep(15);
  18.  
  19. //当执行到这里时,因为超时,所以mysql自动把连接断开了
  20. $ret = $db->query("INSERT INTO test VALUES(NULL, {$data['title']}, {$data['content']});");
  21. if($ret) {
  22. return "插入成功\n";
  23. }
  24. });
  25.  
  26. //死循环
  27. //等待job提交的任务
  28. while($worker->work());

client.php代码如下:

  1. <?php
  2. //创建一个客户端
  3. $client = new GearmanClient();
  4. //添加一个job服务
  5. $client->addServer('127.0.0.1', 4730);
  6.  
  7. //doNormal同步
  8. $ret = $client->doNormal('longTime', json_encode(array(
  9. 'title' => '我是标题',
  10. 'content' => '我是内容',
  11. )));
  12.  
  13. echo $ret;

执行的结果如下图所示,出现了MySQL server has gone away的情况。

一般的解决方法:

1、调大wait_timeout的值(不建议)
2、每次在操作数据库的时候,ping()一下,如果断开就重新连。
3、在wait_timeout时间间隔之内,我们时不时的去query('select 1+1');一下,让mysql知道连接还活着。

修改worker.php代码如下:

  1. <?php
  2. //创建一个worker
  3. $worker = new GearmanWorker();
  4. //添加一个job服务
  5. $worker->addServer('127.0.0.1', 4730);
  6. //注册一个回调函数,用于业务处理
  7. $worker->addFunction('longTime', function($job) {
  8. //workload()获取客户端发送来的序列化数据
  9. $data = json_decode($job->workload(), true);
  10.  
  11. $db = new mysqli('192.168.1.100', 'root', '', 'test');
  12. if($db->connect_error) {
  13. die('connect error');
  14. }
  15.  
  16. //等待15秒,我们设置mysql的wait_timeout为10秒
  17. sleep(15);
  18.  
  19. //ini_set('mysqli.reconnect', 1);
  20. //php手册上说,ping会尝试重新连接,但现实是并不会
  21. //$db->ping();
  22.  
  23. if(!$db->ping()) {
  24. $db->close();
  25. //重新连接数据库
  26. $db = new mysqli('192.168.1.100', 'root', '', 'test');
  27. }
  28.  
  29. $ret = $db->query("INSERT INTO test VALUES(NULL, '{$data['title']}', '{$data['content']}');");
  30. if($ret) {
  31. return "插入成功\n";
  32. }
  33. });
  34.  
  35. //死循环
  36. //等待job提交的任务
  37. while($worker->work());

运行结果如下:

希望本文所述对大家PHP程序设计有所帮助。

原文链接:https://www.cnblogs.com/jkko123/p/6505987.html

可以去百度分享获取分享代码输入这里。
声明

1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,请转载时务必注明文章作者和来源,不尊重原创的行为我们将追究责任;3.作者投稿可能会经我们编辑修改或补充。

【腾讯云】云服务器产品特惠热卖中
搜索
标签列表
    关注我们

    了解等多精彩内容