发表新帖

协程Websocket服务器如何发送广播？

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

Pty

登录后参与评论

2020-08-12

桶

桶哥

2020-08-12

Pty 回复桶哥

2020-12-30

偎徕回复桶哥

2020-08-13

鲁飞

```php
function getObjectId(\Swoole\Http\Response $response) {
    if (PHP_VERSION_ID < 70200) {
        $id = spl_object_hash($response);
    } else {
        $id = spl_object_id($response);
    }
    return $id;
}

Co\run(function () {
    $server = new Co\Http\Server("127.0.0.1", 9501, false);
    $server->handle('/websocket', function ($request, $ws) {
        $ws->upgrade();
        global $wsObjects;
        $wsObjects[getObjectId($ws)] = $ws;
        while (true) {
            $frame = $ws->recv();
            if ($frame->data == '') {
                unset($wsObjects[getObjectId($ws)]);
                $ws->close();
                break;
            } else if ($frame->data === false) {
                echo "error : " . swoole_last_error() . "\n";
                break;
            } else {
                if ($frame->data == "close") {
                    unset($wsObjects[getObjectId($ws)]);
                    $ws->close();
                    return;
                }
                foreach ($wsObjects as $obj) {
                    $obj->push("Server：{$frame->data}");
                }
            }
        }
    });
    $server->start();
});

```