establish connection

慎用establish connection

在一个Rails应用中连接多个数据库，我们常常这么做:

Ruby代码

class Cookie < ActiveRecord::Base
establish_connection :monitor_spider
...
end

这样，在使用Cookie.find等操作的时候，就会连接到database.yml中monitor_spider配置的数据库上操作。

以前一直都这么用，没发现什么不妥。最近一个项目，由于启动的进程比较多，老是碰到数据库连接池链接获取超时的错误。通过MySQL Client用命令:show processlist;

发现数据库连接数量一直居高不下，轻轻松松就上2k+的连接。通过读Rails框架的connection_pool.rb文件代码，发现在各模型中用 establish_connection连接数据库会造成很大的问题。文件中类ConnectionHandler的 establish_connection方法代码如下：

Ruby代码

def establish_connection(name, spec)
@connection_pools[name] = ConnectionAdapters::ConnectionPool.new(spec)
end

对应上面Cookie模型的配置，这里name的值会是Cookie。也就是说，有10个模型中使用了establish_connection配置，@connection_pools中就会初始化10个ConnectionPool，如果每个ConnectionPool的pool size是20，那么应用运行的时候，将需要200(10 × 20)个数据库连接。而我的应用中有两类模型（连接到两个数据库），模型总数40+。按establish_connection的方式设置数据库连接，那么mysql的连接轻易就被消耗完了。

那要怎么处理呢？

我现在的思路是自己来维护数据库连接池。

首先，对ConnectionAdapters进行一下改造，将如下代码放到initializers中：

Ruby代码

module ActiveRecord
module ConnectionAdapters
class ConnectionHandler
def specified_establish_connection(name, spec)
@connection_pools[name] = ConnectionAdapters::ConnectionPool.new(spec)
end
def retrieve_connection_pool(klass)
if klass.respond_to?(:pool_name)
pool = @connection_pools[klass.pool_name]
# ActiveRecord::Base.logger.info "pool: #{pool.inspect}"
return pool if pool
end
pool = @connection_pools[klass.name]
# puts pool.inspect
return pool if pool
return nil if ActiveRecord::Base == klass
retrieve_connection_pool klass.superclass
end
end
end
end

在environment.rb中事先连接建立数据库连接池：

Ruby代码

#specified pool
config = YAML::load(File.open("config/database.yml"))
%w(monitor_center monitor_spider).each do |pool_name|
spec = config[pool_name]
adapter_method = "#{spec["adapter"]}_connection"
ActiveRecord::Base.connection_handler.specified_establish_connection(pool_name, ActiveRecord::Base::ConnectionSpecification.new(spec, adapter_method))
end

在模型中，定义方法pool_name：

Ruby代码

class TaskStat < ActiveRecord::Base
def self.pool_name;"monitor_spider";end
...
end
class TaskInfo < ActiveRecord::Base
def self.pool_name;"monitor_center";end
...
end

这样，TaskStat就会用monitor_spider pool，TaskInfo会用monitor_center pool。同时整个应用就只有三个ConnectionPool（外加默认的ActiveRecord::Base的）

通过这样的改造之后，效果明显，现在show processlist一般只有200~300的连接数。

转载于:https://www.cnblogs.com/qinyan20/p/3643130.html

establish connection相关推荐

Chrome报错：Unchecked runtime.lastError: Could not establish connection. Receiving end does not exist.
Chrome报错:Unchecked runtime.lastError: Could not establish connection. Receiving end does not exist. ...
Could not establish connection to hadoop0:10000/default: Connection refused: connect
今天在完成Hive的安装配置后,通过java客户端连接Hive进行操作时抛了一个异常: Exception in thread "main" java.sql.SQLExcepti ...
报错：Unchecked runtime.lastError:Could not establish connection. Receiving end does not exist.
报错:Unchecked runtime.lastError:Could not establish connection. Receiving end does not exist. 解决办法: 打 ...
VSCode远程链接Could not establish connection to “hz.matpool.com”
VS Code远程链接报错Could not establish connection to "hz-t2.matpool.com" 输出的部分内容安装Git git for w ...
VS Code远程链接报错Could not establish connection to “hz-t2.matpool.com”
VS Code远程链接报错Could not establish connection to "hz-t2.matpool.com" 输出的部分内容 ## 解决方法1 git fo ...
VScode远程连接出错 Could not establish connection. Cannot read properties of undefined (reading ‘replace‘)
出现问题 2022.9.11 使用vscode ssh远程服务器时突然发现如下提示: Could not establish connection to "xx.xx.xx.xx" ...
【VSCode】Could not establish connection The VS Code Server failed to start的三种原因和三种解决方案
一.sever断连解决方案:cmd+shift+p调出Command Palette,键入Remote-SSH,选择 Kill VS code Server on Host- 使用vscode重新连 ...
CLion 2021.1 WSL 2报错cannot establish connection的解决方法
昨天 CLion 2021.1.2 版本连接 WSL 2 用的好好的重启一下电脑以后突然不能用了: 尝试过WSL2 unable to establish connection : CPP-17763 ...
VSCode远程连接服务器报错：Could not establish connection to “xxxxxx”【已解决】
假设你已经做好了如下配置和尝试在Extensions中安装好了Remote -SSH 添加了你要访问的服务器ip地址等信息,并拥有了一个config文件(如下图) 请记住这个config文件的路径, ...
Google Chrome 插件开发: 无法建立连接, 接收端不存在. Could not establish connection. Receiving end does not exist
通过以下代码向当前页面发送 "start" 消息: chrome.tabs.query({active: true,currentWindow: true}, tabs => ...

establish connection

慎用establish connection

establish connection相关推荐

最新文章

热门文章