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

composer require topthink/think-worker

php think make:command Spider spider

<?php namespace appcommand;   // tp指令特性使用的功能 use thinkconsoleCommand; use thinkconsoleInput; use thinkconsoleinputArgument; use thinkconsoleOutput;   // 引用项目的基类,该类继承自worker use appservercontrollerStart;   /**  * 指令类  * 在此定义指令  * 再次启动多个控制器  * @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('spider')             -&gt;addArgument('status', Argument::OPTIONAL, "status")             -&gt;addArgument('controller_name', Argument::OPTIONAL, "controller_name/controller_name")             -&gt;addArgument('mode', Argument::OPTIONAL, "d")             -&gt;setDescription('spider control');           /**          * 以上设置命令格式为: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-&gt;getArgument('status');         if(!$status){             $output-&gt;writeln('pelase input control command , like start');             exit;         }             //获得控制器名称         $controller_str =  $input-&gt;getArgument('controller_name');           //获得模式,d为wokerman的后台模式(生产环境)         $mode = $input-&gt;getArgument('mode');           //分析控制器参数,如果缺省或为all,那么运行所有注册的控制器         $controller_list = $this-&gt;controller_names;           if($controller_str != '' &amp;&amp; $controller_str != 'all' )         {             $controller_list = explode('/',$controller_str);         }           //重写mode参数,改为wokerman接受的参数         if($mode == 'd'){             $mode = '-d';         }           if($mode == 'g'){             $mode = '-g';         }           //将wokerman需要的参数传入到其parseCommand方法中,此方法在start类中重写         Start::$argvs = [             'think',             $status,             $mode         ];           $output-&gt;writeln('start running spider');           $programs_ob_list = [];             //实例化需要运行的控制器         foreach ($controller_list as $c_key =&gt; $controller_name) {             $class_name = 'app'.$this-&gt;model_name.'controller'.$controller_name;             $programs_ob_list[] = new $class_name();         }               //将控制器的相关回调参数传到workerman中         foreach (['onWorkerStart', 'onConnect', 'onMessage', 'onClose', 'onError', 'onBufferFull', 'onBufferDrain', 'onWorkerStop', 'onWorkerReload'] as $event) {             foreach ($programs_ob_list as $p_key =&gt; $program_ob) {                 if (method_exists($program_ob, $event)) {                     $programs_ob_list[$p_key]-&gt;$event = [$program_ob,$event];                 }             }         }           Start::runAll();     } }

<?php namespace appservercontroller; use WorkermanWorker;  use WorkermanLibTimer; use thinkacadeCache; use thinkacadeDb; use thinkRequest;   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;     }           }

php think spider start

php think spider stop

php think spider start all d

<?php namespace appservercontroller;   use WorkermanWorker;   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-&gt;protocol . '://' . $this-&gt;host . ':' . $this-&gt;port, $this-&gt;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(             'start',             'stop',             'restart',             'reload',             'status',             'connections',         );         $usage = "Usage: php yourfile <command> [mode] Commands:  start		Start worker in DEBUG mode. 		Use mode -d to start in DAEMON mode. stop		Stop worker. 		Use mode -g to stop gracefully. restart		Restart workers. 		Use mode -d to start in DAEMON mode. 		Use mode -g to stop gracefully. reload		Reload codes. 		Use mode -g to reload gracefully. status		Get worker status. 		Use mode -d to show live status. connections	Get worker connections. ";         if (!isset(static::$argvs[1]) || !in_array(static::$argvs[1], $available_commands)) {             if (isset(static::$argvs[1])) {                 static::safeEcho('Unknown command: ' . static::$argvs[1] . " ");             }             exit($usage);         }           // Get command.         $command  = trim(static::$argvs[1]);         $command2 = isset(static::$argvs[2]) ? static::$argvs[2] : '';           // Start command.         $mode = '';         if ($command === 'start') {             if ($command2 === '-d' || static::$daemonize) {                 $mode = 'in DAEMON mode';             } else {                 $mode = 'in DEBUG mode';             }         }         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 &amp;&amp; posix_kill($master_pid, 0) &amp;&amp; posix_getpid() != $master_pid;         // Master is still alive?         if ($master_is_alive) {             if ($command === 'start') {                 static::log("Workerman[$start_file] already running");                 exit;             }         } elseif ($command !== 'start' &amp;&amp; $command !== 'restart') {             static::log("Workerman[$start_file] not run");             exit;         }           // execute command.         switch ($command) {             case 'start':                 if ($command2 === '-d') {                     static::$daemonize = true;                 }                 break;             case 'status':                 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 === '-d') {                         static::safeEcho("(B", true);                     }                     // Echo status data.                     static::safeEcho(static::formatStatusData());                     if ($command2 !== '-d') {                         exit(0);                     }                     static::safeEcho(" Press Ctrl+C to quit.  ");                 }                 exit(0);             case 'connections':                 if (is_file(static::$_statisticsFile) &amp;&amp; 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 'restart':             case 'stop':                 if ($command2 === '-g') {                     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 &amp;&amp; posix_kill($master_pid, $sig);                 // Timeout.                 $timeout    = 5;                 $start_time = time();                 // Check master process is still alive?                 while (1) {                     $master_is_alive = $master_pid &amp;&amp; posix_kill($master_pid, 0);                     if ($master_is_alive) {                         // Timeout?                         if (!static::$_gracefulStop &amp;&amp; time() - $start_time &gt;= $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 === 'stop') {                         exit(0);                     }                     if ($command2 === '-d') {                         static::$daemonize = true;                     }                     break;                 }                 break;             case 'reload':                 if($command2 === '-g'){                     $sig = SIGQUIT;                 }else{                     $sig = SIGUSR1;                 }                 posix_kill($master_pid, $sig);                 exit;             default :                 if (isset($command)) {                     static::safeEcho('Unknown command: ' . $command . " ");                 }                 exit($usage);         }     }   }</command>