raimx/zmq

ZeroMQ bindings for React.

v0.4.0 2018-05-18 15:27 UTC

Requires

• php: >=5.4.0
• ext-zmq: *
• evenement/evenement: ^3.0 || ^2.0
• react/event-loop: ^1.0 || ^0.5 || ^0.4

Requires (Dev)

• ext-pcntl: *
• phpunit/phpunit: ~4.8.35 || ~5.7 || ~6.4

MIT

• zeromq
• zmq

README

ZeroMQ bindings for React.

Install

The recommended way to install raimx/zmq is through composer.

composer require raimx/zmq

Example

And don't forget to autoload:

<?php
require 'vendor/autoload.php';

Here is an example of a push socket:

<?php

$loop = React\EventLoop\Factory::create();

$context = new React\ZMQ\Context($loop);

$push = $context->getSocket(ZMQ::SOCKET_PUSH);
$push->connect('tcp://127.0.0.1:5555');

$i = 0;
$loop->addPeriodicTimer(1, function () use (&$i, $push) {
    $i++;
    echo "sending $i\n";
    $push->send($i);
});

$loop->run();

And the pull socket that goes with it:

<?php

$loop = React\EventLoop\Factory::create();

$context = new React\ZMQ\Context($loop);

$pull = $context->getSocket(ZMQ::SOCKET_PULL);
$pull->bind('tcp://127.0.0.1:5555');

$pull->on('error', function ($e) {
    var_dump($e->getMessage());
});

$pull->on('message', function ($msg) {
    echo "Received: $msg\n";
});

$loop->run();

Todo

• Integration tests
• Buffer limiting
• Do not push messages if no listener

Tests

To run the test suite, you need PHPUnit.

$ phpunit

License

MIT, see LICENSE.