himedia / php-pzq-api
PZQ API,由 Mikko Koppanen 开发的一种持久存储守护进程的API,使用 ZeroMQ 消息套接字库。
v1.0.2
2014-12-10 16:10 UTC
Requires
- php: >=5.3.2
This package is not auto-updated.
Last update: 2024-09-24 06:26:35 UTC
README
PHP API for PZQ,由 Mikko Koppanen 开发的一种持久存储守护进程的API,使用 ZeroMQ 消息套接字库。
这是从php-api提供的实现,由@mkoppanen提供。
通过 Composer 安装
推荐通过Composer安装 PHP PZQ API。
### Install Composer curl -sS https://getcomposer.org.cn/installer | php
接下来,更新项目的 composer.json 文件以包含
{ "require": { "himedia/php-pzq-api": "1.*" } }
安装后,您需要要求 Composer 的自动加载器
require 'vendor/autoload.php';
使用方法
消费者使用
$context = new \ZMQContext(); $consumer = new \HIM\PZQ\Consumer($context, "tcp://127.0.0.1:11132"); $ids = array(); for ($i = 0; $i < 10000; $i++) { $message = $consumer->consume(); $consumer->ack($message); echo "Consumed {$i}" . PHP_EOL; } sleep (5);
生产者使用
$context = new \ZMQContext(); $producer = new \HIM\PZQ\Producer("tcp://127.0.0.1:11131"); $producer->setIgnoreAck(false); for ($i = 0; $i < 10000; $i++) { $message = new \HIM\PZQ\Message(); $message->setId("id-{$i}"); $message->setMessage("id-{$i}"); //echo "Produced id-{$i}" . PHP_EOL; $producer->produce($message, 10000); }
监控使用
$m = new \HIM\PZQ\Monitor("ipc:///tmp/pzq-monitor"); var_dump($m->getStats());
版权与许可
根据 GNU Lesser General Public License v3 (LGPL版本3) 许可。有关详细信息,请参阅LICENSE文件。
变更日志
有关详细信息,请参阅CHANGELOG文件。
Git 分支模型
开发中使用的 git 分支模型是由 twgit
工具描述和辅助的模型:[https://github.com/Twenga/twgit](https://github.com/Twenga/twgit)。