请教下，更好的去解决mongodb并发的去auth验证账号？谢谢！

763191973

我用ab并发的去测试一个mongodb的插入数据的接口。

一开始的连接可能不是连接池里面的连接，然后没有进行过auth验证账号密码！然后假如并发量大的话，一开始的连接都跑去auth验证了，然后auth验证又很耗时，就卡在那里了。

然后我就想加一把锁，如果是并发进来的一堆请求，如果拿不了锁的就直接return掉。结果测试出来效果还是不好。

请教下大神。代码：

local lock = require "resty.lock"
--获取连接对象
local conn =mongo:new()
conn:set_timeout(1000)
--获取连接客户端
local ok,err =conn:connect("192.168.1.254",27017)
if not ok then
        ngx.log(ngx.ERR, "connect failed:"..err)
        ngx.say("connect failed: "..err)
        return
      else
        local locks_flag = ngx.shared.activity_cache
        --判断此连接是不是从连接池里面拿出来的
        local times,err = conn:get_reused_times()
        if times == nil or times == 0 then
                local lock_cache = lock:new("activity_cache")
                local elapsed, err = lock_cache:lock("auth_key")
                if not elapsed then
                        --ngx.log(ngx.ERR,"locked failed:"..err)
                        return
                end
                if locks_flag:get("flag") ~= nil then
                        ngx.log(ngx.ERR,"flag not nil:")
                        lock_cache:unlock()
                        return
                end
                if locks_flag:get("flag") == nil then
                        ngx.log(ngx.ERR,"flag is nil:")
                        --获取数据库
                        db = conn:new_db_handle("loho_openresty")
                        --用户授权
                        local ok ,err = db:auth_scram_sha1("yrq","123456")
                        if not ok then
                                ngx.log(ngx.ERR, "db select failed:"..err)
                                return
                        end
                        --授权成功，释放锁
                        local ok, err = lock_cache:unlock()
                        if not ok then
                                ngx.log(ngx.ERR,"failed to unlock2: ", err)
                                return
                        end
                        locks_flag:set("flag", true)
                end
        else
                db = conn:new_db_handle("loho_openresty")
        end
	--other
end

谢谢！

doujiang24

Hello

在 2016年8月11日下午6:12， <7631...@qq.com>写道：

请教下，更好的去解决mongodb并发的去auth验证账号？谢谢！

我用ab并发的去测试一个mongodb的插入数据的接口。
一开始的连接可能不是连接池里面的连接，然后没有进行过auth验证账号密码！然后假如并发量大的话，一开始的连接都跑去auth验证了，然后auth验证又很耗时，就卡在那里了。

然后我就想加一把锁，如果是并发进来的一堆请求，如果拿不了锁的就直接return掉。结果测试出来效果还是不好。

我想，limit.conn 会比锁好

https://github.com/openresty/lua-resty-limit-traffic/blob/master/lib/resty/limit/conn.md

请教下大神。代码：
local lock = require "resty.lock" --获取连接对象 local conn =mongo:new() conn:set_timeout(1000) --获取连接客户端 local ok,err =conn:connect("192.168.1.254",27017) if not ok then ngx.log(ngx.ERR, "connect failed:"..err) ngx.say("connect failed: "..err) return else local locks_flag = ngx.shared.activity_cache --判断此连接是不是从连接池里面拿出来的 local times,err = conn:get_reused_times() if times == nil or times == 0 then local lock_cache = lock:new("activity_cache") local elapsed, err = lock_cache:lock("auth_key") if not elapsed then --ngx.log(ngx.ERR,"locked failed:"..err) return end if locks_flag:get("flag") ~= nil then ngx.log(ngx.ERR,"flag not nil:") lock_cache:unlock() return end if locks_flag:get("flag") == nil then ngx.log(ngx.ERR,"flag is nil:") --获取数据库 db = conn:new_db_handle("loho_openresty") --用户授权 local ok ,err = db:auth_scram_sha1("yrq","123456") if not ok then ngx.log(ngx.ERR, "db select failed:"..err) return end --授权成功，释放锁 local ok, err = lock_cache:unlock() if not ok then ngx.log(ngx.ERR,"failed to unlock2: ", err) return end locks_flag:set("flag", true) end else db = conn:new_db_handle("loho_openresty") end --other end

谢谢！

--

yuansheng

请问你用的那个 mongodb 的库？

如果 mongodb 有身份验证，conn:connect("192.168.1.254",27017) 就应该直接填入身份信息，并根据 ip、port、身份信息的组合当做连接池 pool 的名字，否则会出现交叉使用的情况。

正常来说已经验证过的连接，是不需要反复验证的。

2016-08-11 23:16 GMT+08:00 DeJiang Zhu <douj...@gmail.com>:

Hello

在 2016年8月11日下午6:12， <7631...@qq.com>写道：
请教下，更好的去解决mongodb并发的去auth验证账号？谢谢！

我用ab并发的去测试一个mongodb的插入数据的接口。
一开始的连接可能不是连接池里面的连接，然后没有进行过auth验证账号密码！然后假如并发量大的话，一开始的连接都跑去auth验证了，然后auth验证又很耗时，就卡在那里了。
然后我就想加一把锁，如果是并发进来的一堆请求，如果拿不了锁的就直接return掉。结果测试出来效果还是不好。

我想，limit.conn 会比锁好
https://github.com/openresty/lua-resty-limit-traffic/blob/master/lib/resty/limit/conn.md

请教下大神。代码：
local lock = require "resty.lock" --获取连接对象 local conn =mongo:new() conn:set_timeout(1000) --获取连接客户端 local ok,err =conn:connect("192.168.1.254",27017) if not ok then ngx.log(ngx.ERR, "connect failed:"..err) ngx.say("connect failed: "..err) return else local locks_flag = ngx.shared.activity_cache --判断此连接是不是从连接池里面拿出来的 local times,err = conn:get_reused_times() if times == nil or times == 0 then local lock_cache = lock:new("activity_cache") local elapsed, err = lock_cache:lock("auth_key") if not elapsed then --ngx.log(ngx.ERR,"locked failed:"..err) return end if locks_flag:get("flag") ~= nil then ngx.log(ngx.ERR,"flag not nil:") lock_cache:unlock() return end if locks_flag:get("flag") == nil then ngx.log(ngx.ERR,"flag is nil:") --获取数据库 db = conn:new_db_handle("loho_openresty") --用户授权 local ok ,err = db:auth_scram_sha1("yrq","123456") if not ok then ngx.log(ngx.ERR, "db select failed:"..err) return end --授权成功，释放锁 local ok, err = lock_cache:unlock() if not ok then ngx.log(ngx.ERR,"failed to unlock2: ", err) return end locks_flag:set("flag", true) end else db = conn:new_db_handle("loho_openresty") end --other end

谢谢！

--

--

YuanSheng Wang

---------------------------------------

My Github: https://github.com/membphis

OpenResty lover ^_^

763191973

用的是这个库，https://github.com/LuaDist2/lua-resty-mongol3

connect的时候貌似不能指教填入账号密码。

需要在选择数据库之后进行auth验证！

然后如果连接池里面没有验证过了的连接的话，并发大一点的话就都跑到去auth验证了，然后mongodb新的验证不再是md5加密了，然后就很耗时，并发多的话就卡在这里了。

在 2016年8月12日星期五 UTC+8上午12:20:39，YuanSheng写道：

请问你用的那个 mongodb 的库？

如果 mongodb 有身份验证，conn:connect("192.168.1.254",27017) 就应该直接填入身份信息，并根据 ip、port、身份信息的组合当做连接池 pool 的名字，否则会出现交叉使用的情况。

正常来说已经验证过的连接，是不需要反复验证的。

2016-08-11 23:16 GMT+08:00 DeJiang Zhu <douji...@gmail.com>:
Hello

在 2016年8月11日下午6:12， <7631...@qq.com>写道：
请教下，更好的去解决mongodb并发的去auth验证账号？谢谢！

我用ab并发的去测试一个mongodb的插入数据的接口。
一开始的连接可能不是连接池里面的连接，然后没有进行过auth验证账号密码！然后假如并发量大的话，一开始的连接都跑去auth验证了，然后auth验证又很耗时，就卡在那里了。
然后我就想加一把锁，如果是并发进来的一堆请求，如果拿不了锁的就直接return掉。结果测试出来效果还是不好。

我想，limit.conn 会比锁好
https://github.com/openresty/lua-resty-limit-traffic/blob/master/lib/resty/limit/conn.md

请教下大神。代码：
local lock = require "resty.lock" --获取连接对象 local conn =mongo:new() conn:set_timeout(1000) --获取连接客户端 local ok,err =conn:connect("192.168.1.254",27017) if not ok then ngx.log(ngx.ERR, "connect failed:"..err) ngx.say("connect failed: "..err) return else local locks_flag = ngx.shared.activity_cache --判断此连接是不是从连接池里面拿出来的 local times,err = conn:get_reused_times() if times == nil or times == 0 then local lock_cache = lock:new("activity_cache") local elapsed, err = lock_cache:lock("auth_key") if not elapsed then --ngx.log(ngx.ERR,"locked failed:"..err) return end if locks_flag:get("flag") ~= nil then ngx.log(ngx.ERR,"flag not nil:") lock_cache:unlock() return end if locks_flag:get("flag") == nil then ngx.log(ngx.ERR,"flag is nil:") --获取数据库 db = conn:new_db_handle("loho_openresty") --用户授权 local ok ,err = db:auth_scram_sha1("yrq","123456") if not ok then ngx.log(ngx.ERR, "db select failed:"..err) return end --授权成功，释放锁 local ok, err = lock_cache:unlock() if not ok then ngx.log(ngx.ERR,"failed to unlock2: ", err) return end locks_flag:set("flag", true) end else db = conn:new_db_handle("loho_openresty") end --other end

谢谢！

--

--

--

YuanSheng Wang
---------------------------------------
My Github: https://github.com/membphis
OpenResty lover ^_^