1

我正在制作一个多聊天应用程序，这是代码。在这个应用程序中，我创建了一个服务器，代码如下：

defmodule Multichat.Server do
  require Logger

  def accept(port) do
    {:ok, socket} = :gen_tcp.listen(port, [:binary, packet: :line, active: true, reuseaddr: true])
    Logger.info "Accepting connections on port #{port}"
    loop_acceptor(socket)
  end

  defp loop_acceptor(socket) do
    {:ok, client} = :gen_tcp.accept(socket)
    {:ok, pid} = DynamicSupervisor.start_child(Multichat.Server.ConnectionSupervisor, {Multichat.ClientConnection, client})
    :ok = :gen_tcp.controlling_process(client, pid)
    loop_acceptor(socket)
  end
end

您可以在代码中看到有一个客户端部分：

defmodule Multichat.ClientConnection do
  use GenServer

  def start_link(socket), do: GenServer.start_link(__MODULE__, socket)
  def init(init_arg) do
    {:ok, init_arg}
  end

  def handle_call({:send, message}, _from, socket) do
    :gen_tcp.send(socket, message)
    {:reply, :ok, socket}
  end

  def handle_info({:tcp, _socket, message}, socket) do
    for {_, pid, _, _} <- DynamicSupervisor.which_children(Multichat.Server.ConnectionSupervisor) do
      if pid != self() do
        GenServer.call(pid, {:send, message})
      end
    end

    {:noreply, socket}
  end
end

我希望当我在一个端口上启动一个节点时，另一个节点只能连接另一个节点。这怎么可能？

4

1 回答 1

1

在 linux 中，侦听套接字绑定到任何设备的 IP 或所有设备的 IP (1)，通常默认情况下正在侦听所有设备 ( 0.0.0.0ip)。一旦一个进程在其中一个中监听ip:port，其他套接字就不能在同一个中监听ip:port(2)

(1) 这并不完全正确，因为您有网络命名空间和 IP_FREEBIND 选项。(2) 同样，不完全正确，您有 SO_REUSEPORT 套接字选项。

因此，在这种情况下，您有多种选择：

  1. 为本地启动的每个节点设置不同的端口，例如使用环境变量
  2. 例如，在开发期间为每个节点监听不同的 IP，127.0.0.1以及127.0.0.2
  3. 在监听套接字中设置 SO_REUSEPORT 选项
  4. 使用 docker 或其他容器/命名空间技术能够在不同的网络命名空间中启动不同的节点。

套接字选项在这里
解释 在 Erlang 中，似乎相对较新的低级套接字 API具有可用的reuseport选项，而从inet 文档 (gen_tcp)中，似乎SO_REUSEPORT只能作为raw选项使用。

于 2020-09-11T06:29:51.647 回答