一个基于 NimblePool 的 Redis 连接池库。

将 redis_pool_xyz 添加到您的 mix.exs 依赖项中:

def deps do
  [
    {:redis_pool_xyz, "~> 0.3"}
  ]
end

查看完整文档: HexDocs

1. 添加一个使用 RedisPool 的模块:

   defmodule MyApp.Redis do
     use RedisPool, otp_app: :my_app
   end

2. 配置 Redis 连接参数:

   # 在 config/config.exs 中
   config :my_app, MyApp.Redis,
     url: "redis://:password@localhost:6379/0",
     pool_size: 10

   或者在运行时配置:

   # 在应用程序中
   url = "redis://localhost:6379"
   config = [url: url, pool_size: 5]
   config :my_app, MyApp.Redis, config

3. 将 Redis 模块添加到应用程序的监督树中:

   # 在应用程序的 supervisor 中
   children = [
     MyApp.Redis
   ]
   
   Supervisor.start_link(children, strategy: :one_for_one)

4. 使用定义的模块执行 Redis 命令:

   # 执行单个命令
   {:ok, nil} = MyApp.Redis.command(["GET", "foo"])
   {:ok, "OK"} = MyApp.Redis.command(["SET", "foo", "bar"])
   {:ok, "bar"} = MyApp.Redis.command(["GET", "foo"])
   
   # 执行管道命令
   {:ok, ["OK", "OK"]} = MyApp.Redis.pipeline([
     ["SET", "foo1", "bar1"],
     ["SET", "foo2", "bar2"]
   ])

您可以重写 init/1 函数来添加自定义配置处理逻辑:

defmodule MyApp.Redis do
  use RedisPool, otp_app: :my_app

  @impl true
  def init(config) do
    # 添加默认配置
    config = Keyword.put_new(config, :pool_size, 5)

    # 添加日志
    require Logger
    Logger.info("初始化 Redis 连接池: #{inspect(config)}")

    # 验证配置
    if config[:url] do
      config
    else
      raise "Redis URL 未配置"
    end
  end
end

所有命令执行都会返回 {:ok, result} 或 {:error, error} 元组。错误结构提供了详细的错误信息:

# 处理可能的错误情况
case MyApp.Redis.command(["GET", "key"]) do
  {:ok, value} ->
    # 处理成功的结果
    IO.puts("值: #{value || "nil"}")

  {:error, %RedisPool.Error{code: :connection_error}} ->
    # 处理连接错误
    IO.puts("Redis 连接错误，请检查连接参数")

  {:error, %RedisPool.Error{code: :timeout_error}} ->
    # 处理超时错误
    IO.puts("Redis 操作超时")

  {:error, error} ->
    # 处理其他错误
    IO.puts("发生错误: #{inspect(error)}")
end

可用的连接池配置选项:

命令执行选项:

• 对于需要执行多个命令的场景，使用 pipeline/2 可以显著提高性能
• 适当配置连接池大小以匹配应用程序的并发需求
• 避免长时间占用连接，及时释放连接回连接池

欢迎贡献代码、报告问题或提出改进建议。请在 GitHub Issues 上提交问题。

本项目基于 MIT 许可证开源。详见 LICENSE 文件。