pool.lua 1.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. local conn = require("redis.conn")
  2. local redis_pool = {}
  3. redis_pool.__index = redis_pool
  4. --[[
  5. 创建一个新的 fw_redis_pool 对象
  6. @return 返回一个新的 fw_redis_pool 对象
  7. ]]
  8. function redis_pool.new()
  9. local instance = setmetatable({}, redis_pool)
  10. instance.module = fw_redis_pool.new()
  11. return instance
  12. end
  13. --[[
  14. 启动 Redis 连接池
  15. @param address 地址
  16. @param port 端口号
  17. @param password 密码
  18. @param max_size 最大连接数
  19. ]]
  20. function redis_pool:start(address, port, password, max_size)
  21. self.module:start(address, port, password, max_size)
  22. end
  23. --[[
  24. 关闭 Redis 连接池
  25. ]]
  26. function redis_pool:close()
  27. self.module:close()
  28. end
  29. --[[
  30. 获取 Redis 连接
  31. @return 返回一个 redis 连接对象
  32. ]]
  33. function redis_pool:get()
  34. return conn.new(self.module:get())
  35. end
  36. --[[
  37. 获取弹出连接数
  38. @return 返回弹出连接数
  39. ]]
  40. function redis_pool:pop_size()
  41. return self.module:pop_size()
  42. end
  43. function redis_pool:self()
  44. return self.module:self()
  45. end
  46. return redis_pool