为了账号安全,请及时绑定邮箱和手机立即绑定

swoole websocket服务进行mysql断线重连不生效的问题

swoole websocket服务进行mysql断线重连不生效的问题

PHP
拉莫斯之舞 2019-03-06 13:04:11
代码结构大致是这样的: <?php class server { private $server; private $conn = null; public function __construct() { if (!$this->initDb()) exit("终止启动\n"); //连接数据库 $this->server = new swoole_websocket_server('111.111.111.111', 1234); //实例化server //消息 $this->server->on('message', function (swoole_websocket_server $server, $frame) { //这里使用数据库连接$conn }); //work进程开启 $this->server->on('workerStart', function (swoole_websocket_server $server, $worker_id) { if ($worker_id == 0) { // 每10秒检测一次数据库连接 $server->tick(10 * 1000, function ($timer_id) { if (!$this->conn->ping()) { echo "数据库已断开!正在尝试重新连接...\n"; $this->initDb(); //连接数据库 } }); } }); $this->server->start(); } // 连接数据库 private function initDb() { $conn = new mysqli('127.0.0.1', 'root','root','test', 3306); if ($conn->connect_errno) { printf("数据库连接失败: %s\n", $conn->connect_error); return false; } else { $conn->set_charset("utf8"); echo "连接数据库成功!\n"; $this->conn = $conn; return true; } } } new server(); 每十秒检测mysql连接状态,如果断开连接则重新走initDb,this->$conn重新赋值。 然后我手动重启数据库,程序检测到数据库断开之后进行重连,并且连接成功。 但是当接收到消息事件使用$conn时,却还是提示mysql server has gone away,明明已经重新连接了啊。 我猜想,是不是因为swoole server在注册事件时就绑定了所使用到的变量,所以conn虽然重新赋值了,但是并没有生效到swoole server里?
查看完整描述

2 回答

  • 2 回答
  • 0 关注
  • 595 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信