我有一个问题:我想创建一个可以容纳 1M 同时打开的 tcp 连接的 Erlang 服务器。我调整了我的操作系统 (Oracle Linux 7) 以提高文件描述符。
在我做的服务器上
gen_tcp:听
//点_1
套接字 = gen_tcp:accept
spawn(handle(Socket))//另一个线程
回到 point_1
如果我按顺序连接没问题,在 100 秒内我连接了 100K 个客户端;但我已经没有耐心了。
如果我想将它们连接到 并发例如,只有大约 80 个连接由 100 个连接而成。
这就是我运行一切的方式:
erlc *.erl
erl +Q 134217727 +P 1000000 -env ERL_MAX_PORTS 40960000 -env ERTS_MAX_PORTS 40960000
//启动一个监听 9999 端口的服务器
ex:start(1, 9999)
//100 个客户端尝试在端口 9999 上连接
ex:connect_clients(100, 9999)
让我向您展示一些代码:
start(Num,LPort) ->
case gen_tcp:listen(LPort,[{active, false},{packet,2}]) of
{ok, ListenSock} ->
start_servers(Num,ListenSock),
{ok, Port} = inet:port(ListenSock),
Port;
{error,Reason} ->
{error,Reason}
end.
start_servers(0,_) ->
ok;
start_servers(Num,LS) ->
spawn(?MODULE,server,[LS,0]),
start_servers(Num-1,LS).
server(LS, Nr) ->
io:format("before accept ~w~n",[Nr]),
case gen_tcp:accept(LS) of
{ok,S} ->
io:format("after accept ~w~n",[Nr]),
spawn(ex,loop,[S]),
server(LS, Nr+1);
Other ->
io:format("accept returned ~w - goodbye!~n",[Other]),
ok
end.
loop(S) ->
inet:setopts(S,[{active,once}]),
receive
{tcp,S, _Data} ->
Answer = 1,
gen_tcp:send(S,Answer),
loop(S);
{tcp_closed,S} ->
io:format("Socket ~w closed [~w]~n",[S,self()]),
ok
end.
client(PortNo) ->
{ok,Sock} = gen_tcp:connect("localhost", PortNo,
[]).
connect_clients(Number, Port) ->
spawn(ex, client, [Port]),
case Number of
0 -> ok;
_ -> connect_clients(Number-1, Port)
end.
最佳答案
我在这里看到至少两个问题:
{backlog, N}
来提高它。在您的收听选项中,例如 {backlog, 1024}
. server/2
函数有问题,因为它接受一个连接,然后产生一个新进程来运行 loop/1
但它并没有使这个新进程成为 controlling process对于接受的套接字。 loop/1
函数尝试设置 {active,once}
套接字上的模式以尝试接收传入的消息,但由于它没有在控制进程中运行,所以它不会工作。 (你应该通过在那里说 inet_setopts/2
来验证 ok = inet:setopts(S,[{active,once}]),
的返回值。) 而不是产生循环,你应该产生一个新的接受器,像这样:
server(LS, Nr) ->
io:format("before accept ~w~n",[Nr]),
case gen_tcp:accept(LS) of
{ok,S} ->
io:format("after accept ~w~n",[Nr]),
spawn(ex,server,[LS,Nr+1]),
loop(S);
Other ->
io:format("accept returned ~w - goodbye!~n",[Other]),
ok
end.
通过这种方法,接受套接字的进程运行
loop/1
因此无需更改套接字的控制过程。
关于sockets - Erlang同时连接1M客户端,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32711242/