浅析thinkphp6中怎么使用workerman【教程分享】

thinkphp6中怎么使用workerman？下面本篇文章给大家介绍一下thinkphp6整合workerman的教程，希望对大家有所帮助。

thinkphp6整合workerman教程

thinkphp6安装workerman命令：

composer require topthink/think-worker

第一步，创建一个自定义命令类文件，运行指令。【相关推荐：《workerman教程》】

php think make:command Spider spider

会生成一个app\command\Spider命令行指令类，我们修改内容如下：

<?php
namespace app\command;
 
// tp指令特性使用的功能
use think\console\Command;
use think\console\Input;
use think\console\input\Argument;
use think\console\Output;
 
// 引用项目的基类,该类继承自worker
use app\server\controller\Start;
 
/**
 * 指令类
 * 在此定义指令
 * 再次启动多个控制器
 * @var mixed
 */
class Spider extends Command
{
 
    /**
     * 注册模块名称
     * 使用命令会启动该模块控制器
     * @var mixed
     */
    public $model_name = &#39;server&#39;;
 
    /**
     * 注册控制器名称
     * 使用命令启动相关控制器
     * @var mixed
     */
    public $controller_names = [&#39;WebhookTimer&#39;];
 
    /**
     * configure
     * tp框架自定义指令特性
     * 注册命令参数
     * @return mixed
     */
    protected function configure()
    {
        $this->setName(&#39;spider&#39;)
            ->addArgument(&#39;status&#39;, Argument::OPTIONAL, "status")
            ->addArgument(&#39;controller_name&#39;, Argument::OPTIONAL, "controller_name/controller_name")
            ->addArgument(&#39;mode&#39;, Argument::OPTIONAL, "d")
            ->setDescription(&#39;spider control&#39;);
 
        /**
         * 以上设置命令格式为:php think spider [status] [controller_name/controller_name] [d]
         * think        为thinkphp框架入口文件
         * spider       为在框架中注册的命令,上面setName设置的
         * staus        为workerman框架接受的命令
         * controller_name/controller_name      为控制器名称,以正斜线分割,执行制定控制器,为空或缺省则启动所有控制器,控制器列表在controller_name属性中注册
         * d            最后一个参数为wokerman支持的-d-g参数,但是不用加-,直接使用d或者g
         * php think spider start collect/SendMsg
         */
    }
 
 
    /**
     * execute
     * tp框架自定义指令特性
     * 执行命令后的逻辑
     * @param mixed $input
     * @param mixed $output
     * @return mixed
     */
    protected function execute(Input $input, Output $output)
    {
 
        //获得status参数,即think自定义指令中的第一个参数,缺省报错
        $status  = $input->getArgument(&#39;status&#39;);
        if(!$status){
            $output->writeln(&#39;pelase input control command , like start&#39;);
            exit;
        }
 
 
        //获得控制器名称
        $controller_str =  $input->getArgument(&#39;controller_name&#39;);
 
        //获得模式,d为wokerman的后台模式(生产环境)
        $mode = $input->getArgument(&#39;mode&#39;);
 
        //分析控制器参数,如果缺省或为all,那么运行所有注册的控制器
        $controller_list = $this->controller_names;
 
        if($controller_str != &#39;&#39; && $controller_str != &#39;all&#39; )
        {
            $controller_list = explode(&#39;/&#39;,$controller_str);
        }
 
        //重写mode参数,改为wokerman接受的参数
        if($mode == &#39;d&#39;){
            $mode = &#39;-d&#39;;
        }
 
        if($mode == &#39;g&#39;){
            $mode = &#39;-g&#39;;
        }
 
        //将wokerman需要的参数传入到其parseCommand方法中,此方法在start类中重写
        Start::$argvs = [
            &#39;think&#39;,
            $status,
            $mode
        ];
 
        $output->writeln(&#39;start running spider&#39;);
 
        $programs_ob_list = [];
 
 
        //实例化需要运行的控制器
        foreach ($controller_list as $c_key => $controller_name) {
            $class_name = &#39;app\\&#39;.$this->model_name.&#39;\controller\\&#39;.$controller_name;
            $programs_ob_list[] = new $class_name();
        }
 
 
 
        //将控制器的相关回调参数传到workerman中
        foreach ([&#39;onWorkerStart&#39;, &#39;onConnect&#39;, &#39;onMessage&#39;, &#39;onClose&#39;, &#39;onError&#39;, &#39;onBufferFull&#39;, &#39;onBufferDrain&#39;, &#39;onWorkerStop&#39;, &#39;onWorkerReload&#39;] as $event) {
            foreach ($programs_ob_list as $p_key => $program_ob) {
                if (method_exists($program_ob, $event)) {
                    $programs_ob_list[$p_key]->$event = [$program_ob,$event];
                }
            }
        }
 
        Start::runAll();
    }
}

例如我们创建一个定时器的命令app\server\controller创建WebhookTimer.php

<?php
namespace app\server\controller;
use Workerman\Worker; 
use \Workerman\Lib\Timer;
use think\facade\Cache;
use think\facade\Db;
use think\Request;
 
class WebhookTimer extends Start
{
    public $host     = &#39;0.0.0.0&#39;;
    public $port     = &#39;9527&#39;;
    public $name     = &#39;webhook&#39;;
    public $count    = 1;
    public function onWorkerStart($worker)
    {
      
        
            Timer::add(2, array($this, &#39;webhooks&#39;), array(), true);
        
     
    }
    public function onConnect()
    {
 
    }
 
    public function onMessage($ws_connection, $message)
    {
       
    }
 
    public function onClose()
    {
 
    }
    
    public function webhooks()
    {
 
       echo 11;
    }
    
    
}

执行start命令行

php think spider start

执行stop命令

php think spider stop

执行全部进程命令

php think spider start all d

在app\command\Spider.php文件

public $controller_names = ['WebhookTimer','其他方法','其他方法'];

其他方法 就是app\server\controller下创建的其他类文件方法

完结

Start.php文件

<?php
namespace app\server\controller;
 
use Workerman\Worker;
 
class Start extends Worker
{
    public static $argvs = [];
    public static $workerHost;
    public $socket   = &#39;&#39;;
    public $protocol = &#39;http&#39;;
    public $host     = &#39;0.0.0.0&#39;;
    public $port     = &#39;2346&#39;;
    public $context  = [];
 
    public function __construct()
    {
        self::$workerHost = parent::__construct($this->socket ?: $this->protocol . &#39;://&#39; . $this->host . &#39;:&#39; . $this->port, $this->context);
    }
 
    /**
     * parseCommand
     * 重写wokerman的解析命令方法
     * @return mixed
     */
    public static function parseCommand()
    {
        if (static::$_OS !== OS_TYPE_LINUX) {
            return;
        }
        // static::$argvs;
        // Check static::$argvs;
        $start_file = static::$argvs[0];
        $available_commands = array(
            &#39;start&#39;,
            &#39;stop&#39;,
            &#39;restart&#39;,
            &#39;reload&#39;,
            &#39;status&#39;,
            &#39;connections&#39;,
        );
        $usage = "Usage: php yourfile <command> [mode]\nCommands: \nstart\t\tStart worker in DEBUG mode.\n\t\tUse mode -d to start in DAEMON mode.\nstop\t\tStop worker.\n\t\tUse mode -g to stop gracefully.\nrestart\t\tRestart workers.\n\t\tUse mode -d to start in DAEMON mode.\n\t\tUse mode -g to stop gracefully.\nreload\t\tReload codes.\n\t\tUse mode -g to reload gracefully.\nstatus\t\tGet worker status.\n\t\tUse mode -d to show live status.\nconnections\tGet worker connections.\n";
        if (!isset(static::$argvs[1]) || !in_array(static::$argvs[1], $available_commands)) {
            if (isset(static::$argvs[1])) {
                static::safeEcho(&#39;Unknown command: &#39; . static::$argvs[1] . "\n");
            }
            exit($usage);
        }
 
        // Get command.
        $command  = trim(static::$argvs[1]);
        $command2 = isset(static::$argvs[2]) ? static::$argvs[2] : &#39;&#39;;
 
        // Start command.
        $mode = &#39;&#39;;
        if ($command === &#39;start&#39;) {
            if ($command2 === &#39;-d&#39; || static::$daemonize) {
                $mode = &#39;in DAEMON mode&#39;;
            } else {
                $mode = &#39;in DEBUG mode&#39;;
            }
        }
        static::log("Workerman[$start_file] $command $mode");
 
        // Get master process PID.
        $master_pid      = is_file(static::$pidFile) ? file_get_contents(static::$pidFile) : 0;
        $master_is_alive = $master_pid && posix_kill($master_pid, 0) && posix_getpid() != $master_pid;
        // Master is still alive?
        if ($master_is_alive) {
            if ($command === &#39;start&#39;) {
                static::log("Workerman[$start_file] already running");
                exit;
            }
        } elseif ($command !== &#39;start&#39; && $command !== &#39;restart&#39;) {
            static::log("Workerman[$start_file] not run");
            exit;
        }
 
        // execute command.
        switch ($command) {
            case &#39;start&#39;:
                if ($command2 === &#39;-d&#39;) {
                    static::$daemonize = true;
                }
                break;
            case &#39;status&#39;:
                while (1) {
                    if (is_file(static::$_statisticsFile)) {
                        @unlink(static::$_statisticsFile);
                    }
                    // Master process will send SIGUSR2 signal to all child processes.
                    posix_kill($master_pid, SIGUSR2);
                    // Sleep 1 second.
                    sleep(1);
                    // Clear terminal.
                    if ($command2 === &#39;-d&#39;) {
                        static::safeEcho("\33[H\33[2J\33(B\33[m", true);
                    }
                    // Echo status data.
                    static::safeEcho(static::formatStatusData());
                    if ($command2 !== &#39;-d&#39;) {
                        exit(0);
                    }
                    static::safeEcho("\nPress Ctrl+C to quit.\n\n");
                }
                exit(0);
            case &#39;connections&#39;:
                if (is_file(static::$_statisticsFile) && is_writable(static::$_statisticsFile)) {
                    unlink(static::$_statisticsFile);
                }
                // Master process will send SIGIO signal to all child processes.
                posix_kill($master_pid, SIGIO);
                // Waiting amoment.
                usleep(500000);
                // Display statisitcs data from a disk file.
                if(is_readable(static::$_statisticsFile)) {
                    readfile(static::$_statisticsFile);
                }
                exit(0);
            case &#39;restart&#39;:
            case &#39;stop&#39;:
                if ($command2 === &#39;-g&#39;) {
                    static::$_gracefulStop = true;
                    $sig = SIGTERM;
                    static::log("Workerman[$start_file] is gracefully stopping ...");
                } else {
                    static::$_gracefulStop = false;
                    $sig = SIGINT;
                    static::log("Workerman[$start_file] is stopping ...");
                }
                // Send stop signal to master process.
                $master_pid && posix_kill($master_pid, $sig);
                // Timeout.
                $timeout    = 5;
                $start_time = time();
                // Check master process is still alive?
                while (1) {
                    $master_is_alive = $master_pid && posix_kill($master_pid, 0);
                    if ($master_is_alive) {
                        // Timeout?
                        if (!static::$_gracefulStop && time() - $start_time >= $timeout) {
                            static::log("Workerman[$start_file] stop fail");
                            exit;
                        }
                        // Waiting amoment.
                        usleep(10000);
                        continue;
                    }
                    // Stop success.
                    static::log("Workerman[$start_file] stop success");
                    if ($command === &#39;stop&#39;) {
                        exit(0);
                    }
                    if ($command2 === &#39;-d&#39;) {
                        static::$daemonize = true;
                    }
                    break;
                }
                break;
            case &#39;reload&#39;:
                if($command2 === &#39;-g&#39;){
                    $sig = SIGQUIT;
                }else{
                    $sig = SIGUSR1;
                }
                posix_kill($master_pid, $sig);
                exit;
            default :
                if (isset($command)) {
                    static::safeEcho(&#39;Unknown command: &#39; . $command . "\n");
                }
                exit($usage);
        }
    }
 
}

更多编程相关知识，请访问：编程教学！！

以上是浅析thinkphp6中怎么使用workerman【教程分享】的详细内容。更多信息请关注PHP中文网其他相关文章！