ActiveJob：在没有完整的工作类别的情况下如何执行简单的操作？

Jacob 发表于 Dev

雅各布

使用delayed_job，我可以执行以下简单操作：

@foo.delay.increment!(:myfield)

Rails的新ActiveJob是否可以做同样的事情？（无需创建一堆执行这些小操作的作业类）

D面

ActiveJob只是在各种后台作业处理器之上的抽象，因此许多功能取决于您实际使用的提供者。但是，我将尽量不依赖任何后端。

通常情况下，工作提供者包括持久性机制和亚军。当卸载工作时，您以某种方式将其写入持久性机制，然后稍后一个运行者检索并运行它。所以问题是：您能否以与您需要的任何操作兼容的格式来表达您的工作数据？

那将是棘手的。

然后定义什么是工作定义。例如，它可以是单个方法调用。假设这种语法：

Model.find(42).delay.foo(1, 2)

我们可以使用以下格式：

{
  class: 'Model',
  id: '42', # whatever
  method: 'foo',
  args: [
    1, 2
  ]
}

现在，我们如何从给定的调用中构建这样的哈希并将其排队到作业队列中？

首先，看上去，我们需要定义一个类method_missing以捕获被调用的方法名：

class JobMacro
  attr_accessor :data
  def initialize(record = nil)
    self.data = {}
    if record.present?
      self.data[:class] = record.class.to_s
      self.data[:id]    = record.id
    end
  end
  def method_missing(action, *args)
    self.data[:method] = action.to_s
    self.data[:args] = args
    GenericJob.perform_later(data)
  end
end

工作本身必须像下面这样重构该表达式：

data[:class].constantize.find(data[:id]).public_send(data[:method], *data[:args])

当然，您必须delay在模型上定义宏。最好将其分解为模块，因为定义非常通用：

def delay
  JobMacro.new(self)
end

它确实有一些限制：

仅支持在持久化ActiveRecord模型上运行的作业。一项工作需要一种重构被调用者以调用该方法的方法，我选择了最可能的方法。如果需要，也可以使用封送处理，但是我认为这是不可靠的：在执行作业之前，未封送处理的对象可能无效。与“ GlobalID”相同。
它使用Ruby的反射。这是解决许多问题的诱人解决方案，但是它并不快，并且在安全性方面有点冒险。因此，请谨慎使用此方法。
仅一个方法调用。没有procs（您可能可以使用ruby2rubygem做到这一点）。依靠作业提供者正确地序列化参数，如果失败，可以使用您自己的代码来帮助它。例如，在que内部使用JSON，因此无论是在JSON中工作，还是在中工作que。例如，符号没有。