1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
| -module(tcp_server).
| -author('Bin Shen <23420800@qq.com>').
| -compile(export_all).
|
| -export([listen/1, loop/3]).
| -import(handler,[doWork/3]).
|
| -define(TCP_OPTIONS, [binary, {packet, 0}, {active, false}, {reuseaddr, true}]).
|
| % Call echo:listen(Port) to start the service.
| listen(Port) ->
| {ok, LSocket} = gen_tcp:listen(Port, ?TCP_OPTIONS), accept(LSocket).
|
| % Wait for incoming connections and spawn the echo loop when we get one.
| accept(LSocket) ->
| {ok, Socket} = gen_tcp:accept(LSocket),
| spawn(fun() -> loop(Socket, <<>>, 0) end),
| accept(LSocket).
|
| % Echo back whatever data we receive on Socket.
| loop(Socket, Chain, Count) ->
|
| io:format("~p~n", [Count]),
|
| case gen_tcp:recv(Socket, 0) of
|
| %% {ok, <<90, 0, 16, 1, 0, 1, A1, A2, A3, A4, A5, A6>>} ->
| %% io:format("recv +++++++"),
| %% io:format("recv ~p~n", [A1]),
| %% io:format("recv ~p~n", [A2]),
| %% io:format("recv ~p~n", [A3]),
| %% io:format("recv ~p~n", [A4]),
| %% io:format("recv ~p~n", [A5]),
| %% io:format("recv ~p~n", [A6]),
| %%
| %% loop(Socket);
|
| {ok, Data} ->
| %% io:format("recv ~p~n", [Data]),
| %% gen_tcp:send(Socket, Data),
|
| %% io:format("recv ~p~n", [Data]),
| %%
| %% X = binary_to_list(Data),
| %% io:format("recv ~w~n", [X]),
| %%
| %% Y = [ integer_to_list(N, 16) || N <- X],
| %% io:format("recv ~w~n", [Y]),
|
| ChainLen = byte_size(Chain),
| DataLen = byte_size(Data),
| doWork(Socket, <<Chain:ChainLen/binary, Data:DataLen/binary >>, Count);
|
| %% loop(Socket);
| {error, closed} ->
| ok
| end.
|
|
