daalvand/pubsub

用于pub/sub系统的包

维护者

详细信息

github.com/daalvand/pub-sub

源代码

问题

安装: 0

依赖者: 0

建议者: 0

安全: 0

星星: 0

关注者: 1

分支: 0

开放问题: 0

1.0.0 2021-09-24 10:04 UTC

Requires

MIT ad321194f29c993c32be6429b4886bed41422717

  • Mehdi Daalvand <mdaalvand.woop@gmail.com>

This package is auto-updated.

Last update: 2024-09-24 16:25:38 UTC

README

  • 此包用于使用Regis或Kafka进行发布和订阅

安装

安装包

运行 composer require daalvand/pubsub

发布提供者

Laravel

  • php artisan vendor:publish --provider="Daalvand\PubSub\PubSubServiceProvider"

Lumen

  • 将服务提供者添加到 bootstrap/app.php 文件
<?php
//...
/** @var App $app */
$app->register(Daalvand\PubSub\PubSubServiceProvider::class);

将配置文件从 /vendor/daalvand/pubsub/src/config 复制到 config 目录。然后在 /bootstrap/app.php 文件中配置它

<?php
/** @var App $app */
$app->configure("pub-sub");

用法

发布者

use Daalvand\PubSub\Facades\Publisher;

Publisher::publish('channel_name', $data);

订阅者

use Daalvand\PubSub\Facades\Subscriber;
use Daalvand\PubSub\Message;

Subscriber::subscribe(['channel_one', 'channel_two'], function (Message $message) {
    switch ($message->getType()) {
    case 'channel_one':
        //a
        break;
    case 'channel_two':
        //b
        break;
    }
}, 'user');

注意

注意真实通道名称如下：{microservice_name}_{channel_name}_{environment}