beta/rabbit.client

RabbitMQ 客户端

维护者

详细信息

github.com/beta-eto-code/rabbit.client

源代码

问题

安装: 0

依赖项: 0

建议者: 0

安全性: 0

星标: 0

关注者: 2

分支: 0

开放问题: 0

类型：lib

1.0.1 2024-01-31 08:04 UTC

Requires

MIT d29794b7296b118d7d0cdb251beed6bf0b2f8b89

  • Alexander Nesterov <alex19pov31.woop@gmail.com>

This package is auto-updated.

Last update: 2024-08-30 01:44:32 UTC

README

安装

composer require beta/rabbit.client

消费者工作示例

use RabbitClient\Client;

$client = Client::initByParams('127.0.0.1', 5672, 'testUser', 'somePassword', 'myVhost');
$message = $client->getMessage('my_topic', ['no_ask' => false]); // запрашиваем 1 сообщение из брокера
$message->getData(); // payload сообщения
$message->getOriginal(); // оригинальное сообщение AMQPMessage
$message->confirm(); // подтверждаем обработку сообщения

/**
* Перебираем новые сообщения из брокера
**/
foreach ($client->getMessageIterator('my_topic') as $message) {
    echo $message->getData();
    $message->confirm();
}

生产者工作示例

use RabbitClient\Client;

$client = Client::initByParams('127.0.0.1', 5672, 'testUser', 'somePassword', 'myVhost');
$client->sendMessage('Test message', 'my_topic');