1

我试图了解如何在 Ruby 中使用各种非阻塞 IO 库,并制作了一个简单的应用程序来使用 Sinatra 进行测试,

# proxy.rb
require 'bundler/setup'
require 'sinatra/base'
require 'sinatra/synchrony'
require 'faraday'

class ProxyApp < Sinatra::Base
  register Sinatra::Synchrony

  get "/proxy" do
    conn = Faraday.new("http://mirror.yandex.ru") do |faraday|
      faraday.use Faraday::Adapter::EMSynchrony
    end
    conn.get "/ubuntu-releases/precise/ubuntu-12.04.1-alternate-i386.iso"
    "Hello, world"
  end

  get "/" do
    "Hello, world"
  end
end

据我了解,使用非阻塞 IO 下载文件应该允许执行其他请求,但它不会 - 如果我使用ab打开/proxy路径(我使用 Thin 作为应用程序服务器),请求/接受很长一段时间。难道我做错了什么?

4

1 回答 1

2

西纳特拉::同步?为什么?

配置.ru:

require File.join Dir.pwd, 'proxy.rb'
run Proxy

宝石文件:

source 'https://rubygems.org'

gem 'sinatra'
gem 'thin'
gem 'faraday'
gem 'em-synchrony'
gem 'em-http-request'
gem 'rack-fiber_pool'

代理.rb:

require 'bundler'
Bundler.require

class Proxy < Sinatra::Base
  use Rack::FiberPool

  get "/proxy" do
    conn = Faraday.new("http://mirror.yandex.ru") do |faraday|
      faraday.use Faraday::Adapter::EMSynchrony
    end
    conn.get "/ubuntu-releases/precise/ubuntu-12.04.1-alternate-i386.iso"
    "Hello, world"
  end

  get "/" do
    "Hello, world"
  end
end

开始:

thin start -d
wget localhost:3000/proxy

在另一个终端:

wget localhost:3000/

无论您在并行中对 /proxy 提出多少请求,都会立即回复 /。

于 2012-09-25T13:00:15.193 回答