gistfile1.txt

require "msgpack"
require "socket"

class Bar
end

class Server
  attr_accessor :server, :exit_now
  def initialize
    @server = TCPServer.new("0.0.0.0", 8123)
    @exit_now = false
    Thread.abort_on_exception = true
  end

  def start
    loop do
      puts "Waiting for client connections"
      if sock = server.accept
        puts "Accepted a client #{sock}"
        process_client_connection(sock)
      end
    end
  end

  def process_client_connection(socket)
    unpacker = MessagePack::Unpacker.new(socket)

    unpacker.each do |message|
      p message
    end
  end
end

Server.new.start

gistfile2.txt

require "msgpack"
require "socket"
require "pry"

socket = TCPSocket.new("localhost", 8123)
packer = MessagePack::Packer.new(socket)
packer.write({:hello => "world"})
packer.flush()
socket.close()