swoole服务端TP5

谁借莪１个温暖的怀抱￠ 2023-01-14 01:42 162阅读 0赞

运行命令：php think swoser

<?php
    /** * swoole通用服务 */
    
    namespace app\home\swoole;
    
    
    use app\console\common\ServerCommand;
    use app\home\controller\AmazonExport;
    use app\home\controller\AmazonEx;
    use think\Log;
    use think\console\Input;
    use think\console\Output;
    
    //继承Server基类
    class SwooleServ extends ServerCommand
    { 
    
    //实际业务的接口地址前缀
        private $swooleTaskPath = '\\app\home\\controller\\';
        const HOST = '127.0.0.1';
        const LIVE_PORT = 8811;
    
    
        protected function execute(Input $input, Output $output)
        { 
            $this->serv = new \Swoole\Server(self::HOST, self::LIVE_PORT);
            $this->serv->set(array(
                'worker_num' => 2,
                'daemonize' => 1,#守护进程运行
                'task_worker_num' => 6,
            ));
            $this->serv->on('Receive', array($this, 'onReceive'));
            $this->serv->on('Task', array($this, 'onTask'));
            $this->serv->on('Finish', array($this, 'onFinish'));
            $this->serv->start();
        }
    
        protected function configure()
        { 
            #此为tp5特有的cli命名模式
            $this->setName('swoser')->setDescription('swoole通用服务');
        }
    
        public function onReceive($serv, $fd, $from_id, $data)
        { 
    
    
            $serv->task($data, -1);
        }
    
        public function onTask($serv, $task_id, $src_worker_id, $data)
        { 
            if (is_array($data)) { 
                file_put_contents(ROOT_PATH . 'public/swoole_error.log', date('Y-m-d H:i:s') . json_encode($data) . '1111' . PHP_EOL, 8);
            } else { 
                file_put_contents(ROOT_PATH . 'public/swoole_error.log', date('Y-m-d H:i:s') . ' taskId=' . $task_id . $data . PHP_EOL, 8);
            }
            $data = trim($data);
            $data = json_decode($data, true);
            switch ($data['type']) { 
                //异步汇出
                case 'AmazonExport':
    
                    $className = $this->swooleTaskPath . $data['class'];
                    $action = $data['action'];
    
                    (new $className())->$action($data['data']);
    
    
    
    // return call_user_func_array(array(
    // new $className(),
    // $action
    // ), array($data['data']));
                    break;
    
                case 'Test':
                    $taskClass = $this->swooleTaskPath . 'wechat\\' . $data['type'] . 'Task';
                    call_user_func_array(array(
                        new $taskClass(),
                        'index'
                    ), array(
                        $serv,
                        $data['data']
                    ));
                    break;
    
                default:
                    return [
                        'type' => 'undefided',
                        'status' => false
                    ];
            }
    
    
        }
    
        public function onFinish($serv, $task_id, $data)
        { 
    
        }
    }