发表新帖

问一个 websocket 的问题

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

2020-04-20

鲸落

Server 端：
    
    <?php
    
    //创建websocket服务器对象，监听0.0.0.0:9502端口
    $ws = new Swoole\WebSocket\Server("0.0.0.0", 9502);
    
    $process = new \Swoole\Process(function (\Swoole\Process $process) use ($ws) {
        $socket = $process->exportSocket();
        while (true) {
            $msg = $socket->recv();
            foreach ($ws->connections as $connection) {
                $ws->push($connection, $msg);
            }
        }
    }, false, 2, 1);
    
    $ws->addProcess($process);
    
    //监听WebSocket连接打开事件
    $ws->on('open', function ($ws, $request) {
        var_dump($request->fd, $request->get, $request->server);
        $ws->push($request->fd, "hello, welcome\n");
    });
    
    //监听WebSocket消息事件
    $ws->on('message', function ($ws, $frame) use($process) {
        $socket = $process->exportSocket();
        $socket -> send($frame->data);
        echo "Message: {$frame->data}\n";
        $ws->push($frame->fd, "server: {$frame->data}");
    });
    
    //监听WebSocket连接关闭事件
    $ws->on('close', function ($ws, $fd) {
        echo "client-{$fd} is closed\n";
    });
    
    $ws->start();

client端：

<?php
    go(function () {
        $client = new Swoole\Coroutine\Http\Client("127.0.0.1", 9502);
        $ret = $client->upgrade("/");
        var_dump($ret);
        if ($ret) {
            while(true) {
                var_dump($client->push("hello"));
                var_dump($client->recv());
                co::sleep(1);
            }
        }
    });
    
本地测试了是没有啥问题的，你可以试一下

2020-04-22

nicoi 回复鲸落