repejota/nats

A nats.io 客户端在 PHP 中

0.8.7 2018-06-09 15:32 UTC

README

Travis

覆盖率

简介

PHP 客户端用于 NATS 消息系统

要求

用法

安装

首先,让我们在我们的项目目录中下载 composer

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

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

{
  "require": {
    "repejota/nats": "dev-master"
  }
}

让我们让 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();
    }
);

开发者信息

发布

测试

测试位于 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,该文件检查文档块和不同的性能提示。

创建者

Raül Pérez

许可

MIT,请参阅 LICENSE