A sample implementation of streaming server to make a lot concurrency connections. The connections are keepalived by server!

server.rb

require 'sinatra'
require 'eventmachine'

get '/' do
  stream :keep_open do |out|
    interval = 1
    size     = 1000
    EventMachine::PeriodicTimer.new(interval) { out << "#{gen_data(size)}\n" }
  end
end

post '/' do
  'ok'
end

def gen_data(length=10)  
  chars = 'abcdefghjkmnpqrstuvwxyzABCDEFGHJKLMNOPQRSTUVWXYZ23456789'  
  Array.new(length) { chars[rand(chars.length)].chr }.join  
end