dtyq / async-event
v0.1.1
2025-04-06 10:47 UTC
Requires
- php: >=7.4
- ext-json: *
- hyperf/config: *
- hyperf/crontab: *
- hyperf/db-connection: *
- hyperf/di: *
- hyperf/event: *
- hyperf/framework: *
- hyperf/logger: *
- hyperf/redis: *
- hyperf/snowflake: *
Requires (Dev)
- friendsofphp/php-cs-fixer: ^3.0
- mockery/mockery: ^1.0
- phpstan/phpstan: ^1.0
- phpunit/phpunit: >=7.0
- swoole/ide-helper: ^4.5
Suggests
- swow/swow: Required to create swow components.
README
- 事件将会放到一个协程中,然后按照顺序执行
- 核心代码为
\Dtyq\AsyncEvent\AsyncEventDispatcher::dispatch
安装
- 安装
composer require dtyq/async-event
- 发布配置
php bin/hyperf.php vendor:publish dtyq/async-event
- 运行数据库迁移
php bin/hyperf.php migrate
使用方式
- 为了不影响原有逻辑,采用新的dispatcher即可
demo
<?php declare(strict_types=1); /** * Copyright (c) The Magic , Distributed under the software license */ namespace App\Controller; use App\Event\DemoEvent; use Hyperf\Di\Annotation\Inject; use Dtyq\AsyncEvent\AsyncEventDispatcher; class IndexController extends AbstractController { /** * @Inject() */ protected AsyncEventDispatcher $asyncEventDispatcher; public function index() { $user = $this->request->input('user', 'Hyperf'); $method = $this->request->getMethod(); $this->asyncEventDispatcher->dispatch(new DemoEvent([123,222], 9)); return [ 'method' => $method, 'message' => "Hello {$user}.", ]; } }
- 达到最大执行次数,可以进行消息提醒,但是需要自己增加配置,本项目仅提供达到最大重试事件
注意事项
- 事件中尽量不要使用协程上下文来传递数据,因为事件是异步的,可能会导致数据不一致