swoolewebSocketServer广播问题

protected function execute(Input $input, Output $output)

    {



        $this->server = new \swoole_websocket_server('0.0.0.0', 10000);

        $this->server->set([

            /**

             *  设置启动的worker进程数

             *  业务代码是全异步非阻塞的，这里设置为CPU的1-4倍最合理

             *  业务代码为同步阻塞，需要根据请求响应时间和系统负载来调整

             */

            'worker_num' => 4,

            // 守护进程化

            'daemonize'  => false,

            // 监听队列的长度

            'backlog'    => 128

        ]);

        $this->server->on('Open', [$this, 'onOpen']);

        $this->server->on('Message', [$this, 'onMessage']);

        $this->server->on('Close', [$this, 'onClose']);

        $this->server->start();

    }



    public function onOpen(\swoole_websocket_server $server, \swoole_http_request $request)

    {

        echo "server: handshake success with fd{$request->fd}\n";

    }



    // 收到数据时回调函数

    public function onMessage(\swoole_websocket_server $server, \swoole_websocket_frame $frame)

    {

        //echo sizeof($server->connections);

        //echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";



        foreach ($server->connections  as $fd) {

            echo "push data to".$fd."\n";

            //$this->server->push($fd,$frame->data);

        }



    }



    // 连接关闭时回调函数

    public function onClose($server, $fd)

    {

        echo "client {$fd} closed\n";

    }