3

我在 ruby​​ 方面不是很有经验（每天都用 java 编码），我正在尝试找到“Ruby 方式”来保留连接池之类的东西。我有一个带有多个线程的独立 Ruby 应用程序，我想出了类似下面的东西。

请注意，MongoClient为 Mongo 提供的原生 ruby​​ 驱动程序在内部维护连接池，所以我所需要的只是能够保留一个MongoClient周围的实例

require 'mongo'

module MongoPool

  # module instance var to ensures only one exists
  @mongo = nil

  def self.lazy_create
    @mongo ||= Mongo::MongoClient.new('localhost', 27017, :pool_size => 5, :timeout => 5)
  end

  # when getting connection lazily create pool by assigning to @mongo only if nil
  def connection
    MongoPool.lazy_create
  end

end

class PeopleRepository

  include MongoPool

  def random_person
    coll = connection['test']['people']
    coll.find_one
  end

end

# usage
PeopleRepository.new.find_one

我知道这是可行的（检查了在多次调用object_id中@mongo保持不变），但这是保留事物的首选方式吗？

可能有多个存储库，因此每个存储库都可以包含MongoPool和使用其连接。上述解决方案有什么缺点吗？还有其他我应该注意的方法吗？

注意：问题更多是关于如何以 Ruby 方式做事，而不是关于如何做一般的事情（因为我得到了它的工作）。

4

2 回答 2

5

您实际上并不需要另一个 gem 来执行此操作，实际上 Mongoid 的驱动程序 (Moped) 还不支持连接池。

与在 rails 中使用应用程序级常量的建议类似，您只需在无头应用程序中使用类变量，以便您的 MongoClient 实例在应用程序基类的所有调用中都是相同的单个对象/池实例。

例如，您可以执行以下操作：

require 'mongo'

class MyApplication
  include Mongo

  # creates a single class instance, sets pool size but won't connect until used (lazy)
  @@client = MongoClient.new('localhost', 27017, :pool_size => 5, :connect => false)

  def do_something
    @@client['my_db']['my_collection].insert({ "foo" => "bar"})
  end
end

简单而且非常直接。您在上面使用的模块方法不是必需的。

您提到了 Torquebox，所以我假设您正在使用 JRuby 并让 Torquebox 为您管理应用程序的线程池。

确保您正在运行 1.8.3 或更高版本的 mongo ruby​​ 驱动程序，其中包括一些主要修复和改进，以便在这种繁重的设置下运行。我们解决了一些线程安全问题并大大提高了连接池中的并发性。

希望有帮助。

于 2013-03-07T23:41:56.260 回答
2

假设您使用的是 Rails，我会这样做：

# config/initializers/mongo.rb
MONGODB = Mongo::MongoClient.new('localhost', 27017, :pool_size => 5, :timeout => 5)

当您使用诸如 mongomapper 之类的库时，可能有一些方法可以配置池并透明地使用它。

看看这里的 mongo 库：http ://railscasts.com/episodes/194-mongodb-and-mongomapper

于 2013-03-04T10:04:38.077 回答