ruby-on-rails – 如何正常重启delayed_job使用者？

我有一个基类,所有延迟的作业都从名为BaseJob继承：

class BaseJob
  attr_accessor :live_hash

  def before(job)
    # check to make sure that the version of code here is the right version of code
    resp = HTTParty.get("#{Rails.application.config.root_url}/revision")
    self.live_hash = resp.body.strip
  end

  def should_perform()
    return self.live_hash == GIT_REVISION
  end

  def perform()
    if self.should_perform == true
      self.safe_perform()
    end
  end

  def safe_perform()
    # override this method in subclasses
  end

  def success(job)
    if self.should_perform == false
      # log stats here about a failure

      # enqueue a new job of the same kind
      new_job = DelayedJob.new
      new_job.priority = job.priority
      new_job.handler = job.handler
      new_job.queue = job.queue
      new_job.run_at = job.run_at
      new_job.save
      job.delete

      # restart the delayed job system
      %x("export RAILS_ENV=#{Rails.env} && ./script/delayed_job stop")
    else
      # log stats here about a success
    end
  end

end

所有基类都继承自BaseJob并覆盖safe_perform以实际完成其工作.关于上述代码的一些假设：

> Rails.application.config.root_url指向应用程序的根目录(即：www.myapp.com)
>有一条被称为/修订的路线(即：www.myapp.com/revision)
>您的应用程序知道有一个名为GIT_REVISION的全局常量

我最终做的是将git rev-parse HEAD的输出放在一个文件中并用代码推送它.它会在启动时加载,因此可以在web版本和delayed_job使用者中使用.

当我们通过Capistrano部署代码时,我们不再停止,启动或重新启动delayed_job使用者.我们在每分钟运行的消费者节点上安装一个cronjob,并确定delayed_job进程是否正在运行.如果不是,那么将产生一个新的.

由于所有这些,满足以下所有条件：

>推送代码不会在delayed_job上等待重启/强制终止.当推送新代码时,正在运行的现有作业将保持不变.>如果消费者正在运行旧代码,我们可以检测作业何时开始.工作得到重新排列,消费者自杀.>当delayed_job死亡时,通过带有新代码的cronjob生成一个新的代码(根据启动delayed_job的性质,它有新代码).>如果您对杀死delayed_job消费者感到妄想,请安装一个与cron作业相同的nagios检查,但是当delayed_job进程没有运行5分钟时会提醒您.