README

为 RabbitMQ 和 PHP 提供简单的发布-订阅。

要求

PHP 8.0, 8.1, 或 8.2
php-amqplib 所需的扩展

安装

composer require cerpus/pubsub

使用方法

use Cerpus\PubSub\Connection\ConnectionFactory;
use Cerpus\PubSub\PubSub;

$connectionFactory = new ConnectionFactory('localhost', 5672, 'guest', 'guest', '/');
$pubSub = new PubSub($connectionFactory->connect());

// publish your own messages
$pubSub->publish('some_other_topic', 'some data');

// listen for incoming messages
$pubSub->subscribe('subscriber_name', 'some_topic', function (string $data) {
    // do something with the data
    echo "$data\n";
});
$pubSub->listen();

未来范围

支持 ext-amqp, queue-interop
处理底层库的更多异常
支持配置标志，如自动删除等。

许可证

本软件包遵循 MIT 许可证发布。有关更多信息，请参阅 LICENSE 文件。

cerpus / pubsub

维护者

详细信息

README

要求

安装

使用方法

未来范围

许可证