在 Ruby on Rails 中使用 fork 创建并行进程

Posted 2023-02-24

【中文标题】在 Ruby on Rails 中使用 fork 创建并行进程

【英文标题】：Using fork in Ruby on Rails for creating parallel process

【发布时间】：2012-02-13 08:52:15

【问题描述】：

我有一个 Rails 3 应用程序正在使用 Apache 上的Passenger 进行生产。我有这个代码：

class Billing < ActiveRecord::Base
  after_save :sendEmails

  private
    def sendEmails
      fork do 
        UserMailer.clientBilling(self.user, self).deliver
      end
    end
end

在 localhost 中，当应用程序创建帐单时，保存后，应用程序会向用户发送一封电子邮件，一切正常。但是在服务器中，在应用程序创建帐单后，它会抛出与 gem mysql2 相关的错误，例如“MySQL 服务器已消失”或“连接丢失”等错误，并且应用程序不会发送电子邮件。如果我删除叉子它工作正常，但我想使用叉子，我想创建一个单独的进程，因为发送电子邮件需要很长时间。可能是什么问题？

【参考方案1】：

在使用带有rails/passenger 的fork 时要格外小心，它会变得非常混乱！相反，您应该使用 resque or delayed_job 来完成此任务！

【讨论】：

我花了 7 天时间才发现错误消息“Mysql::Error: Lost connection to MySQL server during query”和“Mysql::Error: MySQL server has gone away”是由于使用叉子。

【参考方案2】：

问题在于分叉的进程继承了其父进程的一些资源，例如其文件描述符。特别是这样的一种共享资源是 MySQL 连接。当子进程完成其电子邮件发送并退出时，它会关闭 MySQL 连接，从而关闭父进程的连接。

如果您确实继续沿着这条路走下去（并且充满了类似的微妙之处），那么您需要执行以下操作：

# Clear existing connections before forking to ensure they do not get inherited.
::ActiveRecord::Base.clear_all_connections! 

fork do
  # Establish a new connection for each fork.
  ::ActiveRecord::Base.establish_connection 
  
  # The rest of the code for each fork...
end

如果你使用 memcached 或 mongodb 等服务，你将不得不做类似的事情。

【讨论】：

你知道继承了哪些资源吗？我认为进程叉复制整个过程？整个 rails 环境不是又加载到一个 fork 上了吗？

它复制整个过程，但文件描述符指的是完全相同的文件（参见 fork 的手册页）

我发现establish_connection 并不总是必要的，因为 ActiveRecord 通常会透明地管理它。

我认为活动记录现在会自动执行此操作，但我认为这是一个相对较新的变化

@FrederickCheung 你绝对是个天才。很好地解释了它，而不仅仅是提供解决方案。这个解释很有道理。甚至（尤其是？）在 2021 年。谢谢！

【参考方案3】：

您可以在分叉内重新建立连接：

dbconfig = YAML::load(File.open('your_app_dir/config/database.yml'))
ActiveRecord::Base.establish_connection(dbconfig['development'])