Lua ZMQ examples

client.lua

require 'zmq'

ctx = zmq.init(1)
socket = ctx:socket(zmq.REQ)
socket:connect 'tcp://localhost:4568'
k = 0

while k < 10 do
   msg = string.format('ping %d', k)
   socket:send(msg)
   print(socket:recv())
   k = k + 1
   os.execute 'sleep 1'
end

socket:close()
ctx:term()

pub.lua

require 'zmq'

ctx = zmq.init(1)
socket = ctx:socket(zmq.PUB)
socket:bind 'tcp://*:4568'

while true do
   zip = math.random(89999) + 10000
   temp = math.random(70) + 50 -- temp range 50 .. 120; welcome to Texas
   socket:send(string.format('%d %d', zip, temp))
end

socket:close()
ctx:term()

server.lua

require 'zmq'

ctx = zmq.init(1)
socket = ctx:socket(zmq.REP)
socket:bind 'tcp://*:4568'

while true do
   s = socket:recv()
   print(string.format('Echoing %q', s))
   socket:send(s)
end

socket:close()
ctx:term()

sub.lua

require 'zmq'

ctx = zmq.init(1)
socket = ctx:socket(zmq.SUB)
socket:setopt(zmq.SUBSCRIBE, '78701')
socket:connect 'tcp://localhost:4568'

while true do
   print(socket:recv())
end

socket:close()
ctx:term()