1

所以基本上我的目标是获得某种轻量级的 ruby​​ 守护程序（或 sidekiq/resque worker），它处理作业并通过 http 通知其他应用程序。应用程序本身不需要接收 http 请求，因此没有机架可以保持尽可能轻量级。我可以在循环中运行相当多的 ruby​​ 代码{}

所以尽量不使用 EventMachine 的反应器模式，而是使用光纤方法。在这种情况下，我会将 EM.run 或 EM.stop 放在哪里Thread.new { EM.run }似乎没有纤维意识，所以添加它不会产生回调？有没有一个em-synchrony替代方案？

#slow=true injects a sleep 3, so page 2 callback should output faster
require 'em-http-request'
require 'fiber'
def http_get(url)
  f = Fiber.current
  http = EventMachine::HttpRequest.new(url).get

  # resume fiber once http call is done
  http.callback { f.resume(http) }
  http.errback  { f.resume(http) }

  return Fiber.yield
end

puts "fetching some data from database for request params"
EventMachine.run do
  Fiber.new{
    page = http_get('http://localhost:3000/status?slow=true')
    puts "notified external page it responded with: #{page.response_header.status}"
  }.resume
  Fiber.new{
    page = http_get('http://localhost:4000/status')
    puts "notified external page 2 it responded with: #{page.response_header.status}"
  }.resume
  puts "Finishised notification task"
end
puts "Moving on to next task as fast as possible"
4

1 回答 1

-2

避免重新发明轮子，使用EM::Synchrony甚至更好地切换到赛璐珞或赛璐珞-io，因为 EM 似乎已经停止维护

于 2014-01-20T12:49:30.023 回答