Swoole\Server::task(): task method can't be executed without task worker

来源：8-17 赛事直播功能开发-优化

慕少5137873

2019-11-05

在调用task的时候报错，这是为什么呢

<?php


namespace app\admin\controller;


use app\common\lib\redis\Predis;
use app\common\lib\Util;

class Live
{
    public function push(){
        if(empty($_GET)){
            return Util::show(config('code.error'), 'error');
        }
        //print_r($_GET);
        //token md5(content)
        $teams = [
            1=>[
              'name' => '马刺',
              'logo' => '/live/imgs/tem1.png',
            ],
            4 => [
              'name' => '火箭',
              'logo' => '/live/imgs/team2.png',
            ],
        ];
        $data = [
            'type' => intval($_GET['type']),
            'title' => !empty($teamas[$_GET['team_id']]['name']) ? $teams[$_GET['team_id']]['name'] : '直播员',
            'logo' => !empty($teamas[$_GET['team_id']]['logo']) ? $teams[$_GET['team_id']]['logo'] : '',
            'content' => !empty($_GET['content']) ? $_GET['content'] : '',
            'image' => !empty($_GET['image']) ? $_GET['image'] : '',
        ];

        //修改为task任务发布
        $taskData = [
            'method' => 'pushLive',
            'data' => $data,
        ];
        $_POST['http_server']->task($taskData, -1);
        return Util::show(config('code.success'), 'ok');

        //赛况的基本信息
        //获取连接的用户，push 到直播页面

    }

}




<?php


use think\App;

class Ws
{
    CONST HOST = '0.0.0.0';
    CONST PORT = 8811;

    public $ws = null;

    public function __construct()
    {
        //判断redis里面有值
       // \app\common\lib\redis\Predis::getInstance()->del(config('redis.live_redis_key'));
        $this->ws = new  Swoole\Websocket\Server(self::HOST, self::PORT);
        $this->ws->set(
            [
                'enable_static_handler' => true,
                'document_root' => '/data/wwwroot/default/swoole_tp/public/static',
                'worker_num' => 5,
                'task_work_num'=> 4 ,
            ]
        );
        $this->ws->on('open', [$this, 'onOpen']);
        $this->ws->on('message', [$this, 'onMessage']);
        $this->ws->on('WorkerStart', [$this, 'onWorkerStart']);
        $this->ws->on("request", [$this, 'onRequest']);
        $this->ws->on("task", [$this, 'onTask']);
        $this->ws->on("finish", [$this, 'onFinish']);
        $this->ws->on("close", [$this, 'onClose']);

        $this->ws->start();
    }

    /**
     * @param $ws
     * @param $request
     */
    public function onOpen($ws, $request) {
        //todo
        //fd redis [1, 2]
        \app\common\lib\redis\Predis::getInstance()->sAdd(config('redis.live_redis_key'), $request->fd);

    }

    /**
     * @param $server
     * @param $worker_id
     */
    public function onWorkerStart($server, $worker_id){
        //定义应用目录
        define('APP_PATH', __DIR__ . '/../application/');
        //加载框架里的文件
        //require __DIR__ . '/../thinkphp/base.php';
        require __DIR__ . '/../thinkphp/start.php';
    }

    /**
     * request 回调
     * @param $request
     * @param $response
     */
    public function onRequest($request, $response){
        $_SERVER = [];
        //var_dump($request->server);
        if (isset($request->server)) {
            foreach ($request->server as $k => $v) {
                $_SERVER[strtoupper($k)] = $v;
            }
        }
        if (isset($request->header)) {
            foreach ($request->header as $k => $v) {
                $_SERVER[strtoupper($k)] = $v;
            }
        }
        $_GET = [];
        if (isset($request->get)) {
            foreach ($request->get as $k => $v) {
                $_GET[$k] = $v;
            }
        }
        $_FILES = [];
        if (isset($request->files)) {
            foreach ($request->files as $k => $v) {
                $_FILES[$k] = $v;
            }
        }
        $_POST = [];
        if (isset($request->post)) {
            foreach ($request->post as $k => $v) {
                $_POST[$k] = $v;
            }
        }
        $_POST['http_server'] = $this->ws;
        ob_start();
        try {
            think\App::run()->send();
        } catch (\Exception $e) {
            print_r($e);
        }
        $res = ob_get_contents();
        if (ob_get_length() > 0) {
            ob_end_clean();
        }
        $response->end($res);
    }

    /**
     * @param $serv
     * @param $taskId
     * @param $workerId
     * @param $data
     * @return bool
     */
    public function onTask($serv, $taskId, $worker_id, $data){
        // 分发 task任务机制, 让不同的任务，走不同的逻辑
         $obj = new app\common\lib\task\Task;
         $method = $data['method'];
         $flag = $obj->$method($data['data'], $serv);
         return $flag;

    }

    /**
     * @param $serv
     * @param $taskId
     * @param $data
     */
    public function onFinish($serv, $taskId, $data){
        //todo
    }

    /**
     * @param $serv
     * @param $fd
     */
    public function onClose($serv, $fd){
        //todo
        //把用户连接 fd del
        \app\common\lib\redis\Predis::getInstance()->sRem(config('redis.live_redis_key'), $fd);
    }

    /**
     * @param $ws
     * @param $frame
     */
    public function onMessage($ws, $frame){
        //todo
        //$ws->push();
    }
}

new Ws();

报错信息

写回答

1回答