0

关于tp的think-swoole 用过了 感觉怪怪的. 有些问题 然后再网上找的了 其他的适配方式
请问一下这种适配方式能用吗? 有没有更好的 还是说 用基于swoole 开发的框架
贴代码

<?php
namespace app\Console;

use think\console\Command;
use think\console\Input;
use think\console\Output;

class AsyncTask extends Command
{
    protected $server;

    // 命令行配置函数
    protected function configure()
    {
        // setName 设置命令行名称
        // setDescription 设置命令行描述
        $this->setName('task:start')->setDescription('Start Task Server!');
    }

    // 设置命令返回信息
    protected function execute(Input $input, Output $output)
    {
        $this->server = new \swoole_server('0.0.0.0', 9509);

        // server 运行前配置
        $this->server->set([
            'worker_num'      => 4,
            'daemonize'       => false,
            'task_worker_num' => 4  # task 进程数
        ]);

        // 注册回调函数
        $this->server->on('Start', [$this, 'onStart']);
        $this->server->on('Connect', [$this, 'onConnect']);
        $this->server->on('Receive', [$this, 'onReceive']);
        $this->server->on('Task', [$this, 'onTask']);
        $this->server->on('Finish', [$this, 'onFinish']);
        $this->server->on('Close', [$this, 'onClose']);
        $this->server->on('Message', [$this, 'onMessage']);

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

    // 主进程启动时回调函数
    public function onStart(\swoole_server $server)
    {
        echo "Start\n";
    }

    // 建立连接时回调函数
    public function onConnect(\swoole_server $server, $fd, $from_id)
    {

        echo "$fd 连接了\n";
    }

    // 收到信息时回调函数
    public function onReceive(\swoole_server $server, $fd, $from_id, $data)
    {
        echo $data.PHP_EOL;
        //print_r($data);

        // 投递异步任务
        //$task_id = $server->task($data);
      //  echo "Dispath AsyncTask: id={$task_id}\n";

        // 将受到的客户端消息再返回给客户端
       // $server->send($fd, "Message form Server: {$data}, task_id: {$task_id}");
    }

    // 异步任务处理函数
    public function onTask(\swoole_server $server, $task_id, $from_id, $data)
    {
        echo "{$task_id}, Task Completed \n";

        //返回任务执行的结果
        $server->finish("$data -> OK");
    }

    // 异步任务完成通知 Worker 进程函数
    public function onFinish(\swoole_server $server, $task_id, $data)
    {
        echo "AsyncTask[{$task_id}] Finish: {$data} \n";
    }

    // 关闭连时回调函数
    public function onClose(\swoole_server $server, $fd, $from_id)
    {
        echo "Close\n";
    }

    public function onMessage($server, $frame)
    {
        echo $frame->data.PHP_EOL;
    }

}
2019-06-05 提问

查看全部 3 个回答

推广链接