发表新帖

SwooleDistributed 3 mysql连接池在数据库重启后全部失效，然后重连时报2006 Connection refused错误怎么解决？

### 问题描述

说来就蛋疼了，这个SwooleDistributed 3的框架在我开发项目之前就已经停止更新了，上面让用这个框架开发这个项目。现在的问题是我的mysql连接是使用了官方说的异步连接池进行的，然后数据库重启后，连接池全挂。可以看到底层逻辑是会进行重连的，但是报如 Connection refused 2006 的数据库连接错误，请问大神们这到底是mysql的问题，还是框架程序的问题？

### Swoole版本，PHP版本，以及操作系统版本信息
运行是用docker 容器，镜像是 lenkaren/php-swoole:latest
进入镜像看到的信息是：
"PHP_VERSION=7.1.14",
"SWOOLE_VERSION=4.1.2",

### 相关代码
```php
 /**
     * @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) {
                $this->pushToPool($client);
                $errcode = $client->errno ?? '';
				//接下来就报错
                $mysqlCoroutine->getResult(new SwooleException(sprintf("err:%s,code:%s", $client->connect_error, $errcode)));
            }
        }
        $res = $client->query($sql, $mysqlCoroutine->getTimeout() / 1000);
        if ($res === false) {
            $this->pushToPool($client);
            if ($client->errno == 110) {
                $mysqlCoroutine->onTimeOut();
            } else {
                $mysqlCoroutine->getResult(new SwooleException("[sql]:$sql,[err]:$client->error"));
            }
        }
        $mysqlCoroutine->destroy();
        if ($delayRecv)//延迟收包
        {
            $data['delay_recv_fuc'] = function () use ($client) {
                $res = $client->recv();
                $data['result'] = $res;
                $data['affected_rows'] = $client->affected_rows;
                $data['insert_id'] = $client->insert_id;
                $data['client_id'] = $client->id;
                $this->pushToPool($client);
                return $data;
            };
            return new MysqlSyncHelp($sql, $data);
        }
        $data['result'] = $res;
        $data['affected_rows'] = $client->affected_rows;
        $data['insert_id'] = $client->insert_id;
        $data['client_id'] = $client->id;
        if (!$notPush) {
            $this->pushToPool($client);
        }
        return new MysqlSyncHelp($sql, $data);
    }
```

### 你期待的结果是什么？实际看到的错误信息又是什么？

发布于3年前 · 17 次浏览 · 来自提问