2

我有一个 tcp 服务器和一个客户端。客户端产生 1000 个进程，每个进程都试图连接到 tcp 服务器。我可以看到 tcp 服务器正在接受 245 个连接并拒绝所有其他连接。每次，服务器都接受第一个 245。

修复：尝试增加 backlog 属性但没有用。
尝试在每个进程生成后调用 timer:sleep(N) 以便我可以降低 tcp 服务器可以接受客户端的速率。失败的！

服务器和客户端：

 accept(LSocket) ->
   case gen_tcp:accept(LSocket) of
     {ok, Socket} ->
       io:format("Accepted ~n"),
       {sockets, List} = hd(ets:lookup(csockets, sockets)),
       NewList = [Socket | List],
       ets:insert(csockets, {sockets, NewList}),
       Pid = spawn(fun() ->
        loop(Socket, 0)
              end),
       gen_tcp:controlling_process(Socket, Pid),
       accept(LSocket);
     {error, closed} ->
       error
    end.

客户：

    send(State = #state{low = Low, high = Low}) ->
      NewState = receive_sockets(0, Low, State),
      NewState;
      send(State = #state{low = Low}) ->
      N = Low rem 2,
      Dest = lists:nth(2, State#state.dest),
      loop(self(), Dest, Low),
      NewState = State#state{low = Low + 1},
      send(NewState).

   loop(From, {IP, Port}, Low) ->
     case gen_tcp:connect(IP, Port, []) of
      {ok, Socket} ->
        gen_tcp:send(Socket, integer_to_binary(Low)),
        From ! {Low, Socket},
        Pid = spawn(?MODULE, receive_from_other_users, []),
        gen_tcp:controlling_process(Socket, Pid);
      _Else ->
        io:format("The connection failed ~n"),
        loop(From, {IP, Port}, Low)
   end.
4

0 回答 0