README

ZeroMQ bindings for Swoole.

Install

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

{
 "require": {
 "swoole/zmq": "0.1.*"
 }
}

composer require swoole/zmq

Example

And don't forget to autoload:

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

Here is an example of a push socket:

$zmq = new Swoole\Async\ZMQ();

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

$zmq->bind('tcp://0.0.0.0:9530');

And the pull socket that goes with it:

$zmq = new Swoole\Async\ZMQ();

$zmq->connect('tcp://0.0.0.0:5555');

Swoole\Timer::tick(1000, function () use ($zmq)
{
 static $i = 0;
 $msg = "hello-" . $i++;
 echo "Sending: $msg\n";
 $zmq->send($msg);
});