sub.php

sub.php

<?php

$context = new ZMQContext();

// Socket to talk to server
$subscriber = new ZMQSocket($context, ZMQ::SOCKET_SUB);
$subscriber->connect("tcp://127.0.0.1:5555");

$subscriber->setSockOpt(ZMQ::SOCKOPT_SUBSCRIBE, 'hello');
$subscriber->setSockOpt(ZMQ::SOCKOPT_HWM, 10);

$count = 0;
$last = 0;

$start = round(microtime(true),2);
$i=0;
echo 'memory: '.memory_get_usage() . "\n";
while (true) {
        if ($subscriber->recv()) {
        $count++;
        }
        if (round(microtime(true),2)==$start+1) {
                echo $count-$last."\n";
                $last=$count;
                $start=round(microtime(true),2);
                echo 'memory: '.memory_get_usage() . "\n";
        }
}