我有一个单一的TCP连接到服务器，但可能有多个请求在同一时间。大多数时候，响应将是如此之大，我会不断收到大量的数据块。这是可能的，我检查数据长度，以确定它是流的结束。但与多个请求，有时包“混合”与另一个请求，导致许多失败。
比如说，
对于正常请求：

• • 〉请求#1 1/3
• • 〉请求#1 2/3
• • 〉请求#1 3/3
• • 〉请求#1已完成

在真实的生活中：

• • 〉请求#1 1/3
• • 〉请求#1 2/3
• • 〉请求#2 1/3
• • 〉请求#2 2/3
• • 〉在某个点失败

现在，我唯一的想法是通过一个接一个地服务请求来使它串行化，但是它不能完全解决我的问题，因为有时候我会收到订阅的事件，而这些事件是不受控制的。
一般来说，我如何解决这个TCP问题？
我展示了下面的一些代码（以防有人知道erlang和elixir）

# Create TCP connection
{:ok, socket} =
      :gen_tcp.connect(host_charlist, port, [:binary, active: true, keepalive: true])

# Send request
def handle_call({:send, msg}, from, state) do
  :ok = :gen_tcp.send(state.socket, msg)
  new_state = %{state | from: from, msg: ""}

  {:noreply, new_state}
end

# When it receive packet
def handle_info({:tcp, _socket, msg}, state) do
  new_state = %{state | msg: state.msg <> msg}
  current_msg_size = byte_size(new_state.msg)
  defined_msg_size = Response.get_body_size(new_state.msg) # this msg size can read from the first packet's header

  cond do
    current_msg_size == defined_msg_size ->
      GenServer.reply(new_state.from, {:ok, new_state.msg})
      {:noreply, %{new_state | msg: ""}}

    current_msg_size > defined_msg_size ->
      GenServer.reply(new_state.from, {:error, "Message size exceed."})
      {:noreply, %{new_state | msg: ""}}

    true ->
      {:noreply, new_state}
  end
end