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

Question

我在Apache上有一个Rails 3应用程序和Passenger在生产中。我有这样的代码：

class Billing < ActiveRecord::Base
  after_save :sendEmails

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

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

Answer 1

问题是forked进程继承了它的父进程的一些资源，比如它的文件描述符。特别地，一种这样的共享资源是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等服务，您将不得不执行类似的操作。

Answer 2

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

Answer 3

您可以在fork内部重新建立连接：

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