wuclient-dblfilter.php

<?php
/*
*  Weather update client
*  Connects SUB socket to tcp://localhost:5556
*  Collects weather updates and finds avg temp in zipcode
* @author Ian Barber <ian(dot)barber(at)gmail(dot)com>
*/

$context = new ZMQContext();

//  Socket to talk to server
echo "Collecting updates from weather server…", PHP_EOL;
$subscriber = new ZMQSocket($context, ZMQ::SOCKET_SUB);
$subscriber->connect("tcp://localhost:5556");

//  Subscribe to zipcode, default is NYC, 10001
$subscriber->setSockOpt(ZMQ::SOCKOPT_SUBSCRIBE, '10001 ');
$subscriber->setSockOpt(ZMQ::SOCKOPT_SUBSCRIBE, '10002 ');

while (true) {
    $string = $subscriber->recv();
    print "Got $string\n";
}