|
1
|
|
|
<?php |
|
2
|
|
|
|
|
|
|
|
|
|
3
|
|
|
namespace Hhxsv5\LaravelS\Swoole\Process; |
|
4
|
|
|
|
|
5
|
|
|
use Swoole\Http\Server; |
|
6
|
|
|
use Swoole\Process; |
|
7
|
|
|
|
|
8
|
|
|
trait CustomProcessTrait |
|
|
|
|
|
|
9
|
|
|
{ |
|
10
|
|
|
private $customProcessPidFile = 'laravels-custom-processes.pid'; |
|
|
|
|
|
|
11
|
|
|
|
|
12
|
|
|
public function addCustomProcesses(Server $swoole, $processPrefix, array $processes, array $laravelConfig) |
|
|
|
|
|
|
13
|
|
|
{ |
|
14
|
|
|
$pidfile = dirname($swoole->setting['pid_file']) . '/' . $this->customProcessPidFile; |
|
15
|
|
|
if (file_exists($pidfile)) { |
|
16
|
|
|
unlink($pidfile); |
|
17
|
|
|
} |
|
18
|
|
|
|
|
19
|
|
|
/**@var []CustomProcessInterface $processList */ |
|
|
|
|
|
|
20
|
|
|
$processList = []; |
|
21
|
|
|
foreach ($processes as $name => $item) { |
|
22
|
|
|
if (empty($item['class'])) { |
|
23
|
|
|
throw new \InvalidArgumentException(sprintf( |
|
|
|
|
|
|
24
|
|
|
'process class name must be specified' |
|
|
|
|
|
|
25
|
|
|
) |
|
|
|
|
|
|
26
|
|
|
); |
|
27
|
|
|
} |
|
28
|
|
|
if (isset($item['enable']) && !$item['enable']) { |
|
29
|
|
|
continue; |
|
30
|
|
|
} |
|
31
|
|
|
$processClass = $item['class']; |
|
32
|
|
|
$restartInterval = isset($item['restart_interval']) ? (int)$item['restart_interval'] : 5; |
|
33
|
|
|
$callback = function (Process $worker) use ($pidfile, $swoole, $processPrefix, $processClass, $restartInterval, $name, $laravelConfig) { |
|
34
|
|
|
file_put_contents($pidfile, $worker->pid . "\n", FILE_APPEND | LOCK_EX); |
|
35
|
|
|
$this->initLaravel($laravelConfig, $swoole); |
|
|
|
|
|
|
36
|
|
|
if (!isset(class_implements($processClass)[CustomProcessInterface::class])) { |
|
37
|
|
|
throw new \InvalidArgumentException( |
|
38
|
|
|
sprintf( |
|
39
|
|
|
'%s must implement the interface %s', |
|
40
|
|
|
$processClass, |
|
41
|
|
|
CustomProcessInterface::class |
|
42
|
|
|
) |
|
43
|
|
|
); |
|
44
|
|
|
} |
|
45
|
|
|
/**@var CustomProcessInterface $processClass */ |
|
|
|
|
|
|
46
|
|
|
$this->setProcessTitle(sprintf('%s laravels: %s process', $processPrefix, $name)); |
|
|
|
|
|
|
47
|
|
|
|
|
48
|
|
|
Process::signal(SIGUSR1, function ($signo) use ($name, $processClass, $worker, $pidfile, $swoole) { |
|
|
|
|
|
|
49
|
|
|
$this->info(sprintf('Reloading %s process[PID=%d].', $name, $worker->pid)); |
|
|
|
|
|
|
50
|
|
|
$processClass::onReload($swoole, $worker); |
|
51
|
|
|
}); |
|
|
|
|
|
|
52
|
|
|
|
|
53
|
|
|
if (method_exists($processClass, 'onStop')) { |
|
54
|
|
|
Process::signal(SIGTERM, function ($signo) use ($name, $processClass, $worker, $pidfile, $swoole) { |
|
|
|
|
|
|
55
|
|
|
$this->info(sprintf('Stopping %s process[PID=%d].', $name, $worker->pid)); |
|
56
|
|
|
$processClass::onStop($swoole, $worker); |
|
57
|
|
|
}); |
|
|
|
|
|
|
58
|
|
|
} |
|
59
|
|
|
|
|
60
|
|
|
if (class_exists('Swoole\Runtime')) { |
|
61
|
|
|
\Swoole\Runtime::enableCoroutine(); |
|
62
|
|
|
} |
|
63
|
|
|
|
|
64
|
|
|
$this->callWithCatchException([$processClass, 'callback'], [$swoole, $worker]); |
|
|
|
|
|
|
65
|
|
|
|
|
66
|
|
|
// Avoid frequent process creation |
|
67
|
|
|
if (class_exists('Swoole\Coroutine')) { |
|
68
|
|
|
\Swoole\Coroutine::sleep($restartInterval); |
|
69
|
|
|
} else { |
|
70
|
|
|
sleep($restartInterval); |
|
71
|
|
|
} |
|
72
|
|
|
}; |
|
73
|
|
|
|
|
74
|
|
|
// for multiple processes |
|
75
|
|
|
if (isset($item['num']) && $item['num'] > 1) { |
|
76
|
|
|
for ($i = 0; $i < $item['num']; $i++) { |
|
77
|
|
|
$process = $this->makeProcess($callback, $item); |
|
78
|
|
|
$swoole->addProcess($process); |
|
79
|
|
|
$processList[$name . $i] = $process; |
|
80
|
|
|
} |
|
81
|
|
|
|
|
82
|
|
|
return $processList; |
|
83
|
|
|
} |
|
84
|
|
|
|
|
85
|
|
|
// for single process |
|
86
|
|
|
$process = $this->makeProcess($callback, $item); |
|
87
|
|
|
$swoole->addProcess($process); |
|
88
|
|
|
$processList[$name] = $process; |
|
89
|
|
|
} |
|
90
|
|
|
return $processList; |
|
91
|
|
|
} |
|
92
|
|
|
|
|
93
|
|
|
/** |
|
|
|
|
|
|
94
|
|
|
* @param callable $callback |
|
|
|
|
|
|
95
|
|
|
* @param array $processConfig process config from config/laravels.php |
|
|
|
|
|
|
96
|
|
|
* @return Process |
|
|
|
|
|
|
97
|
|
|
*/ |
|
98
|
|
|
public function makeProcess(callable $callback, array $processConfig) |
|
99
|
|
|
{ |
|
100
|
|
|
$redirect = isset($processConfig['redirect']) ? $processConfig['redirect'] : false; |
|
101
|
|
|
$pipe = isset($processConfig['pipe']) ? $processConfig['pipe'] : 0; |
|
102
|
|
|
$process = version_compare(SWOOLE_VERSION, '4.3.0', '>=') |
|
103
|
|
|
? new Process($callback, $redirect, $pipe, class_exists('Swoole\Coroutine')) |
|
104
|
|
|
: new Process($callback, $redirect, $pipe); |
|
105
|
|
|
if (isset($processConfig['queue'])) { |
|
106
|
|
|
if (empty($processConfig['queue'])) { |
|
107
|
|
|
$process->useQueue(); |
|
108
|
|
|
} else { |
|
109
|
|
|
$msgKey = isset($processConfig['msg_key']) ? $processConfig['msg_key'] : 0; |
|
110
|
|
|
$mode = isset($processConfig['mode']) ? $processConfig['mode'] : 2; |
|
111
|
|
|
$capacity = isset($processConfig['capacity']) ? $processConfig['capacity'] : -1; |
|
112
|
|
|
$process->useQueue($msgKey, $mode, $capacity); |
|
113
|
|
|
} |
|
114
|
|
|
} |
|
115
|
|
|
|
|
116
|
|
|
return $process; |
|
117
|
|
|
} |
|
118
|
|
|
} |
|
119
|
|
|
|
hhxsv5 /
laravel-s
Loading history...
