iris/nsq_to_swoole

使用swoole扩展的强大PHP客户端，用于NSQ

维护者

详细信息

github.com/iris-xie/nsq_to_swoole

主页

源代码

问题

安装次数: 4,812

依赖者: 0

建议者: 0

安全性: 0

星标: 33

关注者: 5

分支: 4

开放问题: 4

1.2.2 2017-11-14 00:58 UTC

Requires

MIT 6cc2aa80f712fdf5ede7032b6e89961e309e4eb4

phpclientSocketnsqswoole

This package is not auto-updated.

Last update: 2024-09-23 19:20:23 UTC

README

使用swoole扩展的强大PHP客户端，用于NSQ

必要组件

  • PHP >= 5.5
  • Swoole >= 1.8.6

安装

pecl install swoole

composer require iris/nsq_to_swoole

发布

客户端支持NSQ服务器集群，同时支持单条消息多条消息发送

$hosts = [
    ['host' => '192.168.9.135', 'port' => 4150],
];

$client = new Iris\NsqToSwoole\Client;
$client->setTarget($hosts, 1);

$client->pub('examples', 'Hello From iris-xie', 1);

订阅

首先通过lookup获取列表，然后才能订阅

$lookup = new Iris\NsqToSwoole\Lookup\Lookupd([
    ['host' => '192.168.9.135', 'port' => 4161],
]);

$client = new Iris\NsqToSwoole\Client;

$client->sub($lookup, 'examples', 'example', function($moniter, $msg) {
    echo sprintf("READ\t%s\t%s\n", $msg->getId(), $msg->getPayload());
});

使用示例

cd nsq_to_swoole/examples

发布（Pub）

php Pub.php

订阅（Sub）

php Sub.php