limitium/zmq

Brokers for ZeroMQ from TA:map project used for distributed parsing system.

dev-master 2015-05-05 12:01 UTC

Requires

• php: >=5.4.0
• ext-zmq: *
• psr/log: ~1.0

Requires (Dev)

• phpunit/phpunit: ~4.6

MIT

• limitium

• queue
• message
• zmq
• 0mq
• psr-3
• broker

README

Brokers for ZeroMQ from TA:map project used for distributed parsing system.

Install(debian)

1. Install ZeroMQ

    sudo apt-get update -qq
    sudo apt-get install -y libzmq3-dev

2. Install php-zmq binding

    git clone https://github.com/mkoppanen/php-zmq.git
    sh -c "cd php-zmq && phpize && ./configure && make --silent && sudo make install"
    echo "extension=zmq.so" >> `php --ini | grep "Loaded Configuration" | sed -e "s|.*:\s*||"`

3. Require ZMQ via Composer

    composer require limitium/zmq

Tests

    phpunit

Usage

PSR-3 distributed logger

Can be used in single process, several process on single machine or on several machines.

logger

    $logger = new ZLogger('my_service_1', 'tcp://127.0.0.1:5555');
    $logger->info("core is stable");
    $logger->emergency("we're all going to die!");

collector

    (new Concentrator('tcp://127.0.0.1:5555'))
        ->setReceiver(function ($logMsg) {
            $serviceName = $logMsg[0];
            $time = $logMsg[1];
            $logLevel = $logMsg[2];
            $logMsg = $logMsg[3];
        })
        ->listen();

Task generator

With workers management (checks workers statuses, checks workers heartbeats etc)

Generator

    (new Ventilator('tcp://127.0.0.1:5555'))
        ->setGenerator(function () {
            sleep(1);
            return rand();
        })
        ->setResponder(function ($msg) {
            echo $msg;
        })
        ->listen();

Worker

    (new Worker('tcp://127.0.0.1:5555'))
        ->setExecutor(function ($msg) {
            return $msg + $msg;
        })
        ->work();

Publish/Subscribe

Publisher

    $pub = new Publisher('tcp://127.0.0.1:5555');
    $pub->send('azaza');

Subscriber

    (new Subscriber('tcp://127.0.0.1:5555'))
        ->setListener(function ($msg){
            echo $msg;
        })
        ->listen();