camry/nsqclient

该软件包已被废弃且不再维护。未建议替代软件包。

维护者

详细信息

github.com/camry/nsqclient-php

源代码

安装: 562

依赖: 0

建议者: 0

安全: 0

星标: 0

关注者: 1

分支: 11

0.1.2 2019-08-20 07:54 UTC

Requires

Suggests

  • ext-pcntl: graceful shutdown

MIT 79463e46b5c88bb6eb2cd165924d6bec00d17bef

nsq

This package is auto-updated.

Last update: 2022-12-20 15:50:32 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);
});