发生错误中止 EventMachine 进程

Question

我正在创建一个后台脚本，该脚本使用 EventMachine 通过 WebSocket 连接到服务器。该脚本将使用 DelayedJob 或 Resque 运行。我已经能够让它与 WebSockets 服务器通信并发送消息，但是每当 EventMachine 循环中出现错误时，它都不会导致脚本崩溃 - 这是应该发生的事情（也是我需要发生的事情） 。我不必使用 EventMachine，因为我只发送 WebSocket 消息而不接收它们 - 但我希望得到任何帮助:) 谢谢！

#!/usr/bin/env ruby
require 'rubygems'
require 'eventmachine'
require 'em-http'

class Job
  include EventMachine::Deferrable

  def self.perform
    job = Job.new
    EventMachine.run {
      http = EventMachine::HttpRequest.new("ws://localhost:8080/").get :timeout => 0

      http.errback { puts "oops" }
      http.callback {
        puts "WebSocket connected!"
        http.send("Hello watcher")
      }

      http.stream { |msg| }
      job.callback { puts "done" }
      Thread.new { 
        job.execute(http)
        http.close
        EventMachine.stop
      }
    }
  end

  def execute(h)
      sleep 1
      puts "Job Runner!"
      h.send("welcome!")
      sleep 2
      asdsadsa # here I am trying to simulate an error
      sleep 1
      h.send("we are all done!")
      sleep 1
      set_deferred_status :succeeded
  end
end

Job.perform

Answer 1

由于您在线程内引发异常，因此应该设置 Thread.abort_on_exception设置为 true 否则这些错误将不会正确引发。

Answer 2

这里根本不需要使用 Thread.new，事实上，这样做不是线程安全的（eventmachine 本身不是线程安全的，除了 EM::Queue、EM::Channel 和 EM.schedule）。

如果你想在执行中做同步的事情，并且你必须有那个线程，那么，你需要通过 EM.schedule 调用 h.send，例如：

EM.schedule { h.send("welcome!") }

如果你必须以这种方式有那个线程，那么，你想要捕获您自己生成的线程中的异常。然后，您应该自行停止和关闭，或者只是在主（事件机器）线程中重新启动：

EM.run do
  thread = Thread.new do
    raise 'boom'
  end
  EM.add_periodic_timer(0.1) { thread.join(0) }
end

如果合适，上述模式可以轻松地枚举周期性计时器中的线程数组。

最后请注意，仅在 EventMachine > 中支持异常冒泡（正确的异常报告）。 1.0，仍处于测试阶段。要在发生异常时获取可用的回溯，可以使用 gem install eventmachine --pre，或者更好的是使用 Github 存储库中的 master。