qpapi/websockServ/app/logic/cmdpro/CmdInf.php

<?php
namespace  app\logic\cmdpro;
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2019/5/21
 * Time: 16:48
 */

/*
 Swoole\Server\Task Object
(
    [data] => Swoole\WebSocket\Frame Object
        (
            [fd] => 1
            [data] => {'cmd':'xxx','act'=>'xxx','data':'xxxx','time':xxxx,'token':xxx}
            [opcode] => 1
            [finish] => 1
        )

    [id] => 0
    [worker_id] => 2
    [flags] => 6
)

data:
{'cmd':'xxx','act'=>'xxx','data':'xxxx','time':xxxx,'token':xxx}
 **/

use app\lib\DataPack;
use app\lib\Wlog;

class   CmdInf
{
    public function paraCmd($serv, \Swoole\Server\Task $task){
        $fd = $task->data->fd;
        $dataPack = json_decode($task->data->data, true);
        $method = isset($dataPack['act']) ? $dataPack['act'] : '';

        if (empty($method) || !(method_exists($this, $method))) {
            $this->sendTo($serv, $fd, DataPack::toJson(['mtype' => 'error', 'data' => '无效的参数']), true);
            return;
        }

        try{
            return $this->$method($serv,$task);
        }catch (\Exception $e){
            echo "发生异常或错误：".$e->getFile().' '.$e->getLine().' '.$e->getCode().' '.$e->getMessage()."\r\n";
            return ;
        }

    }

    //单发
    public function sendTo($serv,$fd,$dataString,$close=false)
    {
        $serv->push($fd,$dataString);
        if ($close){
            $serv->disconnect($fd);
        }
        return true;
    }

    //在线广播
    public function onlineBroad($serv,$dataString){
        foreach($serv->connections as $fd)
        {
            $serv->push($fd,$dataString);
        }
    }




}