zer0-framework / pubsub
dev-master
2019-04-20 20:16 UTC
Requires
- php: >=7.2
- ext-igbinary: *
- zer0-framework/config: *
- zer0-framework/core: *
This package is auto-updated.
Last update: 2024-09-24 20:42:43 UTC
README
该组件实现了用于通过通道发送消息(事件)的 PubSub 服务。
配置
使用示例
分发
$pubsub = $this->app->factory('PubSub'); $pubsub->publish(new \Zer0\PubSub\Message('someChannel', 'Hello world!'));
订阅(异步版本)
$pubsub = $this->app->factory('PubSubAsync'); // Подписка на определенный канал $pubsub->subscribe('someChannel', function ($payload, string $chan) { var_dump($payload); // string(12) "Hello world!" }); // Подписка по шаблону $pubsub->psubscribe('some*', function ($payload, string $chan) { var_dump($payload); // string(12) "Hello world!" });