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

标签 mysql ruby ruby-on-rails-3 fork mysql2

我有一个 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

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

最佳答案

问题在于 fork 的进程继承了其父进程的一些资源,例如其文件描述符。特别是这样的一种共享资源是 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 等服务,你将不得不做类似的事情。

关于mysql - 在 Ruby on Rails 中使用 fork 创建并行进程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/8913476/

相关文章:

MYSQL 左连接不显示所有行

css - 如何单击出现在三个具有相同名称和相同 ID 的位置的表格内的链接

mysql - 如何使用 mysql 中同一个表的结果更新行?

mysql - 我可以在mysql数据库中获取最高数量的值吗?

javascript - 可以转换 .vtk 吗?

ruby-on-rails - 如何使用 Searchkick 限制最大结果数

ruby-on-rails - 如何使用大量可选 URL 参数在 Rails 3.x 中构建 SEO url?

ruby-on-rails-3 - 使用 Jasmine 和 Rails 3.1 测试 Coffeescript

ruby-on-rails - Rails 3.2 什么时候使用它缓存到磁盘的页面?

java.sql.SQLException : Invalid value for getShort() - ' '