Remove FrankenPHP targeting
This commit is contained in:
@@ -2,7 +2,7 @@
|
||||
|
||||
## Entrypoint (`worker.php` приложения)
|
||||
|
||||
FrankenPHP запускается как `frankenphp run --config Caddyfile` и сам стартует PHP-воркеры.
|
||||
Фреймворк запускается удобным для пользователя способом. `WorkerRunner::run()` без аргументов обрабатывает один запрос и завершается (классический SAPI/FPM/CGI). Чтобы крутить worker-петлю, приложение передаёт свой адаптер:
|
||||
|
||||
```php
|
||||
use Pronchev\Pinecore\Kernel;
|
||||
@@ -11,10 +11,16 @@ use Pronchev\Pinecore\Http\WorkerRunner;
|
||||
require __DIR__ . '/vendor/autoload.php';
|
||||
|
||||
Kernel::boot(__DIR__);
|
||||
Kernel::container()->get(WorkerRunner::class)->run();
|
||||
$runner = Kernel::container()->get(WorkerRunner::class);
|
||||
|
||||
// Один запрос:
|
||||
$runner->run();
|
||||
|
||||
// Или worker-петля (пример для FrankenPHP):
|
||||
$runner->run(fn ($handler) => frankenphp_handle_request($handler));
|
||||
```
|
||||
|
||||
`WorkerRunner` резолвится через DI autowiring — конфигурировать не нужно.
|
||||
Адаптер получает `callable $handler` (обработать один запрос) и возвращает `bool` — продолжать ли цикл. `MAX_REQUESTS`, `$app->terminate()` и `gc_collect_cycles()` отрабатывает сам `WorkerRunner` между итерациями. `WorkerRunner` резолвится через DI autowiring — конфигурировать не нужно.
|
||||
|
||||
## WorkerRunner (`src/Http/WorkerRunner.php`)
|
||||
|
||||
@@ -26,23 +32,33 @@ final class WorkerRunner
|
||||
private readonly ExceptionHandler $exceptionHandler,
|
||||
) {}
|
||||
|
||||
public function run(): void
|
||||
public function run(?callable $loop = null): void
|
||||
{
|
||||
if ($loop === null) {
|
||||
$this->handle();
|
||||
$this->app->terminate();
|
||||
return;
|
||||
}
|
||||
|
||||
$handler = fn () => $this->handle();
|
||||
$maxRequests = (int) ($_SERVER['MAX_REQUESTS'] ?? 0); // 0 = без лимита
|
||||
|
||||
for ($n = 0; !$maxRequests || $n < $maxRequests; ++$n) {
|
||||
$keepRunning = frankenphp_handle_request(function (): void {
|
||||
try {
|
||||
$this->app->handleRequest($_GET, $_POST, $_COOKIE, $_FILES, $_SERVER);
|
||||
} catch (\Throwable $e) {
|
||||
$this->exceptionHandler->handleException($e); // critical лог
|
||||
}
|
||||
});
|
||||
$keepRunning = $loop($handler);
|
||||
|
||||
$this->app->terminate(); // хук: закрытие ресурсов (сейчас пустой)
|
||||
gc_collect_cycles();
|
||||
|
||||
if (!$keepRunning) break; // FrankenPHP сигнализирует об остановке
|
||||
if (!$keepRunning) break;
|
||||
}
|
||||
}
|
||||
|
||||
private function handle(): void
|
||||
{
|
||||
try {
|
||||
$this->app->handleRequest($_GET, $_POST, $_COOKIE, $_FILES, $_SERVER);
|
||||
} catch (\Throwable $e) {
|
||||
$this->exceptionHandler->handleException($e); // critical лог
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user