task

zhoudw

2021-12-22 e60e4cb0ed8f8abda3c31efe1222435ea79de9b0

task

 ws_server.php

@@ -35,14 +35,14 @@
        //     //'heartbeat_idle_time' => 2000,        // 连接最大允许空闲的时间(秒)，与heartbeat_check_interval配合使用.当dispatch_mode=1/3时，底层会屏蔽onConnect/onClose事件
        //     //'heartbeat_check_interval' => 2,   // 表示每隔多久轮循一次，单位为秒
        // ));
        /*
   
        $this->server->set([
            // 'task_worker_num'       => 8,
            // 'enable_coroutine'      => true,
            // 'task_enable_coroutine' => true,
            'task_worker_num'       => 4,
            'enable_coroutine'      => true,
            'task_enable_coroutine' => true,
            'max_conn'              => 100000,
        ]);
        */
        
        $this->server->on('WorkerStart', function (Swoole\WebSocket\Server $server) {
            if (!$this->redis) {
                $this->redis = new Redis();
@@ -61,8 +61,23 @@
        });

        $this->server->on('message', function (Swoole\WebSocket\Server $server, $frame) {
            // $server->task($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) {
            $ret = array('code' => 0, 'data' => null);
            $frame = $task->data;
            $msgData = $this->is_json($frame->data,true);
            if($msgData){
                $frameData = $msgData;
@@ -74,21 +89,6 @@
                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'] );