andrzejkupczyk/redis-messenger

此包已被弃用且不再维护。未建议替代包。

无框架依赖的 Redis Streams 客户端

维护者

详细信息

github.com/andrzejkupczyk/redis-messenger

源代码

问题

安装: 528

依赖者: 1

建议者: 0

安全: 0

星标: 1

关注者: 1

分支: 0

开放问题: 0

dev-master / 1.0.x-dev 2020-11-25 10:42 UTC

Requires

Requires (Dev)

Suggests

MIT 407296119332fd272a8531f4086163b6ec0ad4a6

This package is auto-updated.

Last update: 2021-09-25 12:42:44 UTC

README

PHP requirement Code quality

无框架依赖的 Redis Streams 客户端。

使用示例

此包旨在支持所有可用的 Redis Streams 命令。以下列出的示例仅展示了最简单的用法，但 更多示例 可在提供的链接中找到。

发布消息

use WebGarden\Messaging\Client;
use WebGarden\Messaging\Redis\{Entry,Stream};

$client = Client::connect('redis');

$client
    ->to(new Stream('mystream'))
    ->add(
        Entry::compose(['name' => 'Sara', 'surname' => 'OConnor']),
        Entry::compose(['field1' => 'value1', 'field2' => 'value2'])
    );

消费消息

use WebGarden\Messaging\Client;
use WebGarden\Messaging\Redis\Stream;
use WebGarden\Messaging\Events\ItemReceived;

$client = Client::connect('redis');

$client
    ->from(new Stream('mystream'))
    ->on('reader.item_received', function (ItemReceived $event) {
        printf("Received item %s\n", $event->entry->id());
    })
    ->followNewEntries();

安装

通过 Composer

composer require andrzejkupczyk/redis-messenger

ℹ️️ 包需要 PhpRedis PHP 扩展