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

admin

本文给出一个很实用的服务端和客户端进行TCP通信的小例子。具体实现上非常简单，只是平时编写类似程序，具体步骤经常忘记，还要总是查，暂且将其记下来，方便以后参考。
（1）客户端程序，编写一个文件client.c，内容如下：

1. #include <stdlib.h>
     d/ L  F% u" S' f/ C8 E
2. #include <stdio.h>
   $ J% |$ z" k/ ~1 _( ]
3. #include <unistd.h>
   
4. #include <string.h>
   
5. #include <sys/types.h>
   
6. #include <sys/socket.h>
   & v/ a! S7 L" [: M5 \
7. #include <netinet/in.h>
   3 [  _! k" V2 r
8. #include <netdb.h>  /* netdb is necessary for struct hostent */
   
9. 
   ; j$ z! y: P# R6 s3 C% I
10. #define PORT 4321   /* server port */
    
11. 
    
12. #define MAXDATASIZE 100
    % e: B) g  k; ?* Z$ d
13. 
    
14. int main(int argc, char *argv[])
    
15. {
    
16.     int sockfd, num;    /* files descriptors */
    
17.     char buf[MAXDATASIZE];    /* buf will store received text */
    * D  O0 p, G5 i" _9 Q4 h( v' C4 V
18.     struct hostent *he;    /* structure that will get information about remote host */
    ' c* G: Z# Y! s
19.     struct sockaddr_in server;
    ; j$ e  L  U. B- B  R
20.    
    
21.     if (argc != 2)
    ; ]& x2 C/ F4 ]
22.     {
    
23.         printf("Usage: %s <IP Address>\n",argv[0]);
      F& Y' Q  }8 f5 w1 D
24.         exit(1);
    
25.     }
      g, {3 \% K( A$ x, F4 h! q
26.    
    . R. f, O3 T; C' ^& D
27.     if((he=gethostbyname(argv[1]))==NULL)
    
28.     {
    
29.         printf("gethostbyname() error\n");
    ! b0 t( J/ \* H8 j" E9 z
30.         exit(1);
    " T  b, z: t9 t% ?! o7 e
31.     }
    ' n% [, S( n; _
32.    
    6 G( n) N& l5 S
33.     if((sockfd=socket(AF_INET,SOCK_STREAM, 0))==-1)
    
34.     {
    0 g9 d1 `7 @; F( `0 L; \! h
35.         printf("socket() error\n");
    
36.         exit(1);
    % {( v' E1 n$ B0 a, V+ r; P
37.     }
    
38.     bzero(&server,sizeof(server));
      e, [1 x+ `  q, X! _
39.     server.sin_family = AF_INET;
    
40.     server.sin_port = htons(PORT);
    
41.     server.sin_addr = *((struct in_addr *)he->h_addr);
    
42.     if(connect(sockfd, (struct sockaddr *)&server, sizeof(server))==-1)
    
43.     {
    
44.         printf("connect() error\n");
    * D# Z7 f, i$ P( g, a/ Y
45.         exit(1);
    2 I9 o& S' z2 D) `3 \; ~! {! d
46.     }
    " E! K$ e- Q3 k7 c# J+ l- _
47. 　　
    
48. 　　char str[] = "horst\n"
    & Z7 j2 z" n3 y1 m
49. 
    
50.     if((num=send(sockfd,str,sizeof(str),0))==-1){
    
51.         printf("send() error\n");
    
52.         exit(1);
    + G4 Y9 O* e9 D8 \) @
53.     }
    " v- \9 E8 `- K0 B5 J1 e9 L
54.     if((num=recv(sockfd,buf,MAXDATASIZE,0))==-1)
    # h* H* W7 r+ A- x0 [  r
55.     {
    
56.         printf("recv() error\n");
    + A1 W- V9 R7 U: L. x  E
57.         exit(1);
    9 e$ A6 s! Q9 B
58.     }
    . b; }; [+ G3 T* O' ~
59.     buf[num-1]='\0';
    
60.     printf("server message: %s\n",buf);
    
61.     close(sockfd);
    
62.     return 0;
    % K$ ]  e! A1 E2 z0 |' q2 y4 j
63. }

复制代码

（2）服务器端，编写server.c，内容如下
0 L. d2 f' y2 }1 X  N5 X

1. #include <sys/time.h>
   
2. #include <stdlib.h>
   
3. #include <stdio.h>
   
4. #include <string.h>
   
5. #include <unistd.h>
   7 I, h- K- J3 Q: ~; O
6. #include <sys/types.h>
   5 U; Y3 p% t$ X
7. #include <sys/socket.h>
   ! {7 P3 l2 m- Z* d* z2 ]
8. #include <netinet/in.h>
   
9. #include <arpa/inet.h>
   0 ^) l/ p' Z; A6 o0 M
10. 
    5 D; R! E+ u6 X2 ^* T- f8 L
11. #define PORT 4321
    2 M, I: q4 ?. W+ q4 Q
12. 
    # y/ }9 l; X" x: ]
13. #define BACKLOG 1
    
14. #define MAXRECVLEN 1024
    0 y& v9 ^( m7 X4 t2 m% z' R. v+ H
15. 
    
16. int main(int argc, char *argv[])
    / Y5 p- P( I/ G# \2 h5 `/ L1 \. i
17. {
    
18.     char buf[MAXRECVLEN];
    
19.     int listenfd, connectfd;   /* socket descriptors */
    
20.     struct sockaddr_in server; /* server's address information */
    8 f( n, E7 Z: a9 z% }' M' L
21.     struct sockaddr_in client; /* client's address information */
    
22.     socklen_t addrlen;
    ( d- U. r! N8 Y" w  m5 [0 \
23.     /* Create TCP socket */
    
24.     if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    
25.     {
    
26.         /* handle exception */
    + ]8 p' s& ~, w) E7 g0 v0 l
27.         perror("socket() error. Failed to initiate a socket");
    
28.         exit(1);
    
29.     }
    
30. 
    2 U# L2 d" c7 |2 ]
31.     /* set socket option */
      w  r+ O% `, ]3 {/ E+ k2 Z
32.     int opt = SO_REUSEADDR;
    8 N/ \1 K  I7 u: h; R. L
33.     setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
    8 g, _  _' P& H; f
34. 
    . F3 d7 W; u; L) l
35.     bzero(&server, sizeof(server));
    
36. 
    
37.     server.sin_family = AF_INET;
    ! n! r6 B9 w, Y. W# g
38.     server.sin_port = htons(PORT);
    2 x* D9 J2 w. Y5 U' n6 ?
39.     server.sin_addr.s_addr = htonl(INADDR_ANY);
    
40.     if(bind(listenfd, (struct sockaddr *)&server, sizeof(server)) == -1)
    ! I2 c+ a7 S, X  g5 R
41.     {
    
42.         /* handle exception */
    6 C+ t' u7 `7 {. m) O7 `
43.         perror("Bind() error.");
    
44.         exit(1);
    5 w' m4 ]4 v' [
45.     }
    
46.    
    5 d7 W9 ~8 `# A* w% R+ X
47.     if(listen(listenfd, BACKLOG) == -1)
    3 {- B/ |  t& g+ ^* U- D
48.     {
    4 R* p- z, |. J! y! r% _, Z
49.         perror("listen() error. \n");
    2 N% `8 j$ e+ u1 r; c
50.         exit(1);
    
51.     }
    
52. 
      k5 U  S; V4 f7 G- q& \" V  o4 o6 K
53.     addrlen = sizeof(client);
    
54.     while(1){
    
55.         if((connectfd=accept(listenfd,(struct sockaddr *)&client, &addrlen))==-1)
    7 ~: S2 I; C6 V8 k& H
56.            {
    0 L: I, t( S- M" g7 r$ l3 R  M2 W3 f& z
57.             perror("accept() error. \n");
    / l6 \, \& p7 O' {/ A! w
58.             exit(1);
    
59.            }
    
60. 
    
61.         struct timeval tv;
      B* z0 J, b" W, G* `. ]; f1 a
62.         gettimeofday(&tv, NULL);
    
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);
    * T/ Z8 w$ u7 b8 T
64.         
    ) }* C4 T( N) I* r- u: p: |
65.         int iret=-1;
    1 i& N1 f7 ?. N8 H: S4 v
66.         while(1)
    ; Z; a2 ?$ J5 K" o9 |) d5 [) e
67.         {
    
68.             iret = recv(connectfd, buf, MAXRECVLEN, 0);
    
69.             if(iret>0)
    
70.             {
    9 g+ j$ I) ]# P& p( [& O7 T
71.                 printf("%s\n", buf);
    6 p# [/ v8 b  c5 I9 D3 p# u0 {
72.             }else
    . T0 u% y5 s6 ?* s! t7 ?
73.             {
    
74.                 close(connectfd);
    3 E: V6 k% X( R  r2 c
75.                 break;
    
76.             }
    
77.             /* print client's ip and port */
    . n5 Y6 z# g- M# I! `# R8 P
78.             send(connectfd, buf, iret, 0); /* send to the client welcome message */
    
79.         }
    
80.     }
    " i1 Z/ D5 Q8 {" M: A
81.     close(listenfd); /* close listenfd */
    
82.     return 0;
    
83. }

复制代码

4 a' t+ ^/ H6 u  ~4 y$ H$ v, E( C

（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
   6 Q( c2 z$ u9 v# e9 d6 A
2. 
   & g. O5 _' z! e
3. server message:horst

复制代码

服务器端：

1. $./server
   
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端口等待下一次连接。

admin

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

1. /*client.c*/
   % x1 F) Y8 @1 w0 x4 K3 K. K' j$ u
2. #include<netinet/in.h>                         // for sockaddr_in  
   1 M) t8 [! J3 n- ]( q0 [
3. #include<sys/types.h>                          // for socket  
   
4. #include<sys/socket.h>                         // for socket  
   
5. #include<stdio.h>                              // for printf  
   
6. #include<stdlib.h>                             // for exit  
   3 j/ e6 w/ B* q, R# w1 R" u
7. #include<string.h>                             // for bzero  
   
8. 
   6 h, Y* o. H  `3 o
9. #define HELLO_WORLD_SERVER_PORT       6666  
   3 e5 \2 H0 b/ a$ o# d4 v& e) Z
10. #define BUFFER_SIZE                   1024  
    ( m5 U; v" G' f6 P# V; v/ J
11. #define FILE_NAME_MAX_SIZE            512  
    
12. 
    
13. int main(int argc, char **argv)  
    3 G9 l4 D3 m8 }+ h4 H
14. {  
    1 ~0 _! A4 s3 B& r9 m5 f& V) Q' A
15.     if (argc != 2)  
    , {4 v; U  g) _7 `$ ?7 d/ W8 [
16.     {  
    
17.         printf("Usage: ./%s ServerIPAddress\n", argv[0]);  
    " I$ G- _4 E& F
18.         exit(1);  
    
19.     }  
    8 p; A+ i5 r1 B2 F. k5 C- A
20. 
    
21.     // 设置一个socket地址结构client_addr, 代表客户机的internet地址和端口  
    
22.     struct sockaddr_in client_addr;  
    ! h) o0 P& p" x& f/ p/ T5 u
23.     bzero(&client_addr, sizeof(client_addr));  
      \0 K; }* ^6 G1 f+ v0 N6 Z
24.     client_addr.sin_family = AF_INET; // internet协议族  
    
25.     client_addr.sin_addr.s_addr = htons(INADDR_ANY); // INADDR_ANY表示自动获取本机地址  
    & v5 @" i* V6 e# N* @$ Z
26.     client_addr.sin_port = htons(0); // auto allocated, 让系统自动分配一个空闲端口  
    ' K/ r- `& A( A) g  E
27. 
    
28.     // 创建用于internet的流协议(TCP)类型socket，用client_socket代表客户端socket  
    $ r2 E2 \/ K# a+ d8 \1 p
29.     int client_socket = socket(AF_INET, SOCK_STREAM, 0);  
    
30.     if (client_socket < 0)  
    * s+ t. P& N( I! M
31.     {  
    
32.         printf("Create Socket Failed!\n");  
    
33.         exit(1);  
    
34.     }  
    # O5 j# Q# k0 ^, b+ h
35. 
    
36.     // 把客户端的socket和客户端的socket地址结构绑定   
    5 n# |% y# R7 ^: i' N& f5 }
37.     if (bind(client_socket, (struct sockaddr*)&client_addr, sizeof(client_addr)))  
    ) E. ~/ ?& n$ Z+ ?. K2 @3 n
38.     {  
    
39.         printf("Client Bind Port Failed!\n");  
    
40.         exit(1);  
    5 B5 e5 |: J% k' q
41.     }  
    
42. 
    4 r6 f* L- A! v: L& L5 b' j
43.     // 设置一个socket地址结构server_addr,代表服务器的internet地址和端口  
      M8 ^6 Y2 Q) ^: w
44.     struct sockaddr_in  server_addr;  
    6 X: n/ Y4 c. V. t1 P' E! u+ o
45.     bzero(&server_addr, sizeof(server_addr));  
    
46.     server_addr.sin_family = AF_INET;  
    
47. 
      @* v! `* A# W% o
48.     // 服务器的IP地址来自程序的参数   
    4 N& w8 p6 m1 }8 F6 w9 G
49.     if (inet_aton(argv[1], &server_addr.sin_addr) == 0)  
    5 N  f, Y% d8 R# S7 G# a2 Z' A
50.     {  
    1 a. T8 a: A; ]8 f" J' l$ @, B
51.         printf("Server IP Address Error!\n");  
    * d6 x+ |/ X# U  s
52.         exit(1);  
    # i" T& U4 q3 M' W6 }/ D
53.     }  
    - @5 j  {. O9 \' {0 i$ n
54. 
    ) F3 M# n4 Q& q6 E8 Z
55.     server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);  
    + S& z" X8 U; m9 G6 V) w% d  k/ V
56.     socklen_t server_addr_length = sizeof(server_addr);  
    6 i( K7 Q: |& O
57. 
    
58.     // 向服务器发起连接请求，连接成功后client_socket代表客户端和服务器端的一个socket连接  
    8 a* P- ~* R! h) y6 X7 R
59.     if (connect(client_socket, (struct sockaddr*)&server_addr, server_addr_length) < 0)  
    " T& H9 }! u  H3 S: H( L
60.     {  
    ( z9 p5 X/ [) D4 h; e* X" e' k
61.         printf("Can Not Connect To %s!\n", argv[1]);  
    3 Z4 v3 ?5 Q4 Q# a/ v) J
62.         exit(1);  
    
63.     }  
    
64. 
    
65.     char file_name[FILE_NAME_MAX_SIZE + 1];  
    # }4 a7 N$ P7 w' [* P2 p
66.     bzero(file_name, sizeof(file_name));  
    $ l1 \3 c6 A6 n5 ?; i% j
67.     printf("Please Input File Name On Server.\t");  
    - X5 u" R0 F' K+ `4 C
68.     scanf("%s", file_name);  
    
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));  
    
73.     // 向服务器发送buffer中的数据，此时buffer中存放的是客户端需要接收的文件的名字  
    
74.     send(client_socket, buffer, BUFFER_SIZE, 0);  
    
75. 
    & w- w' u% H& b! I
76.     FILE *fp = fopen(file_name, "w");  
    
77.     if (fp == NULL)  
    
78.     {  
    8 o( r9 O! L& G/ @" @9 Q
79.         printf("File:\t%s Can Not Open To Write!\n", file_name);  
    * o& k( }5 Z4 g1 e
80.         exit(1);  
    
81.     }  
    
82. 
    ( g, {. T" k2 i
83.     // 从服务器端接收数据到buffer中   
    1 R; ~7 H# p0 R, @6 [0 _
84.     bzero(buffer, sizeof(buffer));  
    
85.     int length = 0;  
    
86.     while(length = recv(client_socket, buffer, BUFFER_SIZE, 0))  
    ' X. Q8 v0 [' L+ p; e: ^; ?' g
87.     {  
    , M' T# G& |9 {# a5 a
88.         if (length < 0)  
    
89.         {  
    
90.             printf("Recieve Data From Server %s Failed!\n", argv[1]);  
    0 }$ i  a# o, b) C* z
91.             break;  
    
92.         }  
    
93. 
    4 f& U) W0 l8 F3 n6 O. g# U! ?
94.         int write_length = fwrite(buffer, sizeof(char), length, fp);  
    
95.         if (write_length < length)  
    0 ]5 ?/ S+ K0 c6 d
96.         {  
    : T1 V" ~6 j! a. [/ K7 y2 n' P3 P
97.             printf("File:\t%s Write Failed!\n", file_name);  
    1 |# a* Q- M6 e/ w" b5 G# f
98.             break;  
    5 n9 z) [6 c  d& a8 \6 I8 m$ ]$ D
99.         }  
    ' \! d* z! c% {# E7 i9 v
100.         bzero(buffer, BUFFER_SIZE);  
     
101.     }  
     ' B; _. K: a' `2 ~- G* }& T
102. 
     
103.     printf("Recieve File:\t %s From Server[%s] Finished!\n", file_name, argv[1]);  
     
104. 
     / d0 h; H9 h7 l9 ^3 k" D, I
105.     // 传输完毕，关闭socket   
     ) ^, ~! p& H9 p, {1 @9 {
106.     fclose(fp);  
     
107.     close(client_socket);  
     / J  H* u9 R' c/ U& P
108.     return 0;  
     
109. 
     " m' K  g+ ?- k, Y# D7 K1 v
110. }  
     % {0 o/ M' I- ^8 X! m  B
111. 
     : T3 ?; S& S3 v

复制代码

1. /*server.c*/
   $ o- S' i/ W8 ]9 y( Q, h) J2 _: g
2. #include<netinet/in.h>
   4 E! A" x- F! u
3. #include<sys/types.h>
   
4. #include<sys/socket.h>
   
5. #include<stdio.h>
   * V& z2 ^) i; ]" k: M+ h, P
6. #include<stdlib.h>
   
7. #include<string.h>
   
8. 
   
9. #define HELLO_WORLD_SERVER_PORT    6666         //端口号
   
10. #define LENGTH_OF_LISTEN_QUEUE     20
    & A; x3 X7 s/ L2 Q
11. #define BUFFER_SIZE                1024
    
12. #define FILE_NAME_MAX_SIZE         512
    
13. 
    6 @* c9 O+ q& x9 g- t& C
14. int main(int argc, char **argv)
    # p) A0 L3 k4 ]$ J: f9 |
15. {
    
16.     // set socket's address information
    
17.     // 设置一个socket地址结构server_addr,代表服务器internet的地址和端口
    
18.     struct sockaddr_in   server_addr;
    
19.     bzero(&server_addr, sizeof(server_addr));
    
20.     server_addr.sin_family = AF_INET;
    
21.     server_addr.sin_addr.s_addr = htons(INADDR_ANY);
    , b% p. x- \9 H( Q- T
22.     server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);
    
23. 
    
24.     // create a stream socket
    ( M/ @( m/ i3 ~" B8 L! w+ P
25.     // 创建用于internet的流协议(TCP)socket，用server_socket代表服务器向客户端提供服务的接口
    ! V$ n- a3 ?4 \# z4 d& V" J6 S
26.     int server_socket = socket(PF_INET, SOCK_STREAM, 0);
    / M0 n! r4 R7 y9 Q& Q* w
27.     if (server_socket < 0)
    : d4 }  |7 Z0 T9 z
28.     {
    0 V; m6 P* C( Y8 z7 S
29.         printf("Create Socket Failed!\n");
    
30.         exit(1);
    5 |' f* v! O* c+ e9 U
31.     }
    
32. 
    3 S1 R9 ^& ^& N5 S  r
33.     // 把socket和socket地址结构绑定
    " p, h# s+ n& d1 l
34.     if (bind(server_socket, (struct sockaddr*)&server_addr, sizeof(server_addr)))
    $ ^: m* i! m. m; l& [. \
35.     {
    3 q1 T2 I" }. l  ~4 |  _# j; `1 {' t, S
36.         printf("Server Bind Port: %d Failed!\n", HELLO_WORLD_SERVER_PORT);
    
37.         exit(1);
    . d' d' j+ l7 a3 k1 L5 P
38.     }
    
39. 
    ; J  l5 k) R* J$ s4 a
40.     // server_socket用于监听
    : K' G6 w9 K, Q' v; s" \
41.     if (listen(server_socket, LENGTH_OF_LISTEN_QUEUE))
    ) [) i: c  a; O
42.     {
    " m# z& o; h4 K/ S" U, l, S
43.         printf("Server Listen Failed!\n");
    5 r! W9 w2 _. f/ s$ W. c6 W
44.         exit(1);
    
45.     }
    
46. 
    
47.     // 服务器端一直运行用以持续为客户端提供服务
    * I( o4 k3 ]# T+ |8 d$ B
48.     while(1)
    
49.     {
    2 O( L/ R4 {- ]7 G
50.         // 定义客户端的socket地址结构client_addr，当收到来自客户端的请求后，调用accept
    / ]' x5 a# G6 U' B3 u
51.         // 接受此请求，同时将client端的地址和端口等信息写入client_addr中
    
52.         struct sockaddr_in client_addr;
    
53.         socklen_t          length = sizeof(client_addr);
    5 l3 n6 h# W" t! W' v3 O4 z! e
54. 
    
55.         // 接受一个从client端到达server端的连接请求,将客户端的信息保存在client_addr中
    
56.         // 如果没有连接请求，则一直等待直到有连接请求为止，这是accept函数的特性，可以
    
57.         // 用select()来实现超时检测
    9 x, B! }* a2 `. e6 d
58.         // accpet返回一个新的socket,这个socket用来与此次连接到server的client进行通信
    
59.         // 这里的new_server_socket代表了这个通信通道
    0 u3 s0 B6 V5 s7 V5 U8 u8 W0 [" L
60.         int new_server_socket = accept(server_socket, (struct sockaddr*)&client_addr, &length);
    2 N0 ^6 |! D( u- b/ Z5 d; @
61.         if (new_server_socket < 0)
    
62.         {
    , {% ]. R9 V6 Q4 B- w6 R
63.             printf("Server Accept Failed!\n");
    
64.             break;
    
65.         }
    9 g, ]' Z! V) W: y) y
66. 
    
67.         char buffer[BUFFER_SIZE];
    6 M+ n, j) S0 N5 O7 V/ |1 m: v! k1 }$ t
68.         bzero(buffer, sizeof(buffer));
    
69.         length = recv(new_server_socket, buffer, BUFFER_SIZE, 0);
    0 i% f' b% k& u. b( a5 f: |+ J
70.         if (length < 0)
    , q- f- t) x$ Q6 o9 s  j9 M
71.         {
    & z/ P$ p& v# Q6 G# C4 p4 }
72.             printf("Server Recieve Data Failed!\n");
    / p' X' S/ ^# w' j
73.             break;
    
74.         }
    2 \: b6 `2 d9 j, r
75. 
    
76.         char file_name[FILE_NAME_MAX_SIZE + 1];
    
77.         bzero(file_name, sizeof(file_name));
    5 m$ n! s( [+ S3 j
78.         strncpy(file_name, buffer,
    
79.                 strlen(buffer) > FILE_NAME_MAX_SIZE ? FILE_NAME_MAX_SIZE : strlen(buffer));
    # w8 O) W- {" F. @9 m/ H
80. 
    8 I* v- P, Z* x0 I! K) j+ y# T
81.         FILE *fp = fopen(file_name, "r");
    9 w4 r) f- C( N8 d
82.         if (fp == NULL)
    
83.         {
    
84.             printf("File:\t%s Not Found!\n", file_name);
    
85.         }
    
86.         else
    
87.         {
    7 F* k" v& _: a+ F! @
88.             bzero(buffer, BUFFER_SIZE);
    $ [; Q- E5 k# k  e8 Y/ N5 a9 [
89.             int file_block_length = 0;
    6 J5 c5 @! ]  D% v7 V
90.             while( (file_block_length = fread(buffer, sizeof(char), BUFFER_SIZE, fp)) > 0)
    5 n) h2 y! p# A" C, o: J
91.             {
    
92.                 printf("file_block_length = %d\n", file_block_length);
    
93. 
    . w1 c5 g& U. J, ?* [) j( M. P
94.                 // 发送buffer中的字符串到new_server_socket,实际上就是发送给客户端
    
95.                 if (send(new_server_socket, buffer, file_block_length, 0) < 0)
    3 s0 U. Z6 |" _5 x$ ^
96.                 {
    
97.                     printf("Send File:\t%s Failed!\n", file_name);
    
98.                     break;
    * Q* d: E2 A+ o3 ~. A
99.                 }
    ; Y8 y, L/ J. S, j9 v
100. 
     
101.                 bzero(buffer, sizeof(buffer));
     4 l* A1 L4 u% n' S; E2 B' T" D7 h
102.             }
     , I+ i& ?1 [0 [- O
103.             fclose(fp);
     
104.             printf("File:\t%s Transfer Finished!\n", file_name);
     
105.         }
     
106. 
     
107.         close(new_server_socket);
     ! o6 t: R! W/ ~/ ^6 c; }% d
108.     }
     % m0 K1 s# B/ f9 s( Q. ^" H
109. 
     
110.     close(server_socket);
     & j; Z0 k; F/ I; S% x
111. 
     : r. p- k$ M3 d6 _( w
112.     return 0;
     
113. }
     
114. 
     

复制代码

- J* ?" S8 H9 _1 \* [