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

admin

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

1. #include <stdlib.h>
   1 @% A. ^1 t0 N% ^
2. #include <stdio.h>
   + m7 |& ~' R1 [# l
3. #include <unistd.h>
   
4. #include <string.h>
   / e1 v( \0 n7 X7 Z4 s& K! O
5. #include <sys/types.h>
   
6. #include <sys/socket.h>
   
7. #include <netinet/in.h>
   8 q' O; n8 w0 n1 e6 j& D* x( D
8. #include <netdb.h>  /* netdb is necessary for struct hostent */
   
9. 
   " ?* ~1 ?1 b$ S6 E; s: ~
10. #define PORT 4321   /* server port */
    
11. 
    " q  w% Y+ P) S( J" z" `
12. #define MAXDATASIZE 100
    $ u2 {4 `( {$ ?9 }' J& Z+ s
13. 
    
14. int main(int argc, char *argv[])
    
15. {
    
16.     int sockfd, num;    /* files descriptors */
    
17.     char buf[MAXDATASIZE];    /* buf will store received text */
    ! T, s! w! p) [) s: i0 a
18.     struct hostent *he;    /* structure that will get information about remote host */
    
19.     struct sockaddr_in server;
    ; J0 I5 q! y. |7 ?$ U3 E+ i; R& T; g
20.    
    * L3 g  v9 }; |0 v+ w
21.     if (argc != 2)
      I. j7 {+ Y" a; f- P( \
22.     {
    ( c8 Y3 n1 V  u- L. N. g' p
23.         printf("Usage: %s <IP Address>\n",argv[0]);
    
24.         exit(1);
    ) }# ?6 ~3 b( D& f2 N
25.     }
    - R( e6 w3 b4 F( G- N% j0 D! ~  {
26.    
    
27.     if((he=gethostbyname(argv[1]))==NULL)
    
28.     {
    " v1 d, p+ L" n$ @
29.         printf("gethostbyname() error\n");
    
30.         exit(1);
    * C! l( Q' M2 [; I1 m
31.     }
    
32.    
    
33.     if((sockfd=socket(AF_INET,SOCK_STREAM, 0))==-1)
    " A4 \. M$ v4 N& \/ T+ R
34.     {
    
35.         printf("socket() error\n");
    
36.         exit(1);
    % ~* l9 h. s. O& e1 S" }
37.     }
    
38.     bzero(&server,sizeof(server));
    
39.     server.sin_family = AF_INET;
    
40.     server.sin_port = htons(PORT);
    . C$ y3 t1 u: m4 Z; S* B! G
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");
    
45.         exit(1);
    & R5 P- s' O: i/ G; t: `' ]4 ]
46.     }
    
47. 　　
    
48. 　　char str[] = "horst\n"
      v; }( ], \8 ]
49. 
    
50.     if((num=send(sockfd,str,sizeof(str),0))==-1){
    
51.         printf("send() error\n");
    9 K+ c! z' O$ z" Z4 i  M4 \
52.         exit(1);
    , I, a( r7 s) ~& y
53.     }
    ( E5 f! B! B1 a5 ]8 ]+ b/ d. j1 P
54.     if((num=recv(sockfd,buf,MAXDATASIZE,0))==-1)
    
55.     {
    # K; F) L1 y* t4 J% Z
56.         printf("recv() error\n");
    
57.         exit(1);
    9 f$ A$ j% j8 |. S2 G
58.     }
    1 ?* \4 L/ }. H) r
59.     buf[num-1]='\0';
    * c, ~. D$ Z9 R2 L: w. c; u1 r
60.     printf("server message: %s\n",buf);
    
61.     close(sockfd);
    
62.     return 0;
    
63. }

复制代码

（2）服务器端，编写server.c，内容如下
; ^5 `# d8 v; a- v

1. #include <sys/time.h>
   
2. #include <stdlib.h>
   
3. #include <stdio.h>
   ' ?& ^  `2 n% d! C1 l: K
4. #include <string.h>
   
5. #include <unistd.h>
   
6. #include <sys/types.h>
     O) r1 l* G) B7 W( A: L
7. #include <sys/socket.h>
   * e2 e3 x. C7 V! h
8. #include <netinet/in.h>
   
9. #include <arpa/inet.h>
   . D! ]+ X% J0 l) K( [/ m- b
10. 
    
11. #define PORT 4321
    
12. 
    " b: F# I7 Y& Y5 q; p, \
13. #define BACKLOG 1
    : c+ A: M) N- H
14. #define MAXRECVLEN 1024
    # X3 `8 x8 I+ `+ S9 p
15. 
    4 h% C) V7 d3 `  _  N0 a6 @
16. int main(int argc, char *argv[])
    , u6 m' E3 A- v
17. {
    
18.     char buf[MAXRECVLEN];
    
19.     int listenfd, connectfd;   /* socket descriptors */
    
20.     struct sockaddr_in server; /* server's address information */
    4 U  n" Y! t& ?# i( T
21.     struct sockaddr_in client; /* client's address information */
    
22.     socklen_t addrlen;
    
23.     /* Create TCP socket */
    + _. a6 `7 h# {9 f, W' R) f4 i' m
24.     if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    
25.     {
    
26.         /* handle exception */
    
27.         perror("socket() error. Failed to initiate a socket");
    6 d: X0 f* I& H, |
28.         exit(1);
    
29.     }
    + p/ j7 s; V- s8 Q: J4 ~' K9 S; u
30. 
    
31.     /* set socket option */
    
32.     int opt = SO_REUSEADDR;
    * z' v0 j6 m. z) h$ H% ^
33.     setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
    1 H7 ]0 K/ g2 v$ M  r8 P. q
34. 
    
35.     bzero(&server, sizeof(server));
    6 N6 d/ V& d) I6 R( p# L
36. 
    
37.     server.sin_family = AF_INET;
    
38.     server.sin_port = htons(PORT);
    
39.     server.sin_addr.s_addr = htonl(INADDR_ANY);
    2 Z3 X! q& p" h2 V& m
40.     if(bind(listenfd, (struct sockaddr *)&server, sizeof(server)) == -1)
    
41.     {
    2 ]+ G4 Z! T6 g  {* S
42.         /* handle exception */
    5 L4 m/ D) E7 T0 Z5 d
43.         perror("Bind() error.");
    
44.         exit(1);
    + k8 ?! L1 @: `* M, G& q5 z/ E: I: ]
45.     }
    
46.    
    
47.     if(listen(listenfd, BACKLOG) == -1)
    + T* t. {4 K: s# _1 G5 X
48.     {
      N* L1 ]( T- y$ p2 T+ p
49.         perror("listen() error. \n");
    . {' G! q* W% `% H7 L/ P( m
50.         exit(1);
    
51.     }
    ! C3 C. R! K5 C7 ~# ?. q4 _% C" F
52. 
    
53.     addrlen = sizeof(client);
    
54.     while(1){
    * T2 J: j! B5 u0 P
55.         if((connectfd=accept(listenfd,(struct sockaddr *)&client, &addrlen))==-1)
    
56.            {
    & [/ l* C# a2 A
57.             perror("accept() error. \n");
    % \' a3 M0 q# ]- Q+ y& a
58.             exit(1);
    7 {* S3 y" `" o6 H
59.            }
    
60. 
    6 U: a; M0 |. X% @, @
61.         struct timeval tv;
    3 S2 y8 v) I( @3 J3 e6 f5 |
62.         gettimeofday(&tv, NULL);
    " O- I9 i' Z3 Q7 f8 q
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);
    
64.         
    % L1 l9 v$ Q! x0 @6 W
65.         int iret=-1;
    & y. l" t. R: M& r/ X% j' O
66.         while(1)
    1 }" W1 \- v& c7 a- P  S
67.         {
    
68.             iret = recv(connectfd, buf, MAXRECVLEN, 0);
    
69.             if(iret>0)
    2 Q3 H6 }2 s  ?, S- S* a$ r
70.             {
    0 c1 F% [& W7 O8 j$ p
71.                 printf("%s\n", buf);
    & _! d  b5 M4 L- i9 n5 Q
72.             }else
    
73.             {
    
74.                 close(connectfd);
    9 s: l* G" m! O- Z" {% e( R6 M
75.                 break;
    
76.             }
    1 o( u/ B7 W' ~1 A! U
77.             /* print client's ip and port */
    
78.             send(connectfd, buf, iret, 0); /* send to the client welcome message */
    6 B" x# ]2 o( X7 A# m, H
79.         }
    
80.     }
    
81.     close(listenfd); /* close listenfd */
    
82.     return 0;
    2 z+ v+ {( b! m! {! n! L* r
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
   9 a4 g+ ?  K/ N5 R
2. 
   . B3 V% J$ M, R# i* {
3. server message:horst

复制代码

; M- p: t. O% ^3 D8 m: q) b

服务器端：

1. $./server
     Y6 u1 w/ h3 b+ ~9 W
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*/
   
2. #include<netinet/in.h>                         // for sockaddr_in  
   
3. #include<sys/types.h>                          // for socket  
   2 c6 V2 ^+ f3 {" ~
4. #include<sys/socket.h>                         // for socket  
   " J) T# b# M! U+ J) }# i
5. #include<stdio.h>                              // for printf  
   . d7 |. z3 k" q& A3 J& ?; \5 B+ l
6. #include<stdlib.h>                             // for exit  
     N+ V6 d2 }2 O
7. #include<string.h>                             // for bzero  
   
8. 
   
9. #define HELLO_WORLD_SERVER_PORT       6666  
   : U* t3 b) M1 j  ^' s, b7 @
10. #define BUFFER_SIZE                   1024  
    
11. #define FILE_NAME_MAX_SIZE            512  
    $ I9 T" C' |: _5 B# W, s- `$ h
12. 
    . E0 m8 E5 B! \. _1 ]
13. int main(int argc, char **argv)  
    1 }" p4 x8 O4 k( \) j
14. {  
    8 N8 X, `, w& W
15.     if (argc != 2)  
    
16.     {  
    
17.         printf("Usage: ./%s ServerIPAddress\n", argv[0]);  
    ; T- c( f7 e+ `: ]' s
18.         exit(1);  
    - P4 K- ^$ b0 t: @! ~
19.     }  
      T, p' F: h& ~+ L' C
20. 
    
21.     // 设置一个socket地址结构client_addr, 代表客户机的internet地址和端口  
    7 G; y- V. `% x& G
22.     struct sockaddr_in client_addr;  
    * B" Y) V  n/ G( \( z
23.     bzero(&client_addr, sizeof(client_addr));  
    ( s/ c: t. }# x# O& P$ |: v
24.     client_addr.sin_family = AF_INET; // internet协议族  
    
25.     client_addr.sin_addr.s_addr = htons(INADDR_ANY); // INADDR_ANY表示自动获取本机地址  
    + L, \4 }: \  X- d+ u
26.     client_addr.sin_port = htons(0); // auto allocated, 让系统自动分配一个空闲端口  
    
27. 
    ) I) w* C, O$ c' t
28.     // 创建用于internet的流协议(TCP)类型socket，用client_socket代表客户端socket  
    7 c$ c5 x5 `# \0 w
29.     int client_socket = socket(AF_INET, SOCK_STREAM, 0);  
    ; \7 H/ M7 A" L+ w& W) S
30.     if (client_socket < 0)  
    ; u3 H' G8 K8 l) a& J
31.     {  
    ) M6 s; v) \; Z3 x
32.         printf("Create Socket Failed!\n");  
    3 G  Y% }% |/ ?  ^- Y. I+ y
33.         exit(1);  
    , ?) a1 ~* }5 j% {
34.     }  
    7 R. c6 ]( o# B# X4 N- c% j
35. 
    - E& r8 H/ o  }
36.     // 把客户端的socket和客户端的socket地址结构绑定   
    9 K& L, A! S& ?) x7 f" L% g* w! ~
37.     if (bind(client_socket, (struct sockaddr*)&client_addr, sizeof(client_addr)))  
    ( p. {) B# E, f: Y! k* q
38.     {  
    
39.         printf("Client Bind Port Failed!\n");  
    
40.         exit(1);  
    
41.     }  
    : C+ H; C; w- C- V4 V
42. 
    
43.     // 设置一个socket地址结构server_addr,代表服务器的internet地址和端口  
    0 N3 @0 c& C5 x' w/ e5 P
44.     struct sockaddr_in  server_addr;  
    ) [, Y$ ^& I+ c
45.     bzero(&server_addr, sizeof(server_addr));  
    
46.     server_addr.sin_family = AF_INET;  
    
47. 
    * A4 }( L* V7 U# I
48.     // 服务器的IP地址来自程序的参数   
    
49.     if (inet_aton(argv[1], &server_addr.sin_addr) == 0)  
    
50.     {  
    
51.         printf("Server IP Address Error!\n");  
    
52.         exit(1);  
    % C7 e6 ]" s% H; h
53.     }  
    
54. 
    , }. O- R5 _) d  [1 c+ W- J
55.     server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);  
    
56.     socklen_t server_addr_length = sizeof(server_addr);  
    " k( v% t7 e$ f  u! o
57. 
    
58.     // 向服务器发起连接请求，连接成功后client_socket代表客户端和服务器端的一个socket连接  
    
59.     if (connect(client_socket, (struct sockaddr*)&server_addr, server_addr_length) < 0)  
    
60.     {  
    6 r9 a& i3 p5 {4 p, T
61.         printf("Can Not Connect To %s!\n", argv[1]);  
    7 Y6 F5 h$ Y) e5 |1 Q( u
62.         exit(1);  
    & [; t: I( H; ^, E
63.     }  
    ) l# T3 l0 t8 E; O- ~5 H5 E: F* Q
64. 
    1 W& x! X- K# u( I- U8 A' G0 S) n
65.     char file_name[FILE_NAME_MAX_SIZE + 1];  
    / q; N4 Q5 }% T
66.     bzero(file_name, sizeof(file_name));  
    / o3 a& d7 q- |( P/ Q
67.     printf("Please Input File Name On Server.\t");  
    
68.     scanf("%s", file_name);  
    
69. 
    9 g' S5 b  P' K. w: E# h& K
70.     char buffer[BUFFER_SIZE];  
    
71.     bzero(buffer, sizeof(buffer));  
      t; c9 B4 e9 f6 P0 x
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);  
    * V; r. J; o) F9 w0 O) F( u, f
75. 
    2 p6 E" K4 x/ h; [, v
76.     FILE *fp = fopen(file_name, "w");  
    
77.     if (fp == NULL)  
    
78.     {  
    . o+ }( K/ S* w: |
79.         printf("File:\t%s Can Not Open To Write!\n", file_name);  
    4 a" G3 B7 Z7 H3 Z1 k: b
80.         exit(1);  
    
81.     }  
      p6 c0 k3 G2 H  i# k
82. 
    
83.     // 从服务器端接收数据到buffer中   
    
84.     bzero(buffer, sizeof(buffer));  
    
85.     int length = 0;  
    ! h/ b  p9 h- }5 G4 L9 S
86.     while(length = recv(client_socket, buffer, BUFFER_SIZE, 0))  
    " w  B( o; V' |3 \2 T5 J
87.     {  
    7 L$ h! K; A2 C, Q$ _6 I
88.         if (length < 0)  
    
89.         {  
    8 k2 T$ s0 Z. f1 r3 p% x- E
90.             printf("Recieve Data From Server %s Failed!\n", argv[1]);  
    
91.             break;  
    
92.         }  
    ; f- l" b2 y6 v# B
93. 
    6 ]7 P. ?( l9 J* K% {3 |
94.         int write_length = fwrite(buffer, sizeof(char), length, fp);  
    
95.         if (write_length < length)  
    5 L" s1 G* ^, M/ q+ a( a2 b9 {
96.         {  
    " U! i* F; K- N: l" w
97.             printf("File:\t%s Write Failed!\n", file_name);  
    # h8 K; D# {. q) v7 Q
98.             break;  
    9 b. d7 N& ?% ]. y" S
99.         }  
    
100.         bzero(buffer, BUFFER_SIZE);  
     
101.     }  
     
102. 
     ( D$ q7 }' c. |/ s
103.     printf("Recieve File:\t %s From Server[%s] Finished!\n", file_name, argv[1]);  
     
104. 
     
105.     // 传输完毕，关闭socket   
     
106.     fclose(fp);  
     1 q$ ~; @0 a1 I+ U, ]& s0 c+ L% ]
107.     close(client_socket);  
     ( [4 V0 I. P& x# |* g  U
108.     return 0;  
     2 v4 @; w" k# m8 d) S
109. 
     
110. }  
     5 ]1 x# L1 [  {5 r6 n" j
111. 
     2 n" G  I2 G6 [7 p

复制代码

1. /*server.c*/
   
2. #include<netinet/in.h>
   . K: }8 T; Q: j2 `% _% v1 G' A' v
3. #include<sys/types.h>
   
4. #include<sys/socket.h>
   & L7 d5 k' n3 v! F0 B$ T
5. #include<stdio.h>
   * Z1 d2 [8 y1 o7 ]/ r" x# V
6. #include<stdlib.h>
   
7. #include<string.h>
   
8. 
   , z9 Z7 r- ]" g+ F' h! {1 @1 d. K
9. #define HELLO_WORLD_SERVER_PORT    6666         //端口号
   / y# ^5 m/ n6 V, ]8 q. x
10. #define LENGTH_OF_LISTEN_QUEUE     20
    
11. #define BUFFER_SIZE                1024
    
12. #define FILE_NAME_MAX_SIZE         512
    
13. 
    3 v6 ^9 t2 Q& U! s
14. int main(int argc, char **argv)
    3 Y2 d1 M( T6 O0 q- W
15. {
    4 h& E( ^8 u+ D( n0 b( u% `
16.     // set socket's address information
    $ l: z5 K. S8 U, G5 B% }
17.     // 设置一个socket地址结构server_addr,代表服务器internet的地址和端口
    
18.     struct sockaddr_in   server_addr;
    4 L# k! c; _8 o  ^9 Y8 O
19.     bzero(&server_addr, sizeof(server_addr));
    
20.     server_addr.sin_family = AF_INET;
    / U/ i4 d* R$ j. ^/ f: Q! I
21.     server_addr.sin_addr.s_addr = htons(INADDR_ANY);
    & @: x: ~* L* i# ~6 ]7 m  y3 Y1 r7 g
22.     server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);
    # F0 P2 g- Q2 E- M, ~
23. 
    9 P$ q" Z! Y/ r+ t9 @' F9 b
24.     // create a stream socket
    
25.     // 创建用于internet的流协议(TCP)socket，用server_socket代表服务器向客户端提供服务的接口
    
26.     int server_socket = socket(PF_INET, SOCK_STREAM, 0);
    
27.     if (server_socket < 0)
    $ n5 [8 ~$ p0 h( i" W" x
28.     {
    
29.         printf("Create Socket Failed!\n");
    
30.         exit(1);
    , B) c# M1 T* U0 \" N0 [* C
31.     }
    
32. 
    9 R' N& g5 v$ A: W& M* W3 P
33.     // 把socket和socket地址结构绑定
    " d+ F. Q- I# D1 O, @
34.     if (bind(server_socket, (struct sockaddr*)&server_addr, sizeof(server_addr)))
    
35.     {
    ; x' N" P; `/ i$ ~3 o) A1 p
36.         printf("Server Bind Port: %d Failed!\n", HELLO_WORLD_SERVER_PORT);
    
37.         exit(1);
    / }% a0 k' y# U0 C) c$ m
38.     }
    ' o8 `( Z0 L2 I5 M3 c3 \5 {- }
39. 
    - l$ k9 B/ U( o& J4 V7 v
40.     // server_socket用于监听
    - j; Z& C% K; u6 [
41.     if (listen(server_socket, LENGTH_OF_LISTEN_QUEUE))
    ; Y( Y# R  ]: \' ~
42.     {
    " G! L& [! O1 _4 u* ~* j
43.         printf("Server Listen Failed!\n");
    " \8 w- B8 C8 w8 Z
44.         exit(1);
    
45.     }
    7 a! i8 d; q$ u8 W4 u( l
46. 
    
47.     // 服务器端一直运行用以持续为客户端提供服务
    
48.     while(1)
    , p$ E7 o+ G: n# ]& z* R
49.     {
    
50.         // 定义客户端的socket地址结构client_addr，当收到来自客户端的请求后，调用accept
    + o) s$ k! O4 R, U2 m7 q
51.         // 接受此请求，同时将client端的地址和端口等信息写入client_addr中
    8 o/ j0 q0 Z$ q
52.         struct sockaddr_in client_addr;
    9 o5 T% J/ }$ }4 l  d' v4 g
53.         socklen_t          length = sizeof(client_addr);
    0 i2 [( y% U5 D0 I
54. 
    
55.         // 接受一个从client端到达server端的连接请求,将客户端的信息保存在client_addr中
    ) i7 |& V" A3 t( T! N; w
56.         // 如果没有连接请求，则一直等待直到有连接请求为止，这是accept函数的特性，可以
    
57.         // 用select()来实现超时检测
    1 j: P) _  p- f" |- R
58.         // accpet返回一个新的socket,这个socket用来与此次连接到server的client进行通信
    
59.         // 这里的new_server_socket代表了这个通信通道
    
60.         int new_server_socket = accept(server_socket, (struct sockaddr*)&client_addr, &length);
      A  R/ W, N3 R
61.         if (new_server_socket < 0)
    * U  |! g, Q' F2 e: Q$ Y7 R8 y
62.         {
    3 v# k# m7 n  V6 G
63.             printf("Server Accept Failed!\n");
      k8 d/ V7 K: H
64.             break;
    
65.         }
    
66. 
    
67.         char buffer[BUFFER_SIZE];
    8 z9 O3 b$ T5 I& I
68.         bzero(buffer, sizeof(buffer));
    2 {3 ?& ~0 ?, i# w8 s: {
69.         length = recv(new_server_socket, buffer, BUFFER_SIZE, 0);
    
70.         if (length < 0)
    ) |. R8 w$ s$ c' k  x
71.         {
    
72.             printf("Server Recieve Data Failed!\n");
    6 X  N% Z& N# p4 E2 W% }/ c1 A
73.             break;
    
74.         }
    
75. 
    
76.         char file_name[FILE_NAME_MAX_SIZE + 1];
    / L. n4 V4 A* G$ C  [
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));
    
80. 
    " H' ?) S. q6 s& \! N
81.         FILE *fp = fopen(file_name, "r");
      r4 m& [/ P8 |5 c. q9 @# t  p
82.         if (fp == NULL)
    * d9 p6 o3 c: A: d
83.         {
    
84.             printf("File:\t%s Not Found!\n", file_name);
    
85.         }
    5 Z6 \- ~6 s: n
86.         else
    , I& Z* [/ c4 h+ |3 Q+ t
87.         {
    9 [/ j8 p6 P& N$ O3 ?# c! M8 l$ @
88.             bzero(buffer, BUFFER_SIZE);
    
89.             int file_block_length = 0;
    
90.             while( (file_block_length = fread(buffer, sizeof(char), BUFFER_SIZE, fp)) > 0)
    / J9 n5 p$ T* M. I0 u2 t9 \; b
91.             {
    
92.                 printf("file_block_length = %d\n", file_block_length);
    # p+ S4 s6 R) J8 Q
93. 
      e4 H5 e7 N! N; |; H: |1 A. m; l
94.                 // 发送buffer中的字符串到new_server_socket,实际上就是发送给客户端
    ' ?2 ~# m( |' z7 m7 G8 H1 Y2 A
95.                 if (send(new_server_socket, buffer, file_block_length, 0) < 0)
    
96.                 {
    ! T0 `& D& q# Z, A) y
97.                     printf("Send File:\t%s Failed!\n", file_name);
    
98.                     break;
    / x; v4 C5 T3 x( J" P; V
99.                 }
    4 Y- H. v9 T7 p# p# Y( n
100. 
     ' a& I2 L' i# [6 N" O/ C- _
101.                 bzero(buffer, sizeof(buffer));
     # g& E: K& {, u' S
102.             }
     
103.             fclose(fp);
     
104.             printf("File:\t%s Transfer Finished!\n", file_name);
     , i; i3 F- ?- L3 `- Z9 p! X! G( j
105.         }
     
106. 
     & k6 D! W6 _2 P( h& \. ]1 T
107.         close(new_server_socket);
     8 i( E; _& x* M& b; M& T0 `
108.     }
     
109. 
     
110.     close(server_socket);
     : G; L3 Q% J9 T# x5 K
111. 
     ' X. }1 e4 b4 G3 t0 A' h7 `- u3 k3 L
112.     return 0;
     
113. }
     
114. 
     

复制代码

7 n' x  O) d9 @# ?- y, {# u) m
1 d8 _" \4 l6 K6 G
1 w) b7 @' `( _- N