浅析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命令行指令类，我们修改内容如下：

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 = &＃039;server&＃039;;

/**
* 注册控制器名称
* 使用命令启动相关控制器
* @var mixed
*/
public $controller_names = [&＃039;WebhookTimer&＃039;];

/**
* configure
* tp框架自定义指令特性
* 注册命令参数
* @return mixed
*/
protected function configure()
{
$this->setName(&＃039;spider&＃039;)
->addArgument(&＃039;status&＃039;, Argument::OPTIONAL, "status")
->addArgument(&＃039;controller_name&＃039;, Argument::OPTIONAL, "controller_name/controller_name")
->addArgument(&＃039;mode&＃039;, Argument::OPTIONAL, "d")
->setDescription(&＃039;spider control&＃039;);

/**
* 以上设置命令格式为: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(&＃039;status&＃039;);
if(!$status){
$output->writeln(&＃039;pelase input control command , like start&＃039;);
exit;
}


//获得控制器名称
$controller_str = $input->getArgument(&＃039;controller_name&＃039;);

//获得模式,d为wokerman的后台模式(生产环境)
$mode = $input->getArgument(&＃039;mode&＃039;);

//分析控制器参数,如果缺省或为all,那么运行所有注册的控制器
$controller_list = $this->controller_names;

if($controller_str != &＃039;&＃039; && $controller_str != &＃039;all&＃039; )
{
$controller_list = explode(&＃039;/&＃039;,$controller_str);
}

//重写mode参数,改为wokerman接受的参数
if($mode == &＃039;d&＃039;){
$mode = &＃039;-d&＃039;;
}

if($mode == &＃039;g&＃039;){
$mode = &＃039;-g&＃039;;
}

//将wokerman需要的参数传入到其parseCommand方法中,此方法在start类中重写
Start::$argvs = [
&＃039;think&＃039;,
$status,
$mode
];

$output->writeln(&＃039;start running spider&＃039;);

$programs_ob_list = [];


//实例化需要运行的控制器
foreach ($controller_list as $c_key => $controller_name) {
$class_name = &＃039;app\\&＃039;.$this->model_name.&＃039;\controller\\&＃039;.$controller_name;
$programs_ob_list[] = new $class_name();
}



//将控制器的相关回调参数传到workerman中
foreach ([&＃039;onWorkerStart&＃039;, &＃039;onConnect&＃039;, &＃039;onMessage&＃039;, &＃039;onClose&＃039;, &＃039;onError&＃039;, &＃039;onBufferFull&＃039;, &＃039;onBufferDrain&＃039;, &＃039;onWorkerStop&＃039;, &＃039;onWorkerReload&＃039;] 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

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 = &＃039;0.0.0.0&＃039;;
public $port = &＃039;9527&＃039;;
public $name = &＃039;webhook&＃039;;
public $count = 1;
public function onWorkerStart($worker)
{


Timer::add(2, array($this, &＃039;webhooks&＃039;), 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 = [&＃039;WebhookTimer&＃039;,&＃039;其他方法&＃039;,&＃039;其他方法&＃039;];

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

完结

Start.php文件

namespace app\server\controller;

use Workerman\Worker;

class Start extends Worker
{
public static $argvs = [];
public static $workerHost;
public $socket = &＃039;&＃039;;
public $protocol = &＃039;http&＃039;;
public $host = &＃039;0.0.0.0&＃039;;
public $port = &＃039;2346&＃039;;
public $cOntext= [];

public function __construct()
{
self::$workerHost = parent::__construct($this->socket ?: $this->protocol . &＃039;://&＃039; . $this->host . &＃039;:&＃039; . $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(
&＃039;start&＃039;,
&＃039;stop&＃039;,
&＃039;restart&＃039;,
&＃039;reload&＃039;,
&＃039;status&＃039;,
&＃039;connections&＃039;,
);
$usage = "Usage: php yourfile [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(&＃039;Unknown command: &＃039; . static::$argvs[1] . "\n");
}
exit($usage);
}

// Get command.
$command = trim(static::$argvs[1]);
$command2 = isset(static::$argvs[2]) ? static::$argvs[2] : &＃039;&＃039;;

// Start command.
$mode = &＃039;&＃039;;
if ($command === &＃039;start&＃039;) {
if ($command2 === &＃039;-d&＃039; || static::$daemonize) {
$mode = &＃039;in DAEMON mode&＃039;;
} else {
$mode = &＃039;in DEBUG mode&＃039;;
}
}
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 === &＃039;start&＃039;) {
static::log("Workerman[$start_file] already running");
exit;
}
} elseif ($command !== &＃039;start&＃039; && $command !== &＃039;restart&＃039;) {
static::log("Workerman[$start_file] not run");
exit;
}

// execute command.
switch ($command) {
case &＃039;start&＃039;:
if ($command2 === &＃039;-d&＃039;) {
static::$daemOnize= true;
}
break;
case &＃039;status&＃039;:
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 === &＃039;-d&＃039;) {
static::safeEcho("\33[H\33[2J\33(B\33[m", true);
}
// Echo status data.
static::safeEcho(static::formatStatusData());
if ($command2 !== &＃039;-d&＃039;) {
exit(0);
}
static::safeEcho("\nPress Ctrl+C to quit.\n\n");
}
exit(0);
case &＃039;connections&＃039;:
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 &＃039;restart&＃039;:
case &＃039;stop&＃039;:
if ($command2 === &＃039;-g&＃039;) {
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 === &＃039;stop&＃039;) {
exit(0);
}
if ($command2 === &＃039;-d&＃039;) {
static::$daemOnize= true;
}
break;
}
break;
case &＃039;reload&＃039;:
if($command2 === &＃039;-g&＃039;){
$sig = SIGQUIT;
}else{
$sig = SIGUSR1;
}
posix_kill($master_pid, $sig);
exit;
default :
if (isset($command)) {
static::safeEcho(&＃039;Unknown command: &＃039; . $command . "\n");
}
exit($usage);
}
}

}

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

以上就是浅析thinkphp6中怎么使用workerman【教程分享】的详细内容，更多请关注北冥有鱼其它相关文章！

本文转载自【PHP中文网】，希望能给您带来帮助，苟日新、日日新、又日新，生命不息，学习不止。