feat: workerman 增加热重载

This commit is contained in:
xboard 2024-05-23 11:40:52 +08:00
parent 1cfd077ae7
commit dd78dbde5c
4 changed files with 60 additions and 9 deletions

View File

@ -2,7 +2,7 @@ FROM phpswoole/swoole:php8.1-alpine
COPY --from=mlocati/php-extension-installer /usr/bin/install-php-extensions /usr/local/bin/ COPY --from=mlocati/php-extension-installer /usr/bin/install-php-extensions /usr/local/bin/
RUN install-php-extensions pcntl bcmath \ RUN install-php-extensions pcntl bcmath inotify \
&& apk --no-cache add shadow supervisor nginx sqlite nginx-mod-http-brotli mysql-client git patch \ && apk --no-cache add shadow supervisor nginx sqlite nginx-mod-http-brotli mysql-client git patch \
&& addgroup -S -g 1000 www && adduser -S -G www -u 1000 www && addgroup -S -g 1000 www && adduser -S -G www -u 1000 www
#复制项目文件以及配置文件 #复制项目文件以及配置文件

View File

@ -188,7 +188,10 @@ class ConfigController extends Controller
); );
} }
} }
// 如果是workerman环境则触发reload
if(isset(get_defined_constants(true)['user']['Workerman'])){
posix_kill(posix_getppid(), SIGUSR1);
}
Cache::forget('admin_settings'); Cache::forget('admin_settings');
// \Artisan::call('horizon:terminate'); //重启队列使配置生效 // \Artisan::call('horizon:terminate'); //重启队列使配置生效
return $this->success(true); return $this->success(true);

View File

@ -23,6 +23,7 @@ URL=https://www.aapanel.com/script/install_6.0_en.sh && if [ -f /usr/bin/curl ];
- swoole4 - swoole4
- readline - readline
- event - event
- inotify
4. 解除被禁止函数 4. 解除被禁止函数
> aaPanel 面板 > App Store > 找到PHP 8.1点击Setting > Disabled functions 将以下函数从列表中删除 > aaPanel 面板 > App Store > 找到PHP 8.1点击Setting > Disabled functions 将以下函数从列表中删除

View File

@ -4,26 +4,73 @@ require_once __DIR__ . '/vendor/autoload.php';
use Adapterman\Adapterman; use Adapterman\Adapterman;
use Workerman\Worker; use Workerman\Worker;
use \Workerman\Events\EventInterface;
define('Workerman', true);
Adapterman::init(); Adapterman::init();
$http_worker = new Worker('http://127.0.0.1:7010'); $http_worker = new Worker('http://127.0.0.1:7010');
$http_worker->count = getenv('WEBMAN_WORKERS') ?: max(swoole_cpu_num(), 2); $http_worker->count = getenv('WEBMAN_WORKERS') ?: max(swoole_cpu_num(), 2);
$http_worker->name = 'AdapterMan'; $http_worker->name = 'Xboard';
$http_worker->onWorkerStart = static function () { $http_worker->onWorkerStart = static function () {
//init();
require __DIR__ . '/start.php'; require __DIR__ . '/start.php';
}; };
$http_worker->onMessage = static function ($connection, $request) { $http_worker->onMessage = static function ($connection, $request) {
static $request_count; static $request_count;
$connection->send(run()); $connection->send(run());
if (++$request_count > 10000) { if (++$request_count > 10000) {
Worker::stopAll(); Worker::stopAll();
} }
}; };
$worker = new Worker();
$worker->name = 'FileMonitor';
$worker->reloadable = false;
$monitor_dirs = ['app', 'bootstrap', 'config', 'resources', 'routes', 'public', '.env'];
$monitor_files = array();
// 进程启动后创建inotify监控句柄
$worker->onWorkerStart = function ($worker) {
if (!extension_loaded('inotify')) {
echo "FileMonitor : Please install inotify extension.\n";
return;
}
global $monitor_dirs, $monitor_files;
$worker->inotifyFd = inotify_init();
stream_set_blocking($worker->inotifyFd, 0);
foreach ($monitor_dirs as $monitor_dir) {
$monitor_realpath = realpath(__DIR__ . "/{$monitor_dir}");
addInofity($monitor_realpath, $worker->inotifyFd);
if (is_file($monitor_realpath))
continue;
$iterator = new \RecursiveIteratorIterator(new \RecursiveDirectoryIterator($monitor_realpath, \FilesystemIterator::SKIP_DOTS), \RecursiveIteratorIterator::SELF_FIRST);
foreach ($iterator as $file) {
if ($file->isDir()) {
$realpath = realpath($file);
addInofity($realpath, $worker->inotifyFd);
}
}
}
Worker::$globalEvent->add($worker->inotifyFd, EventInterface::EV_READ, 'check_files_change');
};
function addInofity(string $realpath, $fd)
{
global $monitor_files;
$wd = inotify_add_watch($fd, $realpath, IN_MODIFY | IN_CREATE | IN_DELETE);
$monitor_files[$wd] = $realpath;
}
function check_files_change($inotify_fd)
{
global $monitor_files;
$events = inotify_read($inotify_fd);
if ($events) {
foreach ($events as $ev) {
$file = $monitor_files[$ev['wd']];
echo $file . "/{$ev['name']} update and reload\n";
}
posix_kill(posix_getppid(), SIGUSR1);
}
}
Worker::runAll(); Worker::runAll();