Search by 
lizhichao / one-nsq
nsq client
1.0.3
2021-04-09 02:27 UTC
Requires
- php: >=5.6
- ext-bcmath: *
- ext-json: *
README
nsq https://nsq.io/ client
install
composer require lizhichao/one-nsq
example
$ct = new \OneNsq\Client('tcp://127.0.0.1:4150'); //$ct->auth('12345'); // subscribe $res = $ct->subscribe('test', 's2'); // $ct2 = new \OneNsq\Client('tcp://192.168.23.129:4150'); // $res2 = $ct2->subscribe('test2', 's1'); foreach ($res as $data) { // $data = $res2->current(); // $res2->next(); if ($data === null) { echo 'null' . PHP_EOL; echo "\n --------------- \n"; continue; } echo 'attempts:' . $data->attempts . PHP_EOL; echo 'msg:' . $data->msg . PHP_EOL; echo 'time:' . date('Y-m-d H:i:s', $data->timestamp) . PHP_EOL; echo "\n --------------- \n"; // $ct->touch($data->id); }; // publish for ($i = 0; $i < 6; $i++) { $ct->publish('test', 'msg:' . $i . ' time:' . date('Y-m-d H:i:s')); } for ($i = 0; $i < 3; $i++) { $ct->publishMany('test', [ 'm-msg:' . $i . '-1 time:' . date('Y-m-d H:i:s'), 'm-msg:' . $i . '-2 time:' . date('Y-m-d H:i:s'), 'm-msg:' . $i . '-3 time:' . date('Y-m-d H:i:s') ]); } for ($i = 0; $i < 6; $i++) { $ct->publish('test', 'd-msg:' . $i . ' time:' . date('Y-m-d H:i:s'), ($i + 1) * 1000); }