发表新帖

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

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

Pty

2020-08-12

桶

桶哥

2020-08-12

Pty 回复桶哥

2020-12-30

偎徕回复桶哥

2020-08-12

鲁飞

```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();
});

```

微信公众号

热门内容

暂无回复的问答

- CodeGalaxy K3s 轻量集群节点之间如何实现负载均衡

- 关于openssl CURL WARNING swSSL_connect: SSL_connect(fd=69) failed. Error: error:141A318A:SSL routines:tls_process_ske_dhe:dh key too small[1|394]

- 多个模型如何进行事务异常回退？

- websocket开启wss报错

- 协程tcp服务器如何使用多进程？recv()方法接收信息，打印出来的pid一直是同一个。没用使用到多进程啊。