redis manager

This commit is contained in:
云风
2012-08-15 15:25:54 +08:00
parent 82a523e27c
commit ab85ef535a
4 changed files with 46 additions and 33 deletions

27
service/redis-mgr.lua Normal file
View File

@@ -0,0 +1,27 @@
local skynet = require "skynet"
local log = require "log"
local name = {
main = "127.0.0.1:6379",
}
local connection = {}
skynet.dispatch(function(msg, sz , session, from)
local dbname = skynet.tostring(msg,sz)
if connection[dbname] then
skynet.ret(connection[dbname])
return
end
if name[dbname] == nil then
log.Error("Invalid db name : "..dbname)
skynet.ret("")
return
end
local redis_cli = skynet.launch("snlua", "redis-cli", name[dbname])
connection[dbname] = redis_cli
skynet.ret(redis_cli)
end)
skynet.register ".redis-manager"