发表新帖

$ws-&gt;connections 异常无法遍历

### 问题描述
在WebSocket Server对象 的 $ws->connections 刚开始连接时可以foreach出来，但是如果服务器主动关闭客户端，如telnet 那个WebSocket Server，随便输入入几个字服务器会主动关闭。这种情况下，在on message 中就无法遍历出来connections,但是count($ws->connections)是有值的，其它没关闭的客户端还可以通讯。

### Swoole版本，PHP版本，以及操作系统版本信息
Swoole版本 v4.5.8 
PHP版本 7.4.10
操作系统版本 CentOS 7.8

### 相关代码
```php
<?php
//创建WebSocket Server对象，监听0.0.0.0:10086端口
$ws = new Swoole\WebSocket\Server('0.0.0.0', 10086);
//监听WebSocket连接打开事件
$ws->on('open', function ($ws, $request) {
   // var_dump($request->fd, $request->server);
   //$ws->push($request->fd, "hello, welcome\n");
});

//监听WebSocket消息事件
$ws->on('message', function ($ws, $frame) {
    echo "Message: {$frame->data}\n";
	foreach ($ws->connections as $fd) {
		echo "fd:",$fd,"\n";
	}
	echo "connections:",count($ws->connections),"\n";
    $ws->push($frame->fd,json_encode(array("server"=>"ok")));
});

//监听WebSocket连接关闭事件
$ws->on('close', function ($ws, $fd) {
    echo "client-{$fd} is closed\n";
});

$ws->start();
 ?>
```

### 你期待的结果是什么？实际看到的错误信息又是什么？
期待的结果是 echo "fd:",$fd,"\n";这里可以输出结果，但是一有客户端关闭，那个地方代码就不执行了,下面是输出的结果：

Message: {"type":"ping","data":"2020-12-19 20:35:38"}
fd:1
connections:1
Message: {"name":"aaa","type":"bind"}
fd:1
fd:2
connections:2
Message: {"type":"ping","data":"2020-12-19 20:35:48"}
fd:1
fd:2
connections:2
client-3 is closed  //这个客户端关闭后，后面的fd就遍历不出来了
Message: {"type":"ping","data":"2020-12-19 20:36:18"}
connections:2
Message: {"type":"ping","data":"2020-12-19 20:36:28"}
connections:2
Message: {"type":"ping","data":"2020-12-19 20:36:38"}

找了半天原因，应该是你们源码逻辑出错了

// find the new max_fd
        for (; serv->is_valid_connection(serv->get_connection(find_max_fd)) && find_max_fd > serv->get_minfd();
             find_max_fd--) {
            // pass
        }

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

略

### Swoole版本，PHP版本，以及操作系统版本信息
Swoole版本 v4.5.8 
PHP版本 7.4.10
操作系统版本 CentOS 7.8

//监听WebSocket连接关闭事件
$ws->on('close', function ($ws, $fd) {
    echo "client-{$fd} is closed\n";
});

$ws->start();
 ?>
```

找了半天原因，应该是你们源码逻辑出错了

// find the new max_fd
        for (; serv->is_valid_connection(serv->get_connection(find_max_fd)) && find_max_fd > serv->get_minfd();
             find_max_fd--) {
            // pass
        }