一个很实用的服务端和客户端进行TCP通信的实例

admin

本文给出一个很实用的服务端和客户端进行TCP通信的小例子。具体实现上非常简单，只是平时编写类似程序，具体步骤经常忘记，还要总是查，暂且将其记下来，方便以后参考。
8 q' c/ R9 J$ M: I* b（1）客户端程序，编写一个文件client.c，内容如下：
& A4 B: P' f& T# r

1. #include <stdlib.h>
   
2. #include <stdio.h>
   
3. #include <unistd.h>
   , l- _% q- X: z6 g8 h
4. #include <string.h>
   . w5 s" E4 g# D5 A  c# ]+ c
5. #include <sys/types.h>
   & j: k8 ?7 [7 q/ Y% X
6. #include <sys/socket.h>
   
7. #include <netinet/in.h>
   + `2 I& J& _# S
8. #include <netdb.h>  /* netdb is necessary for struct hostent */
   : j/ ?. N, y" H* d# L0 `- L
9. 
   
10. #define PORT 4321   /* server port */
    % D6 J( B: H; ?+ q) L5 j
11. 
    
12. #define MAXDATASIZE 100
    
13. 
    ) l" c8 |3 r7 C7 d  ^# Y8 W3 H% L
14. int main(int argc, char *argv[])
    
15. {
      ~: L. w% f% O& f3 \2 \$ u
16.     int sockfd, num;    /* files descriptors */
    
17.     char buf[MAXDATASIZE];    /* buf will store received text */
    : Y2 a+ J6 v& I' n  X( r, E& f1 k
18.     struct hostent *he;    /* structure that will get information about remote host */
    
19.     struct sockaddr_in server;
    
20.    
    5 {! H+ [6 P( r; B( D  s% o
21.     if (argc != 2)
    
22.     {
    3 f% x% S6 H- N% R2 F
23.         printf("Usage: %s <IP Address>\n",argv[0]);
      ~7 R8 ?% d8 ^. K6 W4 y
24.         exit(1);
    " ~* K  {4 h1 A+ Y. g$ a
25.     }
    , W* H, V7 {  Y2 H8 N, [  Q
26.    
    & L/ J8 m9 S, P% {5 z
27.     if((he=gethostbyname(argv[1]))==NULL)
    
28.     {
    4 S6 N/ p' s7 n9 g& `+ n
29.         printf("gethostbyname() error\n");
    9 ^# `$ m4 e) {- a. ?. h- g
30.         exit(1);
    
31.     }
    . k) m7 ~5 ?3 p2 x8 j+ J
32.    
    ; {6 P3 k$ b8 t3 B' D( C- N
33.     if((sockfd=socket(AF_INET,SOCK_STREAM, 0))==-1)
    7 P: v) C! o" l8 N, S, D( l: E; I
34.     {
    3 N9 _5 e4 f+ ~! B# N
35.         printf("socket() error\n");
    9 E! e1 D4 v5 m- |6 E7 u* `
36.         exit(1);
    & `7 I$ r$ e5 l9 |, l, @
37.     }
    / l2 O. E& ~! Z( B0 N
38.     bzero(&server,sizeof(server));
    
39.     server.sin_family = AF_INET;
    
40.     server.sin_port = htons(PORT);
    
41.     server.sin_addr = *((struct in_addr *)he->h_addr);
    ' j: N0 j6 r4 R
42.     if(connect(sockfd, (struct sockaddr *)&server, sizeof(server))==-1)
    , D# J  H1 N0 b1 V+ B
43.     {
    8 H  {1 T: |1 _6 J( [& p
44.         printf("connect() error\n");
    
45.         exit(1);
    $ H" H" ^$ e% T/ _" D/ D# T' [
46.     }
    $ i# e8 a$ V: J& D
47. 　　
    ( {6 ^2 y0 o; e' V( v% c# M3 X5 \4 v
48. 　　char str[] = "horst\n"
    
49. 
    
50.     if((num=send(sockfd,str,sizeof(str),0))==-1){
    1 y1 T1 N" _4 v3 T5 @: `( p
51.         printf("send() error\n");
    ; I$ s7 k$ U" E' E! T/ [5 V
52.         exit(1);
    
53.     }
    - R$ m- U7 Q+ B1 k
54.     if((num=recv(sockfd,buf,MAXDATASIZE,0))==-1)
    0 J* V: H0 t( `
55.     {
    
56.         printf("recv() error\n");
    
57.         exit(1);
    
58.     }
    2 {& H- c6 E) v6 m, w
59.     buf[num-1]='\0';
    
60.     printf("server message: %s\n",buf);
    
61.     close(sockfd);
    
62.     return 0;
    $ p# f. L% e) ]% @8 N3 ?
63. }

复制代码

（2）服务器端，编写server.c，内容如下

1. #include <sys/time.h>
   
2. #include <stdlib.h>
   . w4 `# k; D) }- p: w" k" C
3. #include <stdio.h>
   6 S  F( `& R& l6 j5 u4 U2 I5 Q
4. #include <string.h>
   
5. #include <unistd.h>
   
6. #include <sys/types.h>
   
7. #include <sys/socket.h>
   ) [- R( h$ [9 T) @2 M. I# |
8. #include <netinet/in.h>
   1 C% Y% d: y/ y! S
9. #include <arpa/inet.h>
   
10. 
    
11. #define PORT 4321
    
12. 
    
13. #define BACKLOG 1
    % q+ d2 u$ x* G  D
14. #define MAXRECVLEN 1024
    2 A8 t. A2 q7 q
15. 
    0 z& {- }  _" [. ?4 X" w: N
16. int main(int argc, char *argv[])
    # J! ]/ j7 ?& i+ d+ q; r1 Q/ g
17. {
    
18.     char buf[MAXRECVLEN];
    1 |9 [" V: e% _7 S0 ?/ f
19.     int listenfd, connectfd;   /* socket descriptors */
    , b! Z; {) n* N) K
20.     struct sockaddr_in server; /* server's address information */
    
21.     struct sockaddr_in client; /* client's address information */
    4 _* C% ^1 u+ F6 z7 _) o4 @
22.     socklen_t addrlen;
      ?) T/ n  j, ^7 r5 \
23.     /* Create TCP socket */
    
24.     if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    : n  w$ R4 c6 }
25.     {
    
26.         /* handle exception */
    ( P& H4 P3 y' h0 H
27.         perror("socket() error. Failed to initiate a socket");
    % u7 e) l7 `  G/ g% I; Y
28.         exit(1);
    & h! T: |& J. n5 d6 j7 w6 ~
29.     }
    - t0 @+ Y0 w2 Q% I, g& }" i* t  y
30. 
    9 R  l0 a5 D2 ~
31.     /* set socket option */
    ! d4 q. S5 k, O% T% C$ a
32.     int opt = SO_REUSEADDR;
    : A& S( R8 B8 k5 {9 B# k. I8 y- @
33.     setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
    
34. 
    1 S, m+ E& \7 G. j. i
35.     bzero(&server, sizeof(server));
    / O2 n/ ?; u$ |2 D- H: D& v8 t7 H
36. 
      w: |! z1 G$ v1 F& K
37.     server.sin_family = AF_INET;
    
38.     server.sin_port = htons(PORT);
    4 b3 O3 k, L% ?# k! l! Y# i
39.     server.sin_addr.s_addr = htonl(INADDR_ANY);
    - J: ^9 [6 d4 S. c
40.     if(bind(listenfd, (struct sockaddr *)&server, sizeof(server)) == -1)
    
41.     {
    
42.         /* handle exception */
      \+ [" J8 U7 a7 z0 H- s; g5 P
43.         perror("Bind() error.");
    
44.         exit(1);
    
45.     }
    : M) w* S' z# u9 n4 |
46.    
    
47.     if(listen(listenfd, BACKLOG) == -1)
    
48.     {
    
49.         perror("listen() error. \n");
    # G8 h+ ?8 {. e1 r
50.         exit(1);
    
51.     }
    
52. 
    1 E$ R0 V; a1 \. Z  k+ m
53.     addrlen = sizeof(client);
    
54.     while(1){
    $ _9 ]# Q6 p/ `6 k$ U2 u
55.         if((connectfd=accept(listenfd,(struct sockaddr *)&client, &addrlen))==-1)
    
56.            {
    ) v1 ?; n8 g, w4 ~+ F: h2 n0 T
57.             perror("accept() error. \n");
    
58.             exit(1);
    
59.            }
    * ~; Y1 Q2 m2 B2 V2 A0 L
60. 
    
61.         struct timeval tv;
    
62.         gettimeofday(&tv, NULL);
    * M) `6 F: V5 j4 b; g
63.            printf("You got a connection from client's ip %s, port %d at time %ld.%ld\n",inet_ntoa(client.sin_addr),htons(client.sin_port), tv.tv_sec,tv.tv_usec);
    ) {  I, t2 h% ~/ c2 ]
64.         
    
65.         int iret=-1;
    - y! x$ C% v) V' ], {
66.         while(1)
    
67.         {
    , ~+ l* G5 n5 q5 r+ R
68.             iret = recv(connectfd, buf, MAXRECVLEN, 0);
    : M8 p# X+ W7 x8 u
69.             if(iret>0)
    
70.             {
    
71.                 printf("%s\n", buf);
    8 y3 Y$ F) w; G9 [/ o: U! x& ]" f
72.             }else
    9 m2 L! Z6 x+ M9 C/ C  O
73.             {
    
74.                 close(connectfd);
    
75.                 break;
    
76.             }
    
77.             /* print client's ip and port */
    ) I$ a- p* Z/ ^
78.             send(connectfd, buf, iret, 0); /* send to the client welcome message */
    
79.         }
    
80.     }
      V" _+ B& ?! S( B1 q7 u  ]" {
81.     close(listenfd); /* close listenfd */
    
82.     return 0;
    $ D; u% o  w( J) V1 c
83. }

复制代码

（3）编译运行

以上两个程序放在同一个目录下，比如 /home/horstxu/Cprog/tcpCSmodel

命令行进入该目录 $ cd /home/horstxu/Cprog/tcpCSmodel

命令行执行 $ gcc -o client client.c ，可以编译出客户端程序。

命令行执行 $ gcc -o server server.c，可以编译出服务端程序。

命令行执行 $ ./server，启动server程序。

这时你可能需要重新打开一个命令行窗口，到刚才的目录下，执行 $ ./client 127.0.0.1，启动客户端程序，就可以看到结果了。

客户端：

1. $ ./client 127.0.0.1
   ; S0 E- x2 T4 Q4 ~8 a
2. 
   ! G% k0 m: h' Y
3. server message:horst

复制代码

服务器端：

1. $./server
   9 h$ V# t2 p& y8 a" I- O8 I5 n: Z1 H
2. you got a connection from client`s ip 127.0.0.1, port 60865 at time 1418281267.643428

复制代码

本程序客户端会自动退出，服务器不会，因此如果想停掉服务器程序，直接在命令行界面按键盘Ctrl+C停止。

程序实现的功能很简单，就是服务器监听4321端口，客户端与之建立TCP连接后，再发送字符串“horst\n”到服务端，服务端打印出来，然后再把字符串传回给客户端，客户端再打印出来。然后客户端关闭连接退出，而服务端继续监听4321端口等待下一次连接。

. N) t$ T( G$ f# ^* ]

admin

服务端启动,客户端通过ip地址连接服务端,然后输入要发送的文件名,发送文件到服务段.

1. /*client.c*/
   
2. #include<netinet/in.h>                         // for sockaddr_in  
   
3. #include<sys/types.h>                          // for socket  
   ; m  R/ X7 {5 M5 @6 m5 J/ f( j) d7 w
4. #include<sys/socket.h>                         // for socket  
   0 m1 y6 t( z3 ~% [. w9 }
5. #include<stdio.h>                              // for printf  
   
6. #include<stdlib.h>                             // for exit  
   
7. #include<string.h>                             // for bzero  
   " i1 G4 }3 j% i; N
8. 
   3 k5 n* x8 {& D. Q8 ?# F2 y% j7 v
9. #define HELLO_WORLD_SERVER_PORT       6666  
   
10. #define BUFFER_SIZE                   1024  
    
11. #define FILE_NAME_MAX_SIZE            512  
    
12. 
    
13. int main(int argc, char **argv)  
    , W; \( ]/ H. O# @8 K4 J6 a
14. {  
    , ?6 p8 W6 V1 V& I( B3 B1 U' u& Z
15.     if (argc != 2)  
    
16.     {  
    
17.         printf("Usage: ./%s ServerIPAddress\n", argv[0]);  
    
18.         exit(1);  
    9 N& d9 B+ x6 W) `
19.     }  
    
20. 
    , _: L5 ]( Z, K" L4 Z: s
21.     // 设置一个socket地址结构client_addr, 代表客户机的internet地址和端口  
    ) s: C6 \* H3 E: q: Q& v3 t; J" _6 Z
22.     struct sockaddr_in client_addr;  
    7 ?. |, w- r( O7 O: @) w" Q
23.     bzero(&client_addr, sizeof(client_addr));  
    , o9 E) R& ?: Z6 D- s1 Z" v( P  i+ g
24.     client_addr.sin_family = AF_INET; // internet协议族  
    
25.     client_addr.sin_addr.s_addr = htons(INADDR_ANY); // INADDR_ANY表示自动获取本机地址  
    
26.     client_addr.sin_port = htons(0); // auto allocated, 让系统自动分配一个空闲端口  
    8 u( x/ G4 x# T
27. 
    ; V: s6 t* _8 N  d
28.     // 创建用于internet的流协议(TCP)类型socket，用client_socket代表客户端socket  
    
29.     int client_socket = socket(AF_INET, SOCK_STREAM, 0);  
    ! _2 r& J" @- ~5 Q
30.     if (client_socket < 0)  
    
31.     {  
    
32.         printf("Create Socket Failed!\n");  
    . J' o0 B2 L- h' m
33.         exit(1);  
      x5 H9 n$ C7 e% [$ ^* Q
34.     }  
    
35. 
    " P1 o% s5 z9 ]2 @7 m) E+ t- M
36.     // 把客户端的socket和客户端的socket地址结构绑定   
    
37.     if (bind(client_socket, (struct sockaddr*)&client_addr, sizeof(client_addr)))  
    
38.     {  
    
39.         printf("Client Bind Port Failed!\n");  
    9 ~& a# Y( ]7 q% e- Z7 N+ e& p* X
40.         exit(1);  
    * G7 ?  I/ W% e2 e6 w) n) I! E
41.     }  
    
42. 
    - @+ q; x+ @3 h  z' v' x2 o
43.     // 设置一个socket地址结构server_addr,代表服务器的internet地址和端口  
    
44.     struct sockaddr_in  server_addr;  
    
45.     bzero(&server_addr, sizeof(server_addr));  
    2 u* N/ b2 x7 D$ `
46.     server_addr.sin_family = AF_INET;  
    6 ?( h( g, _; m
47. 
    ! t# e+ e# p+ ~8 y) ]" j: D
48.     // 服务器的IP地址来自程序的参数   
    , r1 f0 b/ r+ v+ |: ~, T# i# V
49.     if (inet_aton(argv[1], &server_addr.sin_addr) == 0)  
    
50.     {  
    8 e% P9 N2 Q3 v3 j4 c  O
51.         printf("Server IP Address Error!\n");  
    ' h- o% x6 {0 w
52.         exit(1);  
    0 c: e* A/ m7 k9 B+ `
53.     }  
    ; y/ @4 Y& j  _' b; y0 V
54. 
    3 v( F7 A0 F' ^+ ]+ v  m, M
55.     server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);  
    2 i: O5 S7 p5 }$ s3 L9 s
56.     socklen_t server_addr_length = sizeof(server_addr);  
    
57. 
    5 s" N1 x9 C0 o9 a8 t
58.     // 向服务器发起连接请求，连接成功后client_socket代表客户端和服务器端的一个socket连接  
    
59.     if (connect(client_socket, (struct sockaddr*)&server_addr, server_addr_length) < 0)  
    
60.     {  
    
61.         printf("Can Not Connect To %s!\n", argv[1]);  
    
62.         exit(1);  
    
63.     }  
    0 n- P( Z# J7 H
64. 
    # u' r0 w+ b6 d3 b
65.     char file_name[FILE_NAME_MAX_SIZE + 1];  
    
66.     bzero(file_name, sizeof(file_name));  
    & L  [0 v6 P( m( l& z' ]
67.     printf("Please Input File Name On Server.\t");  
    
68.     scanf("%s", file_name);  
    ' O. i/ f" G4 u$ l' J- F: S9 x
69. 
    
70.     char buffer[BUFFER_SIZE];  
    
71.     bzero(buffer, sizeof(buffer));  
    
72.     strncpy(buffer, file_name, strlen(file_name) > BUFFER_SIZE ? BUFFER_SIZE : strlen(file_name));  
    6 S$ r& C; E7 Z1 z6 h6 x; H5 J! Q
73.     // 向服务器发送buffer中的数据，此时buffer中存放的是客户端需要接收的文件的名字  
    
74.     send(client_socket, buffer, BUFFER_SIZE, 0);  
    4 T5 ?& r3 B8 `. L
75. 
    9 x; K* H- Y$ C0 {* v+ \0 ~
76.     FILE *fp = fopen(file_name, "w");  
    
77.     if (fp == NULL)  
    
78.     {  
    
79.         printf("File:\t%s Can Not Open To Write!\n", file_name);  
    6 \- R) V  Q2 Y! m# y
80.         exit(1);  
    
81.     }  
    
82. 
    
83.     // 从服务器端接收数据到buffer中   
    
84.     bzero(buffer, sizeof(buffer));  
    0 t+ T  q* r% B( }  s0 z$ J1 ~
85.     int length = 0;  
    & |+ o  p* ]$ W1 W( w+ ], w
86.     while(length = recv(client_socket, buffer, BUFFER_SIZE, 0))  
    - {1 y3 d$ X0 ?- T: C
87.     {  
    
88.         if (length < 0)  
    
89.         {  
      B5 i0 ^8 k6 `0 q4 A" K
90.             printf("Recieve Data From Server %s Failed!\n", argv[1]);  
    
91.             break;  
    3 \% ~, {8 ~/ t
92.         }  
    2 i$ |7 n3 G2 K1 r. |2 W, B2 v
93. 
    2 u- S" l5 L2 D7 R
94.         int write_length = fwrite(buffer, sizeof(char), length, fp);  
    5 v! x$ A) s. K* V
95.         if (write_length < length)  
    + D5 D9 Q4 _3 N  U0 ~8 {7 y
96.         {  
    
97.             printf("File:\t%s Write Failed!\n", file_name);  
    
98.             break;  
    
99.         }  
    
100.         bzero(buffer, BUFFER_SIZE);  
     9 _9 h. T% e$ [4 @
101.     }  
     
102. 
     
103.     printf("Recieve File:\t %s From Server[%s] Finished!\n", file_name, argv[1]);  
     
104. 
     8 {/ Q6 H$ b2 ?. e) K
105.     // 传输完毕，关闭socket   
     
106.     fclose(fp);  
     2 x3 ?& V4 r" f& p9 N; `, d  m+ g
107.     close(client_socket);  
     9 F/ m9 D) Q8 n
108.     return 0;  
     
109. 
     
110. }  
     
111. 
     

复制代码

1. /*server.c*/
   
2. #include<netinet/in.h>
   
3. #include<sys/types.h>
   ; E2 A9 f6 o0 S- e. s6 c
4. #include<sys/socket.h>
   5 M! }3 I" H; ]' r* a0 y- P  Z
5. #include<stdio.h>
   6 l' }9 m  ~: A* T: ?
6. #include<stdlib.h>
   % u, ]. Y& N/ e$ f' \
7. #include<string.h>
   ( S/ j$ I: K7 w! E2 A) @" a
8. 
   
9. #define HELLO_WORLD_SERVER_PORT    6666         //端口号
   1 ^2 j% M! o& }8 f/ c& B
10. #define LENGTH_OF_LISTEN_QUEUE     20
    
11. #define BUFFER_SIZE                1024
    ' M6 F- t3 z- R$ F
12. #define FILE_NAME_MAX_SIZE         512
    ) p/ s5 {4 S( a5 P- {& r* g$ s5 y* Q
13. 
    ( J: `3 c+ y" e0 P- l
14. int main(int argc, char **argv)
    8 O( I  U( L% d7 D7 y8 f
15. {
    & ~: V! K, }% v% N* {+ x, m
16.     // set socket's address information
    
17.     // 设置一个socket地址结构server_addr,代表服务器internet的地址和端口
    
18.     struct sockaddr_in   server_addr;
      N8 Y0 F) }3 T
19.     bzero(&server_addr, sizeof(server_addr));
    ! H4 O; w' k5 O; K7 l% ^. ^) ~' F
20.     server_addr.sin_family = AF_INET;
    3 \& p# E1 _* m( O$ I
21.     server_addr.sin_addr.s_addr = htons(INADDR_ANY);
    
22.     server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);
    
23. 
    % q! h+ A" F5 d
24.     // create a stream socket
    
25.     // 创建用于internet的流协议(TCP)socket，用server_socket代表服务器向客户端提供服务的接口
    2 H' }- T& f2 V; U. P' r
26.     int server_socket = socket(PF_INET, SOCK_STREAM, 0);
    6 K7 R1 K& H5 Z# C% h, Y
27.     if (server_socket < 0)
    ( c+ n6 z8 \% z+ i
28.     {
    ' q0 G! ^/ Q/ i. {2 t# G8 E
29.         printf("Create Socket Failed!\n");
    $ t: n0 x- J# Z& y3 A1 ]5 M
30.         exit(1);
    $ i0 P! h, F. E
31.     }
    
32. 
    2 z- ^' t5 s$ U
33.     // 把socket和socket地址结构绑定
    
34.     if (bind(server_socket, (struct sockaddr*)&server_addr, sizeof(server_addr)))
    ' r* t; ^3 J6 a
35.     {
    - A$ Y, n" t6 y3 D" F
36.         printf("Server Bind Port: %d Failed!\n", HELLO_WORLD_SERVER_PORT);
    
37.         exit(1);
    
38.     }
    
39. 
    9 a: F' q: D' M2 X/ s
40.     // server_socket用于监听
    
41.     if (listen(server_socket, LENGTH_OF_LISTEN_QUEUE))
    * e$ r3 v9 }, @
42.     {
    
43.         printf("Server Listen Failed!\n");
    
44.         exit(1);
      _# l( C4 Z. N0 J- R
45.     }
    
46. 
    
47.     // 服务器端一直运行用以持续为客户端提供服务
    
48.     while(1)
    
49.     {
    5 g1 n# N& k8 s/ j. o
50.         // 定义客户端的socket地址结构client_addr，当收到来自客户端的请求后，调用accept
    
51.         // 接受此请求，同时将client端的地址和端口等信息写入client_addr中
    % [& n" }% j4 n, n) V" c7 V
52.         struct sockaddr_in client_addr;
    & Z9 q9 o6 N. u8 q
53.         socklen_t          length = sizeof(client_addr);
      d- ]: v. s5 S( y* q  \
54. 
    6 e) k$ t! y6 \4 f. [5 M4 I
55.         // 接受一个从client端到达server端的连接请求,将客户端的信息保存在client_addr中
    
56.         // 如果没有连接请求，则一直等待直到有连接请求为止，这是accept函数的特性，可以
    + D! m: W0 x9 f" b5 ^
57.         // 用select()来实现超时检测
    
58.         // accpet返回一个新的socket,这个socket用来与此次连接到server的client进行通信
    7 |) c* d, n. a* L. A7 V, J4 e
59.         // 这里的new_server_socket代表了这个通信通道
    
60.         int new_server_socket = accept(server_socket, (struct sockaddr*)&client_addr, &length);
    
61.         if (new_server_socket < 0)
    : n6 A5 E, t, y- J
62.         {
    
63.             printf("Server Accept Failed!\n");
    
64.             break;
    / h7 N9 v/ \5 ~, J0 A
65.         }
    0 ]) f1 V$ S1 p0 t9 `
66. 
    
67.         char buffer[BUFFER_SIZE];
    8 `+ g  h$ b& }: W! F# B
68.         bzero(buffer, sizeof(buffer));
    
69.         length = recv(new_server_socket, buffer, BUFFER_SIZE, 0);
    
70.         if (length < 0)
    
71.         {
    / s) j0 S' L" B2 _$ H9 L
72.             printf("Server Recieve Data Failed!\n");
    % c% b9 J/ f3 U7 W
73.             break;
    * {7 Y; y( ]! |0 h
74.         }
    / O; t, w- X' p
75. 
    
76.         char file_name[FILE_NAME_MAX_SIZE + 1];
    5 k' Z& K8 {/ h5 m
77.         bzero(file_name, sizeof(file_name));
    
78.         strncpy(file_name, buffer,
    
79.                 strlen(buffer) > FILE_NAME_MAX_SIZE ? FILE_NAME_MAX_SIZE : strlen(buffer));
    ) B) e7 G8 m4 H" l8 H
80. 
    ) C# u) O8 \7 ]% `0 U2 t* t4 B/ V
81.         FILE *fp = fopen(file_name, "r");
    3 l* s4 ~: I( X0 {# q5 y
82.         if (fp == NULL)
    9 X7 {* V# b! p
83.         {
    
84.             printf("File:\t%s Not Found!\n", file_name);
    
85.         }
    # i; ]% C1 a7 B! t
86.         else
    0 m8 l- u# I7 x5 q) N
87.         {
    
88.             bzero(buffer, BUFFER_SIZE);
    
89.             int file_block_length = 0;
    ! d+ _  u1 }, }* P+ j/ L: H# G: T
90.             while( (file_block_length = fread(buffer, sizeof(char), BUFFER_SIZE, fp)) > 0)
    
91.             {
    
92.                 printf("file_block_length = %d\n", file_block_length);
    
93. 
    5 ?3 V! X; K8 `7 D! v; B+ R0 v
94.                 // 发送buffer中的字符串到new_server_socket,实际上就是发送给客户端
    
95.                 if (send(new_server_socket, buffer, file_block_length, 0) < 0)
    
96.                 {
    & j( z1 H1 U' X1 p& |
97.                     printf("Send File:\t%s Failed!\n", file_name);
    
98.                     break;
    ( v5 D& ?3 F1 m( v  O1 X% ^
99.                 }
    
100. 
     0 Y2 n, g0 s! N% B) C: ^
101.                 bzero(buffer, sizeof(buffer));
     
102.             }
     ! Q" P+ \  |" R1 p# L
103.             fclose(fp);
     8 L) {8 Z2 |0 y8 _3 v
104.             printf("File:\t%s Transfer Finished!\n", file_name);
     ; b- [' W% l. p
105.         }
     % Z' M3 s1 m4 M' W4 h( U$ t/ _
106. 
     8 r6 B8 ?/ y% z) _4 |( d! ^
107.         close(new_server_socket);
     
108.     }
     
109. 
     
110.     close(server_socket);
     2 v3 T( i6 ^+ e/ l. f3 _9 a7 z0 H
111. 
     + p+ k( W* q! t2 s
112.     return 0;
     ; H1 J  z% s0 m2 z( y9 `+ M
113. }
     
114. 
     ; o: F- U2 ~- @9 i# v8 j

复制代码

$ H) f% C7 l- V5 y  O" l
! P7 X* z; m; ?( R6 I% Q* ]8 T
7 ~9 J  n$ ~0 L* L3 l5 d