ruby - EventMachine、Redis 和 EM HTTP 请求

Question

我尝试从 Redis 存储中读取 URL 并简单地获取 URL 的 HTTP 状态。全部在 EventMachine 中。我不知道我的代码有什么问题，但它并不像预期的那样异步。

所有请求都是从第一个到最后一个发出的，奇怪的是我只在最后一个请求之后得到第一个响应(我想检查的 HTTP header )。有没有人暗示那里出了什么问题？

require 'eventmachine'
require 'em-hiredis'
require 'em-http'

EM.run do
  @redis = EM::Hiredis.connect
  @redis.errback do |code|
    puts "Error code: #{code}"
  end

  @redis.keys("domain:*") do |domains|
    domains.each do |domain|
      if domain
        http = EM::HttpRequest.new("http://www.#{domain}", :connect_timeout => 1).get
        http.callback do
          puts http.response_header.http_status
        end
      else
        EM.stop
      end
    end
  end
end

我正在为几千个域运行此脚本，因此我希望在发送最后一个请求之前获得第一个响应。

Answer 1

虽然 EventMachine 是异步的，但 react 器本身是单线程的。因此，当您的循环运行并触发那数千个请求时，在循环退出之前它们都不会被执行。然后，如果您调用 EM.stop，您将在 react 器执行之前停止它们。

您可以使用 EM::iterator 之类的东西将域的处理分解为让 react 器执行的 block 。然后，如果您真的想要 EM.stop，您需要施展魔法，在停止 react 堆之前保留已发送请求和收到响应的计数器。