KeepAlive

    1. local function send()
    2. for i = 1, count do
    3. local ssdb_db, err = ssdb:new()
    4. local ok, err = ssdb_db:connect(SSDB_HOST, SSDB_PORT)
    5. return -- 这里添加了 return 语句
    6. else
    7. local key, err = ssdb_db:qpop(something)
    8. if not key then
    9. ngx.log(ngx.ERR, "ssdb qpop err:", err)
    10. -- other operations
    11. end
    12. -- 把语句移动到了这里,只会把成功的连接加入到连接池
    13. ssdb_db:set_keepalive(SSDB_KEEP_TIMEOUT, SSDB_KEEP_COUNT)
    14. end