Re: [openresty] 应该如何把对mysql的增删改查封装成模块

moonbingbing

ngx.ctx[mysql_pool] 的初衷是什么呢？好像没啥用啊。 ngx.ctx 的生存周期和当前请求相同，而且 ngx.ctx 比较昂贵。

2016-02-02 9:43 GMT+08:00 <luoj...@163.com>:

您好，我参照网上的封装了一个mysql的模块，用来执行增删改查操作。但是压力测试的时候，吞吐量越来越低。如果我用官网的例子直接测试，基本上每次都是一万2的吞吐量。麻烦帮忙看看这个模块封装问题出现在哪里了。感激不尽。

local mysql_pool = {}

function mysql_pool:get_connect()
ngx.say(ngx.ctx[mysql_pool])
if ngx.ctx[mysql_pool] then
return true, ngx.ctx[mysql_pool]
end

local mysql = require "resty.mysql"
local client, errmsg = mysql.new()
if not client then
return false, "mysql.socket_failed: " .. (errmsg or "nil")
end

--设置超时时间
client:set_timeout(1000)

local props = {
host = "192.168.1.111",
port = 3306,
database = "visitor",
user = "username",
password = "password",
max_packet_size = 1024 * 1024
}
local res, err, errno, sqlstate = client:connect(props)
if not res then
return false, "mysql.query_failed: "..(errmsg or "nil")..", errno:"..(errno or "nil")..", sql_state:"..(sqlstate or "nil")
end

local query = "SET NAMES UTF8"
local result, errmsg, errno, sqlstate = client:query(query)
if not result then
return false, "mysql.query_failed: "..(errmsg or "nil")..", errno:"..(errno or "nil")..", sql_state:"..(sqlstate or "nil")
end

ngx.ctx[mysql_pool] = client
return true, ngx.ctx[mysql_pool]
end

--把连接返回到连接池
--用set_keepalive代替close() 将开启连接池特性 (1分钟timout，连接池100个)
function mysql_pool:close()
if ngx.ctx[mysql_pool] then
local ok, err = ngx.ctx[mysql_pool]:set_keepalive(60000, 100)
if not ok then
ngx.say("failed to set keepalive:", err)
end
ngx.ctx[mysql_pool] = nil
end
end

function mysql_pool:query(sql, flag)

local ret, client = self:get_connect(flag)
if not ret then
return false, client, nil
end
local result, errmsg, errno, sqlstate = client:query(sql)
self:close()
if not result then
errmsg = concat_db_errmsg("mysql.query_failed:", errno, errmsg, sqlstate)
return false, errmsg, sqlstate
end

return true, result, sqlstate
end

return mysql_pool

--

luojuan822

谢谢你的回复，我把ngx.ctx相关的代码都删掉了，效果还是一样的。ngx.ctx想着可以父子进程共享一个client

luojuan822

不对，是父子请求可以共享一个mysql连接

在 2016年2月2日星期二 UTC+8下午6:21:26，luoju...@163.com写道：

谢谢你的回复，我把ngx.ctx相关的代码都删掉了，效果还是一样的。ngx.ctx想着可以父子进程共享一个client