annon / nsqclient

又一个NSQ库。

维护者

详细信息

github.com/wanganfu/nsqclient

源代码

安装: 10

依赖者: 1

建议者: 0

安全: 0

星标: 0

关注者: 0

分支: 12

0.0.2 2023-12-22 08:56 UTC

Requires

Suggests

  • ext-pcntl: graceful shutdown

MIT d3a14d06a4ac8745f64cad3efc0192deefc88cf5

nsq

This package is auto-updated.

Last update: 2024-09-15 05:29:00 UTC

README

又是为 NSQ 开发的PHP客户端。

安装（通过composer）

composer require moolex/nsqclient dev-master

使用

发布

$topic = 'my_topic';
$endpoint = new \NSQClient\Access\Endpoint('http://127.0.0.1:4161');
$message = new \NSQClient\Message\Message('hello world');
$result = \NSQClient\Queue::publish($endpoint, $topic, $message);

发布（延迟）

$topic = 'my_topic';
$endpoint = new \NSQClient\Access\Endpoint('http://127.0.0.1:4161');
$message = (new \NSQClient\Message\Message('hello world'))->deferred(5);
$result = \NSQClient\Queue::publish($endpoint, $topic, $message);

发布（批量）

$topic = 'my_topic';
$endpoint = new \NSQClient\Access\Endpoint('http://127.0.0.1:4161');
$message = \NSQClient\Message\Bag::generate(['msg data 1', 'msg data 2']);
$result = \NSQClient\Queue::publish($endpoint, $topic, $message);

订阅

$topic = 'my_topic';
$channel = 'my_channel';
$endpoint = new \NSQClient\Access\Endpoint('http://127.0.0.1:4161');
\NSQClient\Queue::subscribe($endpoint, $topic, $channel, function (\NSQClient\Contract\Message $message) {
    echo 'GOT ', $message->id(), "\n";
    // make done
    $message->done();
    // make retry immediately
    // $message->retry();
    // make retry delayed in 10 seconds
    // $message->delay(10);
});