README

简介

这是一个 PHP 客户端，用于NATS 消息系统。这是 repejota 修改的 phpnats 的分支，支持 NATS 的较新版本（2.2.0-beta）并包含了一些改进，以更好地适应 PHP7 环境。

要求

• php 7.1+
• gnatsd

用法

安装

首先，将 composer 下载到我们的项目目录中

curl -O http://getcomposer.org/composer.phar
chmod +x composer.phar

现在，让我们让 composer 知道我们项目的依赖项，在这种情况下，PHPNats。我们这样做是通过创建一个 composer.json 文件，并将其放置在我们项目的根目录中，紧挨着 composer.phar

{
  "require": {
    "workfront/nats": "^2.2.3"
  }
}

让 Composer 展示其魔力

php composer.phar install

Composer 将下载 composer.json 中定义的所有依赖项，并为它们准备所有必要的自动加载文件。

基本用法

$client = new \Nats\Connection();
$client->connect();

// Publish Subscribe

// Simple Subscriber.
$client->subscribe(
    'foo',
    function ($message) {
        printf("Data: %s\r\n", $message->getBody());
    }
);

// Simple Publisher.
$client->publish('foo', 'Marty McFly');

// Wait for 1 message.
$client->wait(1);

// Request Response

// Responding to requests.
$sid = $client->subscribe(
    'sayhello',
    function ($message) {
        $message->reply('Reply: Hello, '.$message->getBody().' !!!');
    }
);

// Request.
$client->request(
    'sayhello',
    'Marty McFly',
    function ($message) {
        echo $message->getBody();
    }
);

编码连接

$encoder = new \Nats\Encoders\JSONEncoder();
$options = new \Nats\ConnectionOptions();
$client = new \Nats\EncodedConnection($options, $encoder);
$client->connect();

// Publish Subscribe

// Simple Subscriber.
$client->subscribe(
    'foo',
    function ($payload) {
        printf("Data: %s\r\n", $payload->getBody()[1]);
    }
);

// Simple Publisher.
$client->publish(
    'foo',
    [
     'Marty',
     'McFly',
    ]
);

// Wait for 1 message.
$client->wait(1);

// Request Response

// Responding to requests.
$sid = $client->subscribe(
    'sayhello',
    function ($message) {
        $message->reply('Reply: Hello, '.$message->getBody()[1].' !!!');
    }
);

// Request.
$client->request(
    'sayhello',
    [
     'Marty',
     'McFly',
    ],
    function ($message) {
        echo $message->getBody();
    }
);

开发者信息

版本

• 最新稳定版

• 最新开发版

• PHPNats 在 Packagist 上

测试

测试文件位于 tests 目录下。要运行它们，您需要 PHPUnit 并执行 make test-tdd。

我们还在 spec 目录下有一个 BDD 测试套件。要运行该套件，您需要 PHPSpec 并执行 make test-bdd。

您还可以使用 make test 执行所有套件（TDD + BDD）。

代码质量

我们使用 PHP Code Sniffer 来确保我们的代码遵循高标准。

要分析代码，请执行 make lint。

在执行代码审查时，目前有三个步骤

• 首先使用 PHP 本身进行审查 php -l
• 然后使用 PSR2 标准
• 最后使用自定义的 ruleset.xml 进行审查，检查 doxygen 注释和不同的性能提示。

创建者

Raül Pérez

• https://twitter.com/repejota
• https://github.com/repejota

许可证

MIT，请参阅 LICENSE