EventMachine和循环

这是我的代码：

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所有内容在完成后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的工作原理，您就可以找到更优雅的方法来实现它。