zmq-vs-nats.rb

require "nats/client"

def get_request
  start = nil
  
  NATS.start(:servers => ['nats://198.199.103.139:4222']) do
    start = Time.now
    
    NATS.subscribe('demo') do |msg, reply|
      NATS.publish(reply, "Polo!")
    end

    NATS.request('demo', "Marcko...") do |response|
      duration = Time.now - start
      puts "Duration: #{duration * 1000} ms"
      NATS.stop
    end
  end
end


Thread.new do
  message = ''
  while ZMQ::Util.resultcode_ok?(rc)
    rc = rep_sock.recv_string(message)   
    puts "Received request '#{message}'"
    rc = rep_sock.send_string('Polo!')
  end
end

require 'ffi-rzmq'
ctx = ZMQ::Context.create(1)
req_sock = ctx.socket(ZMQ::REQ)
rc = req_sock.connect('tcp://198.199.103.139:5000')

require 'benchmark'
def bench(req_sock)
  Benchmark.measure do
    rc = req_sock.send_string('Marco...')
    rep = ''
    rc = req_sock.recv_string(rep)
    rep
  end
end

bench(req_sock)