A PHP client for the NATSio cloud messaging system.
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Failed to load latest commit information.
examples
spec/Nats
src/Nats Adds restore_error_handler to isTLSRequired error handler Aug 17, 2018
test
.gitignore Generate local coverage report Jul 6, 2017
.travis.yml
AUTHORS Created contributors May 25, 2016
CONTRIBUTORS
LICENSE
Makefile
Makefile.help.mk
README.md
VERSION
composer.json fixes php-coveralls package version for travis Mar 26, 2018
phpspec.yml Generate local coverage report Jul 6, 2017
phpunit.xml.dist
ruleset.xml

README.md

phpnats

Travis

Master Develop
Build Status Build Status

Coverage

Master Develop
Coverage Status Coverage Status

Introduction

A PHP client for the NATS messaging system.

Requirements

Usage

Installation

Let's start by downloading composer into our project dir:

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

Now let's tell composer about our project's dependancies, in this case, PHPNats. The way we do this is by creating a composer.json file, and placing it in the root folder of our project, right next to composer.phar

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

Let's let Composer work its magic:

php composer.phar install

Composer will download all the dependencies defined in composer.json, and prepare all the files needed to autoload them.

Basic Usage

$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();
    }
);

Encoded Connections

$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();
    }
);

Developer's Information

Releases

Tests

Tests are in the tests folder. To run them, you need PHPUnit and execute make test-tdd.

We also have a BDD test suite under the spec folder. To run the suite, you need PHPSpec and execute make test-bdd.

You can also execute the all suites ( TDD + BDD ) with make test.

Code Quality

We are using PHP Code Sniffer to ensure our code follow an high quality standard.

To perform an analysis of the code execute make lint.

There is currently three steps when we lint our code:

  • First we lint with php itself php -l
  • Then we lint with PSR2 standard
  • And finally we lint with a custom ruleset.xml that checks dockblocks and different performance tips.

Creators

Raül Pérez

License

MIT, see LICENSE