swoole websocket协程服务端出现过多CLOSE_WAIT

发表新帖

偎徕

去年

### 问题描述
![](/storage/article-column/0ADYUAiHyFuDGpS8LzyD4e3oNOk8GcOTEDBh17dD.png)

协程不是自己会回收吗, 我这个 CLOSE_WAIT 有点多

### Swoole版本，PHP版本，以及操作系统版本信息

swoole4.4 php7,4  
### 相关代码
```php
请将代码粘贴至此处（请勿用截图）
    \Co\run(function () {
            $server = new \Co\Http\Server("0.0.0.0", '9501');
            //监听全网段地址、端口
            $server->handle('/websocket', function ($request, $ws) {
                $ws->upgrade();//向客户端发送websocket握手信息
                global $wsObjects;
                $objectId = spl_object_id($ws);
                $wsObjects[$objectId] = $ws;
                $cid = \Co::getCid();
                echo "Client: {$cid}connect\n";
                while (true) {
                    $frame = $ws->recv();
                    if ($frame === '' || $frame->data == 'close' ) {
                        unset($wsObjects[$objectId]);
                        $ws->close();
                        break;
                    } else if ($frame === false) {
                        unset($wsObjects[$objectId]);
                        $ws->close();
                        echo "error : " . swoole_last_error() . "\n";
                        break;
                    } else {
                        if ($frame->data == 'close' || get_class($frame) === \Swoole\WebSocket\CloseFrame::class) {
                            unset($wsObjects[$objectId]);
                            $ws->close();
                            return;
                        }
                        echo "receive from {$cid}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
                        $args = json_decode($frame->data,true);
                        switch($args['method']){
                            case 'mediaPush':
                                break;
                            case 'appInitPush':
                                break;
                            default:
                                unset($wsObjects[$objectId]);
                                $ws->close();
                                break;
                        }
                    }
                }
            });
            $server->start();
        });

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

2020-12-28

鲁飞

2020-12-28

偎徕回复鲁飞

2021-01-11

序冢回复偎徕