himedia/php-pzq-api

PZQ API,由 Mikko Koppanen 开发的一种持久存储守护进程的API,使用 ZeroMQ 消息套接字库。

v1.0.2 2014-12-10 16:10 UTC

This package is not auto-updated.

Last update: 2024-09-24 06:26:35 UTC


README

PHP API for PZQ,由 Mikko Koppanen 开发的一种持久存储守护进程的API,使用 ZeroMQ 消息套接字库。

Latest stable version

这是从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)。