发表新帖

$ws为何获取不到数据

### 问题描述
**[20-Oct-2020 08:50:21 UTC] PHP Warning:  Swoole\Http\Response::recv(): fd[975] is not a websocket conncetion**
请问一下下面代码 $ws为何获取不到数据。另外请问一下下面代码是否正确。小白实在感谢

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

### 相关代码
```php

<?php

Co::set([
    'hook_flags'=> SWOOLE_HOOK_ALL,
    'socket_timeout' => 8,
    'daemonize' => 1,
    'max_coroutine' => 500000
]);
Co\run(function (){
    $server = new Co\Http\Server("0.0.0.0", 9501, false);
    $chan = new Swoole\Coroutine\Channel(10);

$server->handle('/', function ($request, $ws) use ($chan) {
        $ws->upgrade();
        global $wsObjects;
        $wsObjects[getObjectId($ws)] = $ws;
        $i = 0;
        while (true) {
            $frame = $ws->recv();
            if (!isset($frame->opcode)) {
                $ws->close();
                break;
            }
            elseif ($frame->opcode === 9) {
                $pFrame = new Swoole\WebSocket\Frame;
                $pFrame->opcode = 10;
                $ws->push($pFrame);
            }
            elseif ($frame->opcode === 8) {
                $ws->close();
                break;
            }
            elseif ($frame === '' or $frame->data === '') {
                $ws->close();
                break;
            }
            elseif ($frame === false) {
                echo "error : " . swoole_last_error() . "\n";
                break;
            }
            else {
                if ($frame->data == 'close') {
                    $ws->close();
                    return;
                }
                parse_str($frame->data, $arr);
                if (isset($arr['UDID']) && isset($arr['matchid'])) {
                   go(function() use ($chan, $frame, $arr) {
                        $chan->push(['k' => 'mid:'.$arr['matchid'].':ios', 'v' => $arr['UDID']]);
                    });
                }
                elseif (isset($arr['android_id']) && isset($arr['matchid'])) {
                    go(function() use ($chan, $frame, $arr) {
                        $chan->push(['k' => 'mid:'.$arr['matchid'].':android', 'v' => $arr['android_id']]);
                    });
                }

go(function() use ($chan) {
                    $redis = new Redis();
                    $redis->connect('127.0.0.1', 6379);

$data = $chan->pop();
                    if (isset($data['k'])) {
                        $redis->sadd($data['k'], $data['v']);
                    }
                });
                for($i=0;$i<2;$i++) {
                   $ws->push("fd: ".$frame->fd. "this is test message:".rand(1000, 9999), 2);
                }
            }
        }
    });
    $server->start();
});

```

### 你期待的结果是什么？实际看到的错误信息又是什么？
正常连接数十万的socket连接

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