论坛徽章:: 0

电梯直达

1楼 [收藏(0)] [报告]

发表于 2014-04-21 16:33 |只看该作者 |倒序浏览

本帖最后由 arserangel 于 2014-04-21 16:46 编辑

这是服务端的代码，接收请求，处理数据：
----------------------------------------------------------------------------------------------------------

-module(t_server).
-export([start/0, start/1, wait_connect/1, response/1]).
-define(PORT, 8091).
start() -> start(?PORT).
start(Port) ->
{ok, Lsocket} = gen_tcp:listen(Port, [binary, {active, false}, {reuseaddr, true}]),
wait_connect(Lsocket).
wait_connect(Lsocket) ->
{ok, Socket} = gen_tcp:accept(Lsocket),
spawn(?MODULE, wait_connect, [Lsocket]),
get_request(Socket, []).
get_request(Socket, BinaryList) ->
case gen_tcp:recv(Socket, 0) of
{ok, Binary} ->
get_request(Socket, [Binary | BinaryList]);
{error, closed} ->
response(lists:reverse(BinaryList))
end.
response(_Data) ->
ok.

复制代码

这是客户端的代码，就是发送一个链接，然后，发送过去一个数字而已:
----------------------------------------------------------------------------------------------------------

-module(t_client).
-export([start/0, start/1, connect/2]).
-define(HOST, {127, 0, 0, 1}).
-define(PORT, 8091).
-define(NUM, 102400).
start() -> start(?NUM).
start(Num) ->
io:format("Starting to test the concurrent~n", []),
io:format("Current: ~p ~p~n", [date(), time()]),
connect(Num, Num).
connect(0, MaxNum) ->
io:format("Over, finish to test concurrent[~p]: ~p ~p~n", [MaxNum, date(), time()]);
connect(CurNum, MaxNum) when CurNum =< MaxNum ->
case gen_tcp:connect(?HOST, ?PORT, [binary, {packet, 0}]) of
{ok, Socket} ->
gen_tcp:send(Socket, io_lib:fwrite("~p", [CurNum])),
spawn(?MODULE, connect, [CurNum - 1, MaxNum]);
_R ->
io:format("Error: ~p, CurNum: ~p, MaxNum: ~p~n", [_R, CurNum, MaxNum])
end.

复制代码

这些配置：
ulimit -n 51200
ip_local_port_range 1024 61000
也设置过了,

现在 10万并发, 要7秒左右。

我机器配置是: 4核, I5-5320, 6G 内存, erlang 版本是 1603B
我测度过，除掉 socket连接，单单生成进程，100万，约1秒时间，但涉及 socket 慢了 10倍。。。

有加参数优化 -K true -S 4 -P 204800
问题出在了哪里了？