Skip to content

Update rediscluster.lua #8

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 3 commits into
base: master
Choose a base branch
from
Open

Update rediscluster.lua #8

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
2100151
Update rediscluster.lua
fankeke Oct 3, 2016
218fe1f
set timeout for redis
fankeke Apr 6, 2017
fb25d2a
add connectimeout and reuse redis instance in one request
fankeke Apr 6, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 5 additions & 3 deletions lib/resty/rediscluster.lua
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -189,6 +189,7 @@ end
local MAGIC_TRY = 3
local DEFUALT_KEEPALIVE_TIMEOUT = 1000
local DEFAULT_KEEPALIVE_CONS = 200
local DEFAULT_CONNECT_TIMEOUT = 10

local function _do_cmd(self, cmd, key, ...)
if self._reqs then
Expand All @@ -201,6 +202,8 @@ local function _do_cmd(self, cmd, key, ...)

key = tostring(key)
local slot = redis_slot(key)
local redis_client = redis:new()
redis_client:set_timeout(config.connect_timeout or DEFAULT_CONNECT_TIMEOUT)

for k=1, MAGIC_TRY do
local slots = slot_cache[self.config.name]
Expand All @@ -209,17 +212,16 @@ local function _do_cmd(self, cmd, key, ...)
for i=1,#serv_list do
local ip = serv_list[index].ip
local port = serv_list[index].port
redis_client = redis:new()
local ok, err = redis_client:connect(ip_string(ip), port)
if ok then
slots[slot].cur = index
local res, err = redis_client[cmd](redis_client, key, ...)
redis_client:set_keepalive(config.keepalive_timeout or DEFUALT_KEEPALIVE_TIMEOUT,
config.keepalove_cons or DEFAULT_KEEPALIVE_CONS)
if err and string.sub(err, 1, 5) == "MOVED" then
self:fetch_slots()
break
end
redis_client:set_keepalive(config.keepalive_timeout or DEFUALT_KEEPALIVE_TIMEOUT,
config.keepalove_cons or DEFAULT_KEEPALIVE_CONS)
return res, err
else
index = next_index(index, #serv_list)
Expand Down