从一个 GenServer 以主动模式管理多个 TCP 连接

Question

我通常使用这种模式与单个 TCP 资源进行交互，在active-mode：

  def connect(ip, port) do
    t = System.system_time(1000)
    case :gen_tcp.connect(ip, port, [:binary, active: :once, keepalive: true, nodelay: true]) do
      {:ok, socket} ->
        log "Connected to #{ip}:#{port} in #{System.system_time(1000) - t}ms"
        socket
      {:error, err} ->
        log "Connect Error - #{ip}: #{port} [#{inspect err}]"
        Process.send_after(self(), :retry_connect, 3000)
        nil
    end
  end

  def handle_info({:tcp, _, data}, s) do
    s = proc_raw(s.extra <> data, %{s | extra: ""})

    :inet.setopts(s.socket, active: :once)

    {:noreply, s}
  end

如何扩展它以处理同一GenServer 中的多个 TCP 连接？

到目前为止，这对于active-mode 中的单个 TCP 套接字非常有效

更新

每个 GenServer 都由主管管理。另外，每个 GenServer 代表一个客户端，每个客户端可能有 3-5 个 TCP 连接到一些外部资源。

TCP 连接会不时发生故障/重置，每次失败都会尝试重新连接，但主机 GenServer 不需要重新启动

Answer 1

虽然我同意@Onorio Catenacci 的观点，但多个 GenServers 可能是更好的选择。不过，我还是会回答你提出的问题。

传递给handle_info 的元组的第二个位置是正在接收数据的套接字。因此，您已经知道它来自哪个套接字。

handle_info({:tcp, socket, data}, s) do
  # do something with the socket here ... 
end

我怀疑唯一需要的其他更改是保留对所有打开套接字的引用，这可以通过修改连接函数的 handle_call 和 GenServer 的 init 函数来完成：

def init(_) do
  {:ok, []}
end

def handle_call({:connect, ip, port}, _from, sockets) do
  s = connect(ip, port)
  {:reply, :ok, [s|sockets]}
end

注意，您可能还需要以类似的方式更改 handle_call for :retry_connect 函数。

希望这会有所帮助。

Answer 2

我建议您使用 Supervisor 而不是 GenServer。主管将允许您自动重新启动失败的连接：

当事情失败时，你的第一反应可能是：“让我们拯救那些 错误”。但是在 Elixir 中，我们避免了防御性编程习惯 拯救异常，这在其他语言中很常见。相反，我们 说“让它崩溃”。如果有错误导致我们的注册表 崩溃，我们没有什么可担心的，因为我们要建立一个 将启动注册表的新副本的主管。

我意识到上面的段落是在讨论“注册表”，但概念是一样的。

我也意识到我的回答有些笼统。但是，由于您的问题也很笼统，因此我很难为您提供更具体的内容。如果您有更具体的问题，我建议您编辑您的问题，我们可以为您提供更具体的答案。