| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758 |
- local conn = require("redis.conn")
- local redis_pool = {}
- redis_pool.__index = redis_pool
- --[[
- 创建一个新的 fw_redis_pool 对象
- @return 返回一个新的 fw_redis_pool 对象
- ]]
- function redis_pool.new(pool)
- local instance = setmetatable({}, redis_pool)
- if pool == nil then
- instance.module = fw_redis_pool.new()
- else
- instance.module = pool
- end
- return instance
- end
- --[[
- 启动 Redis 连接池
- @param address 地址
- @param port 端口号
- @param password 密码
- @param max_size 最大连接数
- ]]
- function redis_pool:start(address, port, password, max_size)
- self.module:start(address, port, password, max_size)
- end
- --[[
- 关闭 Redis 连接池
- ]]
- function redis_pool:close()
- self.module:close()
- end
- --[[
- 获取 Redis 连接
- @return 返回一个 redis 连接对象
- ]]
- function redis_pool:get()
- return conn.new(self.module:get())
- end
- --[[
- 获取弹出连接数
- @return 返回弹出连接数
- ]]
- function redis_pool:pop_size()
- return self.module:pop_size()
- end
- function redis_pool:self()
- return self.module:self()
- end
- return redis_pool
|