EventMachine与循环

Question

这是我的代码：

EventMachine.run {

    conn = EM::Protocols::HttpClient2.connect request.host, 80

    req = conn.get(request.query)
    req.callback { |response|
      p(response.status)
      p(response.headers)
      p(response.content)
    }
}

回调激发，也就是说，我得到状态的字符串输出，等等。

但我想要做的是启动回调，然后重复。我计划实现更多的逻辑，比如每次调整URL，但现在，我只想让它：

1. 检索URL
2. 启动回调
3. 重复..。

我对这个模式的理解是，循环中的所有东西都会触发，然后返回，然后一直持续到我执行EM.stop为止。

现在，它检索URL数据，似乎只是挂起。

我需要做一些返回才能在这里继续吗？为什么它要挂起来，而不是一遍又一遍地循环？

如果我用循环包围整个上面的代码块。结束它的工作就像预期的那样。这是实现这一目标的正确方法吗？我想我很困惑，因为我认为EM.run中的所有东西在它完成时都会重复。

Answer 1

您给出的run块只运行一次。事件循环不是直接向您公开的，而是打算是不可见的。不要将run块与while循环混淆。它只运行一次和一次，但在执行事件循环时运行。

如果您想重复一个操作，您需要创建某种类型的堆栈并对其进行处理，每个回调检查堆栈是否还有更多的工作要做，然后发出另一个调用。EventMachine应用程序是使用这种回调链方法构建的。

您需要实现如下内容：

def do_stuff(queue, request = nil)
  request ||= queue.pop
  return unless (request)

  conn = EM::Protocols::HttpClient2.connect request.host, 80

  req = conn.get(request.query)
  req.callback { |response|
    p(response.status)
    p(response.headers)
    p(response.content)

    EventMachine.next_tick do
      # This schedules an operation to be performed the next time through
      # the event-loop. Usually this is almost immediate.
      do_stuff(queue)
    end
  }
end   

在您的事件循环中，您将踢出这条链：

EventMachine.run do
  queue = [ ... ] # List of things to do
  do_stuff(queue)
end

一旦您对EventMachine的工作方式有了更好的了解，您可能会找到一种更优雅的方法来实现这个功能。