发表新帖

onClose回调中连接池MysqliProxy查询结果与预期不符且抛出MysqliException异常

### Swoole 4.6.6，php 8.0.3，Ubuntu 20.04
为了与现有框架融合，我对单个连接做了简易封装，出错涉及部分如下
```php
class Mysqli implements ConnectionInterface{
	private $mysqli; // \Mysqli或其代理的实例
	private \Swoole\Database\MysqliPool $pool;
	public function __construct($mysqli=NULL,\Swoole\Database\MysqliPool &$pool=NULL)
	{
		$this->mysqli=$mysqli;
		if(!is_null($pool)){
			$this->pool=$pool;
			echo '借到连接了',PHP_EOL;
		}
	}
	
	public function select(string $sql,array $where=[],string $fetch='object')
	{
		$sql='SELECT '.$sql.self::splicingWhere($where,$types,$params);
		try {
			$stmt=$this->mysqli->prepare($sql);
			if(!empty($types)) $stmt->bind_param($types,...$params);
			$stmt->execute();
			$res=$stmt->get_result();
			$stmt->close();
		} catch (\Throwable $th) {
			echo date('Y-m-d H:i:s'),substr(explode(' ',microtime())[0],1),'：结果异常',$sql,PHP_EOL,$th->getCode(),'：',$th->getMessage(),PHP_EOL;
			var_dump($types,$params);
			return $fetch=='all'?[]:NULL;
		}
		
		if(is_bool($res)){
			echo date('Y-m-d H:i:s'),substr(explode(' ',microtime())[0],1),'：布尔结果',$sql,PHP_EOL;
			var_dump($res,$types,$params);
			return $fetch=='all'?[]:NULL;
		}
		$props=[
			'count'=>'field_count', //总列数
			'rows'=>'num_rows', //总行数
			'len'=>'lengths', //当前行每一列的内容长度
		];
		if(isset($props[$fetch])) $ret=$res->{$props[$fetch]};
		elseif($fetch==='all'){
			$ret=[];
			for($i=0;$i<$res->num_rows;$i++){
				if($i>0) $res->data_seek($i);
				$ret[]=$res->fetch_object();
			}
		}elseif(in_array($fetch,['array','object'])) $ret=$res->{'fetch_'.$fetch}();
		else throw new \ForbiddenException('数据查询结果解析出错！');
		$res->free();
		return $ret;
	}
	
    private static function checkType($v)
    {
        if(is_integer($v)) return 'i';
        if(is_numeric($v)) return 'd';
        if(is_bool($v)) return 'b';
        return 's';
    }
	//拼接where语句
	private static function splicingWhere(array $where,?string &$types,?array &$params)
	{
		if(!isset($types,$params)){
			$types='';
			$params=[];
		}
		$fields=[];
		foreach($where AS $k => $v){
			if(strpos($k,'`')===FALSE) $k='`'.$k.'`';
			$fields[]=$k.' = ?';
			$params[]=$v;
			$types.=self::checkType($v);
		}
		return ' '.implode(' AND ',$fields);
	}
	
	public function __destruct()
	{
		if(isset($this->pool)){
			echo '连接已归还',PHP_EOL;
			$this->pool->put($this->mysqli);
		}
	}
}
```
在onClose事件中，需要更新用户连接的结束时间，删除fd相关数据等操作，出错部分如下
```php
$server->on('close',function($ws,int $fd)use(&$DBPool){
	echo date('Y-m-d H:i:s'),substr(explode(' ',microtime())[0],1),'：',$fd,'断开了',PHP_EOL;
	$db=new \App\DB\Mysqli($DBPool->get(),$DBPool);
	$connect=$db->select('`log_id` FROM `'.TB_SOCKET_ONLINE.'` WHERE',['fd'=>$fd]);
	$db->delete(TB_SOCKET_ONLINE,['fd'=>$fd]);
	if(is_null($connect)) return;
	......
});
```
### 变量$connect赋值的这一行偶发性出错
因此如第一段代码所示，我在查询的位置做了try/catch，发现出错时总是先发生$stmt->get_result()返回布尔值false，紧接着下一次查询就会抛出MysqliException，位置是MysqliProxy.php的第61行，我从git上下载了源文件，找到对应方法如下
```php
public function __call(string $name, array $arguments)
{
	for ($n = 3; $n--;) {
        $ret = @$this->__object->{$name}(...$arguments);
        if ($ret === false) {
            /* non-IO method */
            if (!preg_match(static::IO_METHOD_REGEX, $name)) {
                break;
            }
            /* no more chances or non-IO failures */
            if (!in_array($this->__object->errno, static::IO_ERRORS, true) || ($n === 0)) {
                throw new MysqliException($this->__object->error, $this->__object->errno); //这个位置抛出的异常
            }
            $this->reconnect();
            continue;
        }
        if (strcasecmp($name, 'prepare') === 0) {
            $ret = new MysqliStatementProxy($ret, $arguments[0], $this);
        } elseif (strcasecmp($name, 'stmt_init') === 0) {
            $ret = new MysqliStatementProxy($ret, null, $this);
        }
        break;
    }
    /* @noinspection PhpUndefinedVariableInspection */
    return $ret;
}
```
使人困惑的是，抛出的$this->__object->error是0，$this->__object->errno是空
日志内容如下：
```php
2021-04-27 11:07:12.06089200：548断开了
2021-04-27 11:07:12.06105500：504断开了
2021-04-27 11:07:12.06132400：布尔结果SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
bool(false)
string(1) "i"
array(1) {
  [0]=>
  &int(548)
}
2021-04-27 11:07:12.06169200：结果异常SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
0：
string(1) "i"
array(1) {
  [0]=>
  int(504)
}
```
另外，封装的这个select方法在onOpen、onMessage、onRequest方法中都有应用，而且从没有出错过，就是在onClose方法中，具体概率还不确定，一般前500次以内就会出现。
### 所以，请问这是我逻辑涉及的问题，还是触发了某个底层的bug？

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

White

2021-04-27

White

2021-04-27

鲁飞回复 White

2021-04-27

鲁飞

2021-04-27

White 回复鲁飞

https://gist.github.com/warmbook/30308bb54a808225d8e396fac8fef63e

###以上代码刚刚试过，浏览器同时开了12个标签连服务器，跑了39秒开始异常

```php
2021-04-27 13:17:14.02235000：1连上了
借到连接了
连接已归还
2021-04-27 13:17:14.17065200：2连上了
借到连接了
连接已归还
2021-04-27 13:17:14.25505100：3连上了
借到连接了
连接已归还
2021-04-27 13:17:14.31725800：4连上了
借到连接了
连接已归还
2021-04-27 13:17:14.37752300：5连上了
借到连接了
连接已归还
2021-04-27 13:17:14.45636000：6连上了
借到连接了
连接已归还
2021-04-27 13:17:14.52829300：7连上了
借到连接了
连接已归还
2021-04-27 13:17:14.60347500：8连上了
借到连接了
连接已归还
2021-04-27 13:17:14.67017200：9连上了
借到连接了
连接已归还
2021-04-27 13:17:14.76496100：10连上了
借到连接了
连接已归还
2021-04-27 13:17:14.82076500：11连上了
借到连接了
连接已归还
2021-04-27 13:17:14.88020800：12连上了
借到连接了
连接已归还
2021-04-27 13:17:53.67400500：1断开了
借到连接了
2021-04-27 13:17:53.67428600：5断开了
借到连接了
2021-04-27 13:17:53.67440100：9断开了
借到连接了
2021-04-27 13:17:53.67461500：2断开了
借到连接了
2021-04-27 13:17:53.67478000：6断开了
借到连接了
2021-04-27 13:17:53.67551200：布尔结果SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
bool(false)
string(1) "i"
array(1) {
  [0]=>
  &int(2)
}
2021-04-27 13:17:53.67641600：结果异常SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
0：
string(1) "i"
array(1) {
  [0]=>
  int(1)
}
2021-04-27 13:17:53.67715500：布尔结果SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
bool(false)
string(1) "i"
array(1) {
  [0]=>
  &int(6)
}
连接已归还
PHP Warning:  Wrong COM_STMT_PREPARE response size. Received 1 in @swoole-src/library/core/Database/MysqliProxy.php on line 53
2021-04-27 13:17:53.67778800：结果异常SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
0：
string(1) "i"
array(1) {
  [0]=>
  int(5)
}
2021-04-27 13:17:53.67911100：10断开了
借到连接了
2021-04-27 13:17:53.67972700：3断开了
借到连接了
连接已归还
连接已归还
连接已归还
连接已归还
连接已归还
2021-04-27 13:17:53.68155200：7断开了
借到连接了
连接已归还
2021-04-27 13:17:53.68206900：11断开了
借到连接了
2021-04-27 13:17:53.68269000：4断开了
借到连接了
连接已归还
连接已归还
连接已归还
2021-04-27 13:17:53.68433000：8断开了
借到连接了
2021-04-27 13:17:53.68520700：12断开了
借到连接了
连接已归还
连接已归还
2021-04-27 13:17:53.74811100：13连上了
借到连接了
连接已归还
2021-04-27 13:17:53.82346000：14连上了
借到连接了
连接已归还
2021-04-27 13:17:53.88949700：15连上了
借到连接了
连接已归还
2021-04-27 13:17:53.93651000：16连上了
借到连接了
连接已归还
2021-04-27 13:17:53.99023700：17连上了
借到连接了
连接已归还
2021-04-27 13:17:54.05569400：18连上了
借到连接了
连接已归还
2021-04-27 13:17:54.10877000：19连上了
借到连接了
连接已归还
2021-04-27 13:17:54.16110100：20连上了
借到连接了
连接已归还
2021-04-27 13:17:54.21979300：21连上了
借到连接了
连接已归还
2021-04-27 13:17:54.28680700：22连上了
借到连接了
连接已归还
2021-04-27 13:17:54.34853500：23连上了
借到连接了
连接已归还
2021-04-27 13:17:54.40115700：24连上了
借到连接了
连接已归还
2021-04-27 13:18:33.67441800：13断开了
借到连接了
2021-04-27 13:18:33.67465300：17断开了
借到连接了
2021-04-27 13:18:33.67474800：21断开了
借到连接了
2021-04-27 13:18:33.67495000：14断开了
借到连接了
2021-04-27 13:18:33.67508500：18断开了
借到连接了
2021-04-27 13:18:33.67517700：22断开了
借到连接了
2021-04-27 13:18:33.67572500：布尔结果SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
bool(false)
string(1) "i"
array(1) {
  [0]=>
  &int(14)
}
2021-04-27 13:18:33.67594800：布尔结果SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
bool(false)
string(1) "i"
array(1) {
  [0]=>
  &int(18)
}
2021-04-27 13:18:33.67684900：结果异常SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
0：
string(1) "i"
array(1) {
  [0]=>
  int(13)
}
PHP Warning:  Wrong COM_STMT_PREPARE response size. Received 1 in @swoole-src/library/core/Database/MysqliProxy.php on line 53
2021-04-27 13:18:33.67704800：结果异常SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
0：
string(1) "i"
array(1) {
  [0]=>
  int(17)
}
PHP Warning:  Wrong COM_STMT_PREPARE response size. Received 1 in @swoole-src/library/core/Database/MysqliProxy.php on line 53
2021-04-27 13:18:33.67716500：结果异常SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
0：
string(1) "i"
array(1) {
  [0]=>
  int(21)
}
2021-04-27 13:18:33.67734300：布尔结果SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
bool(false)
string(1) "i"
array(1) {
  [0]=>
  &int(22)
}
2021-04-27 13:18:33.67849300：15断开了
借到连接了
2021-04-27 13:18:33.67872700：19断开了
借到连接了
2021-04-27 13:18:33.67934400：布尔结果SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
bool(false)
string(1) "i"
array(1) {
  [0]=>
  &int(19)
}
2021-04-27 13:18:33.68064300：23断开了
借到连接了
2021-04-27 13:18:33.68074400：布尔结果SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
bool(false)
string(1) "i"
array(1) {
  [0]=>
  &int(23)
}
2021-04-27 13:18:33.68169600：16断开了
借到连接了
连接已归还
连接已归还
连接已归还
连接已归还
连接已归还
2021-04-27 13:18:33.68287700：20断开了
借到连接了
2021-04-27 13:18:33.68305800：24断开了
借到连接了
连接已归还
连接已归还
连接已归还
连接已归还
连接已归还
连接已归还
连接已归还
2021-04-27 13:18:33.74659100：25连上了
借到连接了
连接已归还
2021-04-27 13:18:33.81211200：26连上了
借到连接了
连接已归还
2021-04-27 13:18:33.87916800：27连上了
借到连接了
连接已归还
2021-04-27 13:18:33.93391300：28连上了
借到连接了
连接已归还
2021-04-27 13:18:33.97904500：29连上了
借到连接了
连接已归还
2021-04-27 13:18:34.03062500：30连上了
借到连接了
连接已归还
2021-04-27 13:18:34.09232900：31连上了
借到连接了
连接已归还
2021-04-27 13:18:34.14209700：32连上了
借到连接了
连接已归还
2021-04-27 13:18:34.19879800：33连上了
借到连接了
连接已归还
2021-04-27 13:18:34.28097600：34连上了
借到连接了
连接已归还
2021-04-27 13:18:34.34621300：35连上了
借到连接了
连接已归还
2021-04-27 13:18:34.40156500：36连上了
借到连接了
连接已归还
2021-04-27 13:19:13.67478000：25断开了
借到连接了
2021-04-27 13:19:13.67500500：29断开了
借到连接了
2021-04-27 13:19:13.67510100：33断开了
借到连接了
2021-04-27 13:19:13.67529000：26断开了
借到连接了
2021-04-27 13:19:13.67540900：30断开了
借到连接了
2021-04-27 13:19:13.67550100：34断开了
借到连接了
2021-04-27 13:19:13.67609600：27断开了
借到连接了
2021-04-27 13:19:13.67632100：布尔结果SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
bool(false)
string(1) "i"
array(1) {
  [0]=>
  &int(30)
}
2021-04-27 13:19:13.67722300：结果异常SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
0：
string(1) "i"
array(1) {
  [0]=>
  int(29)
}
2021-04-27 13:19:13.67748500：布尔结果SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
bool(false)
string(1) "i"
array(1) {
  [0]=>
  &int(33)
}
2021-04-27 13:19:13.67834900：结果异常SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
0：
string(1) "i"
array(1) {
  [0]=>
  int(34)
}
2021-04-27 13:19:13.67867200：31断开了
借到连接了
2021-04-27 13:19:13.67949100：布尔结果SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
bool(false)
string(1) "i"
array(1) {
  [0]=>
  &int(31)
}
2021-04-27 13:19:13.67990700：35断开了
借到连接了
连接已归还
连接已归还
2021-04-27 13:19:13.68145800：28断开了
借到连接了
2021-04-27 13:19:13.68154600：32断开了
借到连接了
2021-04-27 13:19:13.68173100：36断开了
借到连接了
2021-04-27 13:19:13.68297200：结果异常SELECT `log_id` FROM `socket_online` WHERE `fd` = ?
0：
string(1) "i"
array(1) {
  [0]=>
  int(28)
}
连接已归还
连接已归还
连接已归还
连接已归还
连接已归还
连接已归还
连接已归还
连接已归还
连接已归还
2021-04-27 13:19:13.76246900：37连上了
借到连接了
连接已归还
2021-04-27 13:19:13.81702400：38连上了
借到连接了
连接已归还
2021-04-27 13:19:13.87938900：39连上了
借到连接了
连接已归还
2021-04-27 13:19:13.96158700：40连上了
借到连接了
连接已归还
2021-04-27 13:19:14.02427300：41连上了
借到连接了
连接已归还
2021-04-27 13:19:14.08349000：42连上了
借到连接了
连接已归还
2021-04-27 13:19:14.14476300：43连上了
借到连接了
连接已归还
2021-04-27 13:19:14.20217700：44连上了
借到连接了
连接已归还
2021-04-27 13:19:14.25786600：45连上了
借到连接了
连接已归还
2021-04-27 13:19:14.31878300：46连上了
借到连接了
连接已归还
2021-04-27 13:19:14.37313100：47连上了
借到连接了
连接已归还
2021-04-27 13:19:14.43209300：48连上了
借到连接了
连接已归还
```
###麻烦了/(ㄒoㄒ)/~~

2021-04-28

White 回复鲁飞

2021-04-30

鲁飞回复 White

2021-04-30

White 回复鲁飞

2021-07-07

White 回复鲁飞