mysql连接池在数据库重启后失效的解决方法
在swooledistributed 3中，如果使用官方提供的mysql连接池，数据库重启后，所有连接可能失效。导致这个问题的原因可能是由于底层重连逻辑存在问题。
以下是解决方法：
修改重连代码：
$result = $client->connect($set);if (!$result) { // 创建新的客户端并重试连接 $client = new swoolecoroutinemysql(); $result = $client->connect($set);}
通过此修改，如果重连失败，程序会创建一个新的客户端并重新尝试连接。
setdefer值问题：
确保重连时将setdefer值设置为false，因为事务不允许设置此值。
$client->setdefer(false);
示例代码：
/** * @param $sql * @param null $client * @param MySqlCoroutine $mysqlCoroutine * @return mixed * @throws Throwable */public function query($sql, $client = null, MySqlCoroutine $mysqlCoroutine){ $notPush = false; $delayRecv = $mysqlCoroutine->getDelayRecv(); if ($client == null) { $client = $this->pool_chan->pop(); $client->setDefer($delayRecv); } else {//这里代表是事务 $notPush = true; //事务不允许setDefer $delayRecv = false; $client->setDefer($delayRecv); } if (!$client->connected) { $set = $this->config['mysql'][$this->active]; $result = $client->connect($set); if (!$result) { // 创建新的客户端并重试连接 $client = new SwooleCoroutineMySQL(); $result = $client->connect($set); if (!$result) { $this->pushToPool($client); $errcode = $client->errno ?? ''; $mysqlCoroutine->getResult(new SwooleException(sprintf("err:%s,code:%s", $client->connect_error, $errcode))); //在这里报的错 } } } // ...}
以上就是SwooleDistributed 3中，MySQL连接池如何解决数据库重启后连接失效的问题？的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1248938.html
微信扫一扫 
支付宝扫一扫 
