elixir - 在 elixir genstage 消费者中使用 redis 连接

Question

我有一个 genstage 应用程序的示例，在它的消费者中，我需要使用与 redis 的连接。而且我不明白我需要如何将此连接传递给handle_events。

如果我写：

  defp connection do
    {:ok, conn} = Redix.start_link(host: "0.0.0.0", port: 6379)
    conn
  end

然后每次在handle_events函数内部调用连接时，都会创建一个新连接。

我怎么解决这个问题？

Answer 1

您可以保留消费者的in conn（就像您希望在 a中一样，如下所示：stateGenStageGenServer

defmodule C do
  use GenStage

  def start_link() do
    GenStage.start_link(C, :ok)
  end

  def init(:ok) do
    {:ok, conn} = Redis.start_link(...)
    {:consumer, conn}
  end

  def handle_events(events, _from, conn) do
    Redix.command!(conn, ...)

    {:noreply, [], conn}
  end
end

在这里，我在创建消费者时创建连接。如果需要，您还可以创建更高的连接并将其传递给此连接，如下所示：

defmodule C do
  use GenStage

  def start_link(conn) do
    GenStage.start_link(C, conn)
  end

  def init(conn) do
    {:consumer, conn}
  end

  def handle_events(events, _from, conn) do
    Redix.command!(conn, ...)

    {:noreply, [], conn}
  end
end