去掉task

zhoudw

2021-12-21 6f73a8496ee81f5d708cae320e8deea37fdc562e

 ws_server.php

@@ -22,9 +22,9 @@

        $this->server = new Swoole\WebSocket\Server($this->server_config['host'], $this->server_config['port']); // swoole连接
        $this->server->set([
            'task_worker_num'       => 8,
            'enable_coroutine'      => true,
            'task_enable_coroutine' => true,
            // 'task_worker_num'       => 8,
            // 'enable_coroutine'      => true,
            // 'task_enable_coroutine' => true,
            'max_conn'              => 100000,
        ]);
        $this->server->on('WorkerStart', function (Swoole\WebSocket\Server $server) {
@@ -45,23 +45,8 @@
        });

        $this->server->on('message', function (Swoole\WebSocket\Server $server, $frame) {
            $server->task($frame);
            // $ret = array('code' => 0, 'data' => null);
            // $msgData = $this->is_json($frame->data,true);
            // if($msgData){
            //     $frameData = $msgData;
            //     $this->dealMsg($frameData,$frame->fd);
            // }else{
            //     $ret['code'] = -1;
            //     $ret['msg'] = 'data is null or data no json';
            //     $server->push($frame->fd, json_encode($ret));
            //     return;
            // } 
        });

        $this->server->on('task', function ($server, $task) {
            // $server->task($frame);
            $ret = array('code' => 0, 'data' => null);
            $frame = $task->data;
            $msgData = $this->is_json($frame->data,true);
            if($msgData){
                $frameData = $msgData;
@@ -73,6 +58,21 @@
                return;
            } 
        });

        // $this->server->on('task', function ($server, $task) {
        //     $ret = array('code' => 0, 'data' => null);
        //     $frame = $task->data;
        //     $msgData = $this->is_json($frame->data,true);
        //     if($msgData){
        //         $frameData = $msgData;
        //         $this->dealMsg($frameData,$frame->fd);
        //     }else{
        //         $ret['code'] = -1;
        //         $ret['msg'] = 'data is null or data no json';
        //         $server->push($frame->fd, json_encode($ret));
        //         return;
        //     } 
        // });
        $this->server->on('close', function ($ser, $fd) {
            $host  = $this->server_config['allow_ip'];
            $this->redis->connect($this->redis_config['host'],$this->redis_config['port'] );