zer0-framework/pubsub

dev-master 2019-04-20 20:16 UTC

Requires

• php: >=7.2
• ext-igbinary: *
• zer0-framework/config: *
• zer0-framework/core: *

GPL-3.0-or-later

• Vasily Zorin

• highload
• Zer0

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!"
});