这是我的代码:
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,但现在我只想:
- 检索网址
- 触发回调
- 重复...
我对这种模式的理解是,循环中的所有内容都会触发,然后返回,然后永远持续下去,直到我执行EM.stop
.
现在,它检索 URL 数据,并且似乎挂起。
我需要进行某种退货才能继续这里吗?为什么它挂着,而不是一遍又一遍地循环?
如果我用循环 do ... end 包围整个上面的代码块,它会按预期工作......这是实现这个的正确方法吗?我想我很困惑,因为我认为里面的一切EM.run
完成后重复。
The run
阻止您只运行一次。事件循环不会直接暴露给您,但它是不可见的。不要混淆run
块与while
环形。它只运行一次,但它运行了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 的工作原理,您可能会找到一种更优雅的方法来实现这一点。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)