cesurapp / swoole-bundle
Symfony Swoole Bundle
Installs: 211
Dependents: 0
Suggesters: 0
Security: 0
Stars: 2
Watchers: 2
Forks: 1
Open Issues: 1
Type:symfony-bundle
Requires
- php: >=8.2
- ext-swoole: *
- dragonmantank/cron-expression: ^3.3
- symfony/console: ^7.1
- symfony/dependency-injection: ^7.1
- symfony/dotenv: ^7.1
- symfony/framework-bundle: ^7.1
- symfony/http-client-contracts: ^3.5
- symfony/http-kernel: ^7.1
- symfony/lock: ^7.1
- symfony/runtime: ^7.1
Requires (Dev)
- doctrine/doctrine-bundle: ^2.11
- doctrine/orm: ^2.17
- php-cs-fixer/shim: ^3.40
- phpstan/phpstan: ^1.10
- symfony/process: ^7.1
- symfony/test-pack: ^1.1
- symfony/uid: ^7.1
README
Built-in Swoole http server, background jobs (Task), scheduled task (Cron) worker are available. Failed jobs are saved in the database to be retried. Each server has built-in background task worker. Scheduled tasks run simultaneously on all servers. It is not possible for tasks to run at the same time as locking is used.
Install
Required Symfony 7
composer req cesurapp/swoole-bundle
Edit: public/index.php
... require_once dirname(__DIR__).'/vendor/cesurapp/swoole-bundle/src/Runtime/entrypoint.php'; require_once dirname(__DIR__).'/vendor/autoload_runtime.php'; ...
Configuration:
# config/packages/swoole.yaml swoole: entrypoint: public/index.php watch_dir: /config,/src,/templates watch_extension: '*.php,*.yaml,*.yml,*.twig' replace_http_client: true # Replace Symfony HTTP Client to Swoole Client cron_worker: true # Enable Cron Worker Service task_worker: true # Enable Task Worker Service task_sync_mode: false # Enable SYNC Mode -> Default false failed_task_retry: '@EveryMinute10' failed_task_attempt: 2 # Failed Task Retry Count
Server Environment: .env
#SERVER_WORKER_CRON=true # Run Cron Worker -> Default = True #SERVER_WORKER_TASK=true # Run Task Worker -> Default = True SERVER_HTTP_HOST=127.0.0.1 # Default = 0.0.0.0 SERVER_HTTP_PORT=9090 # Default = 80 #SERVER_HTTP_SETTINGS_WORKER_NUM=2 # Default = CPU Count #SERVER_HTTP_SETTINGS_TASK_WORKER_NUM=1 # Default = CPU Count / 2 #SERVER_HTTP_SETTINGS_LOG_LEVEL=4 # Details Openswoole\Constant LOG_LEVEL
Server Commands
# Cron Commands bin/console cron:list # List cron jobs bin/console cron:run AcmeCron # Run cron process one time, without locking. # Server Commands bin/console server:start # Start http,cron,queue server bin/console server:stop # Stop http,cron,queue server bin/console server:status # Status http,cron,queue server bin/console server:watch # Start http,cron,queue server for development mode (file watcher enabled) # Task|Job Commands bin/console task:list # List registered tasks bin/console task:failed:clear # Clear all failed task bin/console task:failed:retry # Forced send all failed tasks to swoole task worker bin/console task:failed:view # Lists failed tasks
Create Cron Job
You can use cron expression for scheduled tasks, or you can use predefined expressions.
/** * Predefined Scheduling * * '@yearly' => '0 0 1 1 *', * '@annually' => '0 0 1 1 *', * '@monthly' => '0 0 1 * *', * '@weekly' => '0 0 * * 0', * '@daily' => '0 0 * * *', * '@hourly' => '0 * * * *', * '@EveryMinute' => 'w* * * * *', * "@EveryMinute5' => '*\/5 * * * *', * '@EveryMinute10' => '*\/10 * * * *', * '@EveryMinute15' => '*\/15 * * * *', * '@EveryMinute30' => '*\/30 * * * *',``` */ class ExampleJob extends \Cesurapp\SwooleBundle\Cron\AbstractCronJob { /** * @see AbstractCronJob */ public string $TIME = '@EveryMinute10'; /** * Cron is Enable|Disable. */ public bool $ENABLE = true; /** * Cron Context */ public function __invoke(): void { } }
Create Task (Background Job or Queue)
Data passed to jobs must be of type string, int, bool, array, objects cannot be serialized.
Create:
class ExampleTask implements \Cesurapp\SwooleBundle\Task\TaskInterface { public function __invoke(object|string $data = null): void { var_dump( $data['name'], $data['invoke'] ); } }
Handle Task:
public function hello(\Cesurapp\SwooleBundle\Task\TaskHandler $taskHandler) { $taskHandler->dispatch(ExampleTask::class, [ 'name' => 'Test', 'invoke' => 'Data' ]); }