PyZMQ Basic Pub/Sub Interaction

client.py

import zmq

protocol = "tcp"
host = "tidmarsh.media.mit.edu"
port = "1305"

host = "127.0.0.1"
port = "5556"

# Socket to talk to server
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.setsockopt(zmq.SUBSCRIBE,'')

connect_to = "{}://{}:{}".format(protocol, host, port)
print connect_to
socket.connect(connect_to)
print "connected"

while True:
    print "Blocking, waiting for input..."
    string = socket.recv()
    print "Received: ", string

server.py

import zmq
import time

port = "5556"

context = zmq.Context()
socket = context.socket(zmq.PUB)
connect_to =  "tcp://*:%s" % port
print connect_to
socket.bind(connect_to)

while True:
    socket.send("Hello World!")
    time.sleep(1)