1 -module(server).
2 -export([start/0]).
3
4 start() ->
5 {ok,Listen}=gen_tcp:listen(2345,[binary,{packet,4},
6 {reuseaddr,true},
7 {active,true}]),
8 {ok,Socket}=gen_tcp:accept(Listen),
9 gen_tcp:close(Listen),
10 loop(Socket).
11
12 loop(Socket) ->
13 receive
14 {tcp,Socket,Bin} ->
15 io:format("Server received binary = ~p~n",[Bin]),
16 Str=binary_to_term(Bin),
17 io:format("Server (unpacked) ~p~n",[Str]),
18 Reply= Str ++ "** MLGB!",
19 io:format("Server replying = ~p~n",[Reply]),
20 gen_tcp:send(Socket,term_to_binary(Reply)),
21 loop(Socket);
22 {tcp_closed,Socket} ->
23 io:format("Server socket closed~n")
24 end.
client.erl:2 -export([start/0]).
3
4 start() ->
5 {ok,Listen}=gen_tcp:listen(2345,[binary,{packet,4},
6 {reuseaddr,true},
7 {active,true}]),
8 {ok,Socket}=gen_tcp:accept(Listen),
9 gen_tcp:close(Listen),
10 loop(Socket).
11
12 loop(Socket) ->
13 receive
14 {tcp,Socket,Bin} ->
15 io:format("Server received binary = ~p~n",[Bin]),
16 Str=binary_to_term(Bin),
17 io:format("Server (unpacked) ~p~n",[Str]),
18 Reply= Str ++ "** MLGB!",
19 io:format("Server replying = ~p~n",[Reply]),
20 gen_tcp:send(Socket,term_to_binary(Reply)),
21 loop(Socket);
22 {tcp_closed,Socket} ->
23 io:format("Server socket closed~n")
24 end.
1 -module(client).
2 -export([start/1]).
3
4 start(Str) ->
5 {ok, Socket} =
6 gen_tcp:connect("localhost", 2345, [binary, {packet, 4}]),
7 ok = gen_tcp:send(Socket, term_to_binary(Str)),
8 receive
9 {tcp, Socket, Bin} ->
10 io:format("Client received binary = ~p~n", [Bin]),
11 Val = binary_to_term(Bin),
12 io:format("Client result = ~p~n", [Val]),
13 gen_tcp:close(Socket)
14 end.
緙栬瘧:2 -export([start/1]).
3
4 start(Str) ->
5 {ok, Socket} =
6 gen_tcp:connect("localhost", 2345, [binary, {packet, 4}]),
7 ok = gen_tcp:send(Socket, term_to_binary(Str)),
8 receive
9 {tcp, Socket, Bin} ->
10 io:format("Client received binary = ~p~n", [Bin]),
11 Val = binary_to_term(Bin),
12 io:format("Client result = ~p~n", [Val]),
13 gen_tcp:close(Socket)
14 end.
1 Eshell > c(server).
2 Eshell > c(client).
鍚姩server:2 Eshell > c(client).
1 Eshell > server:start().
鍚姩client:1 Eshell > client:start("sb").
server绔緭鍑?1 Server received binary = <<131,107,0,2,115,98>>
2 Server (unpacked) "sb"
3 Server replying = "sb** MLGB!"
4 Server socket closed
client绔緭鍑?2 Server (unpacked) "sb"
3 Server replying = "sb** MLGB!"
4 Server socket closed
1 Client received binary = <<131,107,0,10,115,98,42,42,32,77,76,71,66,33>>
2 Client result = "sb** MLGB!"
2 Client result = "sb** MLGB!"
]]>
1 #include <stdio.h>
2 #include <stdlib.h>
3 #include <strings.h>
4 #include <unistd.h>
5 #include <sys/types.h>
6 #include <sys/socket.h>
7 #include <netinet/in.h>
8 #include <arpa/inet.h>
9
10 #define PORT 8888
11 #define BACKLOG 10
12
13 int main(int argc, char *argv[])
14 {
15 int listenfd, connectfd;
16 struct sockaddr_in server;
17 struct sockaddr_in client;
18 int sin_size;
19
20 if((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1){
21 perror("Creating socket failed.");
22 exit(0);
23 }
24
25 int opt = SO_REUSEADDR;
26 setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
27
28 bzero(&server, sizeof(server));
29 server.sin_family = AF_INET;
30 server.sin_port = htons(PORT);
31 server.sin_addr.s_addr = htonl(INADDR_ANY);
32
33 if (bind(listenfd, (struct sockaddr *)&server,
34 sizeof(struct sockaddr)) == -1){
35 perror("Bind error!");
36 exit(0);
37 }
38
39 if (listen(listenfd,BACKLOG) == -1){
40 perror("Listen error!");
41 exit(0);
42 }
43
44 while(1){
45 sin_size = sizeof(struct sockaddr_in);
46
47 if((connectfd = accept(listenfd, (struct sockaddr *)&client, &sin_size)) == -1) {
48 perror("Accept error!");
49 break;
50 }
51
52 printf("You got a connection from %s\n", inet_ntoa(client.sin_addr));
53
54 send(connectfd, "Fucking client!\n", 16, 0);
55
56 close(connectfd);
57 }
58
59 close(listenfd);
60 exit(0);
61 }
client.c:
2 #include <stdlib.h>
3 #include <strings.h>
4 #include <unistd.h>
5 #include <sys/types.h>
6 #include <sys/socket.h>
7 #include <netinet/in.h>
8 #include <arpa/inet.h>
9
10 #define PORT 8888
11 #define BACKLOG 10
12
13 int main(int argc, char *argv[])
14 {
15 int listenfd, connectfd;
16 struct sockaddr_in server;
17 struct sockaddr_in client;
18 int sin_size;
19
20 if((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1){
21 perror("Creating socket failed.");
22 exit(0);
23 }
24
25 int opt = SO_REUSEADDR;
26 setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
27
28 bzero(&server, sizeof(server));
29 server.sin_family = AF_INET;
30 server.sin_port = htons(PORT);
31 server.sin_addr.s_addr = htonl(INADDR_ANY);
32
33 if (bind(listenfd, (struct sockaddr *)&server,
34 sizeof(struct sockaddr)) == -1){
35 perror("Bind error!");
36 exit(0);
37 }
38
39 if (listen(listenfd,BACKLOG) == -1){
40 perror("Listen error!");
41 exit(0);
42 }
43
44 while(1){
45 sin_size = sizeof(struct sockaddr_in);
46
47 if((connectfd = accept(listenfd, (struct sockaddr *)&client, &sin_size)) == -1) {
48 perror("Accept error!");
49 break;
50 }
51
52 printf("You got a connection from %s\n", inet_ntoa(client.sin_addr));
53
54 send(connectfd, "Fucking client!\n", 16, 0);
55
56 close(connectfd);
57 }
58
59 close(listenfd);
60 exit(0);
61 }
1 #include <stdio.h>
2 #include <unistd.h>
3 #include <strings.h>
4 #include <stdlib.h>
5 #include <sys/types.h>
6 #include <sys/socket.h>
7 #include <netinet/in.h>
8 #include <netdb.h>
9
10 #define PORT 8888
11 #define MAXDATASIZE 100
12
13 int main(int argc, char *argv[])
14 {
15 int fd, numbytes;
16 char buf[MAXDATASIZE];
17 struct hostent *he;
18 struct sockaddr_in server;
19
20 if (argc != 2) {
21 printf("Usage: %s <IP Address>\n",argv[0]);
22 exit(0);
23 }
24
25 if((he = gethostbyname(argv[1])) == NULL) {
26 printf("gethostbyname() error\n");
27 exit(0);
28 }
29
30 if((fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
31 printf("socket() error\n");
32 exit(0);
33 }
34
35 bzero(&server, sizeof(server));
36 server.sin_family = AF_INET;
37 server.sin_port = htons(PORT);
38 server.sin_addr = *((struct in_addr *)he->h_addr);
39
40 if(connect(fd, (struct sockaddr *)&server, sizeof(struct sockaddr)) == -1) {
41 close(fd);
42 printf("Connect error!");
43 exit(0);
44 }
45
46 if((numbytes = recv(fd, buf, MAXDATASIZE, 0)) == -1) { /* calls recv() */
47 printf("Recv error!");
48 exit(0);
49 }
50
51 buf[numbytes] = '\0';
52 printf("Server Message: %s \n", buf);
53
54 close(fd);
55 }
緙栬瘧錛?br>
2 #include <unistd.h>
3 #include <strings.h>
4 #include <stdlib.h>
5 #include <sys/types.h>
6 #include <sys/socket.h>
7 #include <netinet/in.h>
8 #include <netdb.h>
9
10 #define PORT 8888
11 #define MAXDATASIZE 100
12
13 int main(int argc, char *argv[])
14 {
15 int fd, numbytes;
16 char buf[MAXDATASIZE];
17 struct hostent *he;
18 struct sockaddr_in server;
19
20 if (argc != 2) {
21 printf("Usage: %s <IP Address>\n",argv[0]);
22 exit(0);
23 }
24
25 if((he = gethostbyname(argv[1])) == NULL) {
26 printf("gethostbyname() error\n");
27 exit(0);
28 }
29
30 if((fd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
31 printf("socket() error\n");
32 exit(0);
33 }
34
35 bzero(&server, sizeof(server));
36 server.sin_family = AF_INET;
37 server.sin_port = htons(PORT);
38 server.sin_addr = *((struct in_addr *)he->h_addr);
39
40 if(connect(fd, (struct sockaddr *)&server, sizeof(struct sockaddr)) == -1) {
41 close(fd);
42 printf("Connect error!");
43 exit(0);
44 }
45
46 if((numbytes = recv(fd, buf, MAXDATASIZE, 0)) == -1) { /* calls recv() */
47 printf("Recv error!");
48 exit(0);
49 }
50
51 buf[numbytes] = '\0';
52 printf("Server Message: %s \n", buf);
53
54 close(fd);
55 }
1 gcc -o server server.c
2 gcc -o client client.c
榪愯:2 gcc -o client client.c
1 # server绔?br>2 ./server
3 # client绔?br>4 ./client 127.0.0.1
3 # client绔?br>4 ./client 127.0.0.1
]]>