一个简单的delay server

#!/usr/bin/env ruby

require 'rubygems'
require 'optparse'
require 'eventmachine'

require 'evma_httpserver'
require 'rack'

options = {
  :Port        => 3000,
  :Host        => "0.0.0.0",
  :environment => (ENV['RAILS_ENV'] || "development").dup
}

ARGV.clone.options do |opts|
  opts.on("-p", "--port=port", Integer,
          "Runs Delay Server on the specified port.", "Default: 3000") { |v| options[:Port] = v }
  opts.on("-b", "--binding=ip", String,
          "Binds Delay Server to the specified ip.", "Default: 0.0.0.0") { |v| options[:Host] = v }

  opts.on("-e", "--environment=name", String,
          "Specifies the environment to run this server under (test/development/production).",
          "Default: development") { |v| options[:environment] = v }

  opts.separator ""

  opts.on("-h", "--help", "Show this help message.") { puts opts; exit }

  opts.parse!
end

puts "=> Delay Server  starting on http://#{options[:Host]}:#{options[:Port]}"


ENV["RAILS_ENV"] = options[:environment]


require(File.join(File.dirname(__FILE__), 'config', 'boot'))
require(File.join(File.dirname(__FILE__), 'config', 'environment'))


class DelayServer < EM::Connection
  include EM::HttpServer

  def post_init
    super
  end

  def process_http_request

    params = Rack::Utils.parse_query(@http_query_string)
    
    response = EM::DelegatedHttpResponse.new(self)
    response.status = 200
    response.content_type 'text/html'

    current_time = Time.now
    response.content = "request time -> #{current_time.to_s(:db)} / delay time -> #{params['delay']}s\n"

    EM::add_timer(params["delay"]) do
      p params["operate"]
      puts Time.now.to_s(:db)
    end

    response.send_response
  end
end


trap(:INT) { exit }

puts "=> Ctrl-C to shutdown server"

EM.run{
  EM.start_server options[:Host], options[:Port], DelayServer
}

class XxxController < ApplicationController
  def build
   #.................
   system('%Q{url  "http://0.0.0.0:3000?delay=10&operate=build"  > ./log/delay_server.log 2>&1 &})
   #.................
  end
end

#!/usr/bin/env ruby

require 'rubygems'
require 'optparse'
require 'eventmachine'
require 'evma_httpserver'
require 'rack'

options = {
  :Port        => 3000,
  :Host        => "0.0.0.0",
  :environment => (ENV['RAILS_ENV'] || "development").dup
}

ARGV.clone.options do |opts|
  opts.on("-p", "--port=port", Integer,
          "Runs Delay Server on the specified port.", "Default: 3000") { |v| options[:Port] = v }
  opts.on("-b", "--binding=ip", String,
          "Binds Delay Server to the specified ip.", "Default: 0.0.0.0") { |v| options[:Host] = v }

  opts.on("-e", "--environment=name", String,
          "Specifies the environment to run this server under (test/development/production).",
          "Default: development") { |v| options[:environment] = v }

  opts.separator ""

  opts.on("-h", "--help", "Show this help message.") { puts opts; exit }

  opts.parse!
end

puts "=> Delay Server  starting on http://#{options[:Host]}:#{options[:Port]}"



ENV["RAILS_ENV"] = options[:environment]



require(File.join(File.dirname(__FILE__), 'config', 'boot'))
require(File.join(File.dirname(__FILE__), 'config', 'environment'))




class DelayServer < EM::Connection
  include EM::HttpServer

  def post_init
    super
  end

  def process_http_request

    #params = Rack::Utils.parse_query(@http_query_string)
    
    response = EM::DelegatedHttpResponse.new(self)
    response.status = 200
    response.content_type 'text/html'

    response.content = "ok"


    EM::add_timer(10) do
      sleep 0.5
      $count += 1
      p Time.now.to_s(:db) + "--->#{$count}"
    end

    response.send_response
  end
end



trap(:INT) { exit }

puts "=> Ctrl-C to shutdown server"



EM.run{
  $count = 0
  EM.start_server options[:Host], options[:Port], DelayServer
}

ab -c50 -n100 http://0.0.0.0:3000/