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

admin

本文给出一个很实用的服务端和客户端进行TCP通信的小例子。具体实现上非常简单，只是平时编写类似程序，具体步骤经常忘记，还要总是查，暂且将其记下来，方便以后参考。
. X' }5 t$ V8 N* y- @（1）客户端程序，编写一个文件client.c，内容如下：
+ Y2 e# k+ P5 R6 O! Z

1. #include <stdlib.h>
   
2. #include <stdio.h>
     N  X( ~9 b3 D3 Q8 S* S
3. #include <unistd.h>
   2 v( C! [! P0 H* N/ J4 [
4. #include <string.h>
   . A2 x7 p; r9 \$ B
5. #include <sys/types.h>
   # |  @3 _& g9 Q
6. #include <sys/socket.h>
   - Z6 p; q9 D3 @' E4 d
7. #include <netinet/in.h>
   
8. #include <netdb.h>  /* netdb is necessary for struct hostent */
   8 b8 ?5 t3 Z0 ?; r3 Z& [- R$ P! @9 g
9. 
   
10. #define PORT 4321   /* server port */
    . l9 {) `& `% n# w. [. ~
11. 
    0 G7 T1 a' ]' l' z* r
12. #define MAXDATASIZE 100
    3 q- `+ A7 a! l) z( A) b
13. 
    
14. int main(int argc, char *argv[])
    
15. {
    
16.     int sockfd, num;    /* files descriptors */
    
17.     char buf[MAXDATASIZE];    /* buf will store received text */
    ; N4 }( {3 I, a. Y
18.     struct hostent *he;    /* structure that will get information about remote host */
    7 Z9 c+ T6 ?1 W2 |2 F
19.     struct sockaddr_in server;
    
20.    
    
21.     if (argc != 2)
    % u5 m) g1 L1 f" y1 C$ ~
22.     {
    & b5 t1 ^# i6 e0 m9 e
23.         printf("Usage: %s <IP Address>\n",argv[0]);
    # r& _  `* J) `9 U
24.         exit(1);
    8 j' a4 N  e8 H
25.     }
    
26.    
    
27.     if((he=gethostbyname(argv[1]))==NULL)
    
28.     {
    
29.         printf("gethostbyname() error\n");
    , r2 a, e; `0 L( P
30.         exit(1);
    
31.     }
    
32.    
    
33.     if((sockfd=socket(AF_INET,SOCK_STREAM, 0))==-1)
    7 o* a" o; e6 {# v# k4 d
34.     {
    
35.         printf("socket() error\n");
    ) L% f3 _1 w' P( d1 Z
36.         exit(1);
    2 |/ _9 }1 y( @1 V
37.     }
    $ c$ Z! X. ~9 B
38.     bzero(&server,sizeof(server));
    
39.     server.sin_family = AF_INET;
    
40.     server.sin_port = htons(PORT);
    $ T- C- K) J6 [
41.     server.sin_addr = *((struct in_addr *)he->h_addr);
    9 A& d3 |1 z' a- r5 Y* k
42.     if(connect(sockfd, (struct sockaddr *)&server, sizeof(server))==-1)
    
43.     {
    
44.         printf("connect() error\n");
    
45.         exit(1);
    % o6 v" x8 a4 H% q4 m2 {$ [" ~
46.     }
    
47. 　　
    : e+ [1 e+ j& X: A
48. 　　char str[] = "horst\n"
    
49. 
    
50.     if((num=send(sockfd,str,sizeof(str),0))==-1){
    ( V8 z- i4 v  W4 p2 i  `
51.         printf("send() error\n");
    1 ?1 [) p+ z" i% M7 i# R* u+ j
52.         exit(1);
    ) h! r) v  Q: w/ [# K' i& O. }
53.     }
    7 o, A: a4 I+ _4 _1 p7 h" y6 F$ t
54.     if((num=recv(sockfd,buf,MAXDATASIZE,0))==-1)
    
55.     {
    
56.         printf("recv() error\n");
    8 j9 c# e; P* e$ h6 ]
57.         exit(1);
    / Z, _+ j5 n6 P- y3 G0 a" l) n
58.     }
    
59.     buf[num-1]='\0';
    0 t  N% N9 s: V, P" o% N' p+ v
60.     printf("server message: %s\n",buf);
    
61.     close(sockfd);
    1 s: W% ]5 w3 S; U
62.     return 0;
    
63. }

复制代码

（2）服务器端，编写server.c，内容如下
7 x$ \4 j, E* F2 ~' [

1. #include <sys/time.h>
   
2. #include <stdlib.h>
   
3. #include <stdio.h>
   
4. #include <string.h>
   
5. #include <unistd.h>
   4 R" a6 j# w: t# |& C# R9 _! K. E8 T
6. #include <sys/types.h>
   
7. #include <sys/socket.h>
   % y: F) Y" b% Q. K  u* S3 ?
8. #include <netinet/in.h>
   
9. #include <arpa/inet.h>
     R0 a9 B- N. d6 Q- T
10. 
    
11. #define PORT 4321
    9 `) e0 @+ {; Z* \
12. 
    . h4 W2 I( l  M
13. #define BACKLOG 1
    
14. #define MAXRECVLEN 1024
    
15. 
    ! K3 b+ j6 X+ v8 x) F
16. int main(int argc, char *argv[])
    
17. {
    & X5 `  d# f( u
18.     char buf[MAXRECVLEN];
    9 Y# N8 W. x: w: ~. ^& v
19.     int listenfd, connectfd;   /* socket descriptors */
    
20.     struct sockaddr_in server; /* server's address information */
    - e+ |8 j8 [, o& w7 N% u
21.     struct sockaddr_in client; /* client's address information */
    
22.     socklen_t addrlen;
    6 J5 \% V9 e$ R9 P! P# ?
23.     /* Create TCP socket */
    
24.     if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    
25.     {
    : q4 V5 o7 H2 w8 \  C2 I
26.         /* handle exception */
    
27.         perror("socket() error. Failed to initiate a socket");
    
28.         exit(1);
    8 e, t% m5 ]' @2 H$ C( u) ?2 |
29.     }
    7 ]2 n5 [1 ^" f/ U! Y
30. 
    
31.     /* set socket option */
      u, X2 C6 m+ `6 E6 H( c
32.     int opt = SO_REUSEADDR;
    6 S4 @, t. S# m3 {3 Y
33.     setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
    , F: V/ O) b. }
34. 
    
35.     bzero(&server, sizeof(server));
    . l# q, i! Y$ Q9 \  G3 I& @
36. 
    
37.     server.sin_family = AF_INET;
    % A& ?8 a' D: Y8 Y( x- l
38.     server.sin_port = htons(PORT);
    ) q. h4 P; d9 i. K7 k
39.     server.sin_addr.s_addr = htonl(INADDR_ANY);
    
40.     if(bind(listenfd, (struct sockaddr *)&server, sizeof(server)) == -1)
    
41.     {
    
42.         /* handle exception */
    ; p) n' S5 L, {3 u) T$ R5 z* M- V
43.         perror("Bind() error.");
    * U4 p) l/ h: Y9 l1 N+ @& t
44.         exit(1);
    
45.     }
    4 v) E8 _5 t1 i' E6 T& g
46.    
    
47.     if(listen(listenfd, BACKLOG) == -1)
    
48.     {
    2 I. @8 r1 ~, l7 @
49.         perror("listen() error. \n");
    
50.         exit(1);
    ! O0 _/ @- U  u' g
51.     }
    
52. 
    9 `( Y8 {+ B7 b4 ?* v
53.     addrlen = sizeof(client);
    
54.     while(1){
    5 K0 G, h+ x( @" q
55.         if((connectfd=accept(listenfd,(struct sockaddr *)&client, &addrlen))==-1)
    6 L8 F7 z1 `1 l2 D8 ]
56.            {
    
57.             perror("accept() error. \n");
    , K5 {2 `% W9 r$ \* ]$ S
58.             exit(1);
    
59.            }
    9 S9 P* R- X  p0 ?0 q
60. 
    
61.         struct timeval tv;
    
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);
    
64.         
    
65.         int iret=-1;
    ) a0 D- Q% Q$ I" [9 e8 ]
66.         while(1)
    4 D4 u2 ]  t5 N3 D9 J; h1 u1 f! K
67.         {
    $ n2 F" c1 {  S" I9 C+ z, O
68.             iret = recv(connectfd, buf, MAXRECVLEN, 0);
    3 H& Z. A& U; Y7 `5 W1 R
69.             if(iret>0)
    ) Q5 l2 c# R% o6 n& l) P: l
70.             {
    0 d! V: G- E/ _" _
71.                 printf("%s\n", buf);
    
72.             }else
    
73.             {
    
74.                 close(connectfd);
    
75.                 break;
    
76.             }
    
77.             /* print client's ip and port */
    
78.             send(connectfd, buf, iret, 0); /* send to the client welcome message */
    7 b6 W2 `1 W/ x8 F4 R. P
79.         }
    3 ]' |% o1 |  E
80.     }
    / |/ }* W/ D/ s) W- v* N$ d
81.     close(listenfd); /* close listenfd */
    # R# N* ^" p  q" B' ^
82.     return 0;
    
83. }

复制代码

! R8 J; D  `% Y# r0 d3 ~* O% ?

（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
   
2. 
   
3. server message:horst

复制代码

服务器端：

1. $./server
   & w2 T1 g% U" b/ s" ]  M$ g; T$ M% V
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端口等待下一次连接。

' R$ h/ C( E# m/ V/ ^* T' E

# n* `' s/ V9 Y
0 f+ V* @# s3 t$ ?

admin

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

1. /*client.c*/
   # y* W# k5 o% f$ K
2. #include<netinet/in.h>                         // for sockaddr_in  
   
3. #include<sys/types.h>                          // for socket  
   
4. #include<sys/socket.h>                         // for socket  
   
5. #include<stdio.h>                              // for printf  
   " _5 F3 C" A( W* m1 u! E
6. #include<stdlib.h>                             // for exit  
   . A4 \1 g" E. Q! x& I
7. #include<string.h>                             // for bzero  
   8 i& l" t. i- a- I# T9 }) k$ K
8. 
   2 c6 P4 x, J# x% V# W
9. #define HELLO_WORLD_SERVER_PORT       6666  
   . A$ x( I) @/ t/ T/ r- ?$ Q& w
10. #define BUFFER_SIZE                   1024  
    
11. #define FILE_NAME_MAX_SIZE            512  
      Y. j- A# z- V! x5 _# N
12. 
    
13. int main(int argc, char **argv)  
    
14. {  
    
15.     if (argc != 2)  
    : t. ^& q1 J9 k0 r
16.     {  
    ! D+ q& j" w6 j
17.         printf("Usage: ./%s ServerIPAddress\n", argv[0]);  
    * H' z8 v7 h" k3 u, F& Y
18.         exit(1);  
    
19.     }  
    3 y. |4 c2 ^% j. G2 M. B' k# i( |2 B5 o
20. 
    
21.     // 设置一个socket地址结构client_addr, 代表客户机的internet地址和端口  
    9 [5 O' F- A' u6 O. ~' C4 l" _; S
22.     struct sockaddr_in client_addr;  
    
23.     bzero(&client_addr, sizeof(client_addr));  
    
24.     client_addr.sin_family = AF_INET; // internet协议族  
    5 n$ ?/ b2 `" l3 d( w0 u
25.     client_addr.sin_addr.s_addr = htons(INADDR_ANY); // INADDR_ANY表示自动获取本机地址  
    
26.     client_addr.sin_port = htons(0); // auto allocated, 让系统自动分配一个空闲端口  
    
27. 
    $ ?. p# H; p) F2 Y$ L3 r2 A0 r2 t
28.     // 创建用于internet的流协议(TCP)类型socket，用client_socket代表客户端socket  
    
29.     int client_socket = socket(AF_INET, SOCK_STREAM, 0);  
    
30.     if (client_socket < 0)  
    
31.     {  
    
32.         printf("Create Socket Failed!\n");  
    , B8 A. @/ ^% a6 r
33.         exit(1);  
    : F3 L/ A3 i6 ]# E1 k
34.     }  
    2 x% L8 C* _) z! ]) `. M; @/ F
35. 
    
36.     // 把客户端的socket和客户端的socket地址结构绑定   
    
37.     if (bind(client_socket, (struct sockaddr*)&client_addr, sizeof(client_addr)))  
    5 `- K4 {* ]4 A" P8 s6 f& L
38.     {  
    & B) J) B& A3 s
39.         printf("Client Bind Port Failed!\n");  
    / k- z7 Y2 K1 b9 b6 y: T  W* [
40.         exit(1);  
    
41.     }  
    2 G  D7 k+ V. o' u
42. 
    + B" r( ?5 A9 l' r% _& E
43.     // 设置一个socket地址结构server_addr,代表服务器的internet地址和端口  
    8 X1 s5 `% l% K* R
44.     struct sockaddr_in  server_addr;  
    
45.     bzero(&server_addr, sizeof(server_addr));  
    4 O$ C& _: K# Q" L* W# H. _+ h+ k
46.     server_addr.sin_family = AF_INET;  
    ! h5 w8 U+ B- p
47. 
    0 P7 T7 @6 T6 [+ ^  _( F
48.     // 服务器的IP地址来自程序的参数   
    
49.     if (inet_aton(argv[1], &server_addr.sin_addr) == 0)  
    
50.     {  
    
51.         printf("Server IP Address Error!\n");  
    0 r( c. ~* V' E& a8 O5 Q# J, I+ p
52.         exit(1);  
    
53.     }  
    
54. 
      b- W# K! r$ T# s. `* H4 j  W7 [
55.     server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);  
    ) C4 f" a  \; @  [$ f
56.     socklen_t server_addr_length = sizeof(server_addr);  
    
57. 
    
58.     // 向服务器发起连接请求，连接成功后client_socket代表客户端和服务器端的一个socket连接  
    
59.     if (connect(client_socket, (struct sockaddr*)&server_addr, server_addr_length) < 0)  
    $ e  }4 B  e, j
60.     {  
    
61.         printf("Can Not Connect To %s!\n", argv[1]);  
    5 o& \2 ~" S' j5 Y: U
62.         exit(1);  
    
63.     }  
    - E0 ~8 U) l" D% j/ J( e
64. 
    
65.     char file_name[FILE_NAME_MAX_SIZE + 1];  
    ' W" @' o+ {+ J# H9 A
66.     bzero(file_name, sizeof(file_name));  
    / H. B' t; Q3 r# Q, ^$ G* Q5 S( B
67.     printf("Please Input File Name On Server.\t");  
      i2 D5 ?; `( a- o6 Q# l$ F
68.     scanf("%s", file_name);  
    ' ~3 q8 G, ^: c9 \( ?7 e/ r) Q
69. 
    ) S8 A! O* t/ A
70.     char buffer[BUFFER_SIZE];  
    
71.     bzero(buffer, sizeof(buffer));  
    # @. b: G7 {6 b! z, I% S: C" B
72.     strncpy(buffer, file_name, strlen(file_name) > BUFFER_SIZE ? BUFFER_SIZE : strlen(file_name));  
    & ^% X- U1 a$ j$ Z5 T
73.     // 向服务器发送buffer中的数据，此时buffer中存放的是客户端需要接收的文件的名字  
    ; S3 \. H: C" N. \
74.     send(client_socket, buffer, BUFFER_SIZE, 0);  
    
75. 
    
76.     FILE *fp = fopen(file_name, "w");  
    / l& E& Z* S  @, E% c
77.     if (fp == NULL)  
    
78.     {  
    # @; y, q$ z8 H. }+ s
79.         printf("File:\t%s Can Not Open To Write!\n", file_name);  
    7 m+ Q" Z( {( ~* Y! W
80.         exit(1);  
    
81.     }  
    
82. 
    
83.     // 从服务器端接收数据到buffer中   
    
84.     bzero(buffer, sizeof(buffer));  
    9 ]8 z7 c5 Q- v  l  ~+ |$ t
85.     int length = 0;  
    ) [  J3 [/ H$ p, l/ d
86.     while(length = recv(client_socket, buffer, BUFFER_SIZE, 0))  
    
87.     {  
    
88.         if (length < 0)  
    % {* ~9 j( f+ c9 z' y& y
89.         {  
    1 H9 f# y) ]+ l, u5 P
90.             printf("Recieve Data From Server %s Failed!\n", argv[1]);  
    2 c6 X2 p: k5 K- \
91.             break;  
    . ^8 y2 Y8 {+ o# H# E& C' X
92.         }  
    
93. 
    
94.         int write_length = fwrite(buffer, sizeof(char), length, fp);  
    ( w- g% s/ n, t4 Y) [; z
95.         if (write_length < length)  
    , e* i3 X* {- |7 z- p0 N
96.         {  
    9 k, V" k* J6 I. n0 a0 p$ V
97.             printf("File:\t%s Write Failed!\n", file_name);  
    * e5 }+ q) \5 ~; c  H
98.             break;  
    1 M# m  n: j' B6 `  }! }7 m
99.         }  
    ( e& a3 N3 a9 |( m, s
100.         bzero(buffer, BUFFER_SIZE);  
     
101.     }  
     * \1 b" @, Q2 T) v4 ?  q% t/ Y
102. 
     % z3 d: [7 v+ |$ [$ h
103.     printf("Recieve File:\t %s From Server[%s] Finished!\n", file_name, argv[1]);  
     
104. 
     3 q. h" q# ^8 y; P% e! H  g: t
105.     // 传输完毕，关闭socket   
     ; J7 }* s5 v. d; K
106.     fclose(fp);  
     
107.     close(client_socket);  
     
108.     return 0;  
     
109. 
     
110. }  
     
111. 
     

复制代码

1. /*server.c*/
   
2. #include<netinet/in.h>
   , e& C' H. p% E7 r6 g
3. #include<sys/types.h>
   
4. #include<sys/socket.h>
   
5. #include<stdio.h>
   
6. #include<stdlib.h>
   ! A4 [2 h, V5 r% W: r# X) a. \4 b
7. #include<string.h>
   
8. 
   
9. #define HELLO_WORLD_SERVER_PORT    6666         //端口号
   ; F3 l7 s, C' k. u4 o
10. #define LENGTH_OF_LISTEN_QUEUE     20
    / U7 l5 Y& z6 W$ }
11. #define BUFFER_SIZE                1024
    3 K# U) i" V! }7 v& o# x
12. #define FILE_NAME_MAX_SIZE         512
    
13. 
    3 X& `5 k6 g0 U: E8 t9 ~
14. int main(int argc, char **argv)
    8 b0 [! ~" s& B- B$ o
15. {
    
16.     // set socket's address information
    7 _: O9 w- G& D  \# ~$ j& @2 [
17.     // 设置一个socket地址结构server_addr,代表服务器internet的地址和端口
    / f1 V2 ]# S! s) |( f
18.     struct sockaddr_in   server_addr;
    
19.     bzero(&server_addr, sizeof(server_addr));
    
20.     server_addr.sin_family = AF_INET;
    ' R' v/ j$ G# C* p# h; g
21.     server_addr.sin_addr.s_addr = htons(INADDR_ANY);
    
22.     server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);
    
23. 
    
24.     // create a stream socket
    " J0 Q) C1 M# t- \- `- g9 H
25.     // 创建用于internet的流协议(TCP)socket，用server_socket代表服务器向客户端提供服务的接口
    
26.     int server_socket = socket(PF_INET, SOCK_STREAM, 0);
    # k. K) N3 d3 U) p  {& l$ C
27.     if (server_socket < 0)
    
28.     {
    8 ]% Z3 @7 _8 k" r
29.         printf("Create Socket Failed!\n");
    6 n6 q% E& A( \! A
30.         exit(1);
    ) m! A6 f, {( t, o5 I
31.     }
    1 s" U9 {. b* R$ ]: @+ v
32. 
    . t7 m; x8 ^+ L. i3 Y7 v
33.     // 把socket和socket地址结构绑定
    7 |( }$ v# j; U) h/ G" `1 n
34.     if (bind(server_socket, (struct sockaddr*)&server_addr, sizeof(server_addr)))
    
35.     {
    0 G% v: p" `. q3 a' {% o
36.         printf("Server Bind Port: %d Failed!\n", HELLO_WORLD_SERVER_PORT);
    + [- n% j5 Q, Z! ~
37.         exit(1);
    
38.     }
    * B, |2 h$ }% ~3 K9 Z$ Y) C
39. 
    
40.     // server_socket用于监听
    / v3 ]8 a' G2 Z: p$ H4 c4 g
41.     if (listen(server_socket, LENGTH_OF_LISTEN_QUEUE))
    ; Y; [! k5 e* |
42.     {
    ( l# f  o7 ~/ w3 s
43.         printf("Server Listen Failed!\n");
    
44.         exit(1);
    
45.     }
    
46. 
    ! }  E9 A& w  p0 U
47.     // 服务器端一直运行用以持续为客户端提供服务
    ' }0 o; u3 f7 P* t8 o
48.     while(1)
    5 K7 Q  W1 \0 W* E6 Q
49.     {
    
50.         // 定义客户端的socket地址结构client_addr，当收到来自客户端的请求后，调用accept
    
51.         // 接受此请求，同时将client端的地址和端口等信息写入client_addr中
    % i6 g% m; _0 j; m, M
52.         struct sockaddr_in client_addr;
    
53.         socklen_t          length = sizeof(client_addr);
    
54. 
    
55.         // 接受一个从client端到达server端的连接请求,将客户端的信息保存在client_addr中
    
56.         // 如果没有连接请求，则一直等待直到有连接请求为止，这是accept函数的特性，可以
    
57.         // 用select()来实现超时检测
    
58.         // accpet返回一个新的socket,这个socket用来与此次连接到server的client进行通信
    
59.         // 这里的new_server_socket代表了这个通信通道
    
60.         int new_server_socket = accept(server_socket, (struct sockaddr*)&client_addr, &length);
    4 U$ G1 d$ R9 F! N6 ?/ H
61.         if (new_server_socket < 0)
    
62.         {
    . L) P% {1 G  ?) M) F$ k# P
63.             printf("Server Accept Failed!\n");
    
64.             break;
    
65.         }
    0 |8 |- U$ ^* y$ O2 u* T  z* Q2 Z
66. 
    ( [: ?4 i. j; Y8 R* `0 p  O
67.         char buffer[BUFFER_SIZE];
    
68.         bzero(buffer, sizeof(buffer));
    
69.         length = recv(new_server_socket, buffer, BUFFER_SIZE, 0);
    0 N8 t' T% j9 L8 j$ S+ z4 W
70.         if (length < 0)
    ! i1 \/ j8 Y9 L4 n5 o( ?& {, `# U
71.         {
    
72.             printf("Server Recieve Data Failed!\n");
    7 R7 |% u+ y9 r' a# H% Z- q) H
73.             break;
    
74.         }
    1 ?% ~, o0 r; c5 ^0 {" ^7 z, X  {
75. 
    ( M, y2 _6 a7 x* Z; T
76.         char file_name[FILE_NAME_MAX_SIZE + 1];
    8 _% f/ J0 O& J, y4 f5 q
77.         bzero(file_name, sizeof(file_name));
    & ~/ w8 J0 w5 j1 a4 p( E
78.         strncpy(file_name, buffer,
    9 p! `" X& H: W; c
79.                 strlen(buffer) > FILE_NAME_MAX_SIZE ? FILE_NAME_MAX_SIZE : strlen(buffer));
    
80. 
    + a" M  @; o# @9 o0 S/ P
81.         FILE *fp = fopen(file_name, "r");
    
82.         if (fp == NULL)
    3 z2 q0 }4 S' O) {0 R2 o9 w
83.         {
    + o6 D3 P! B9 ]& u2 Z; h( n
84.             printf("File:\t%s Not Found!\n", file_name);
    
85.         }
    
86.         else
    * m+ F& k2 m, @& t% X  T; n! W8 P
87.         {
    
88.             bzero(buffer, BUFFER_SIZE);
    
89.             int file_block_length = 0;
    
90.             while( (file_block_length = fread(buffer, sizeof(char), BUFFER_SIZE, fp)) > 0)
    . l: M* x4 W, \5 J: d: k' t
91.             {
    6 B+ ?% R" C) T% ?
92.                 printf("file_block_length = %d\n", file_block_length);
    $ T5 G$ z' H5 R' W7 M" S+ R- {; y
93. 
    ! M& H$ }6 J6 V7 c
94.                 // 发送buffer中的字符串到new_server_socket,实际上就是发送给客户端
    
95.                 if (send(new_server_socket, buffer, file_block_length, 0) < 0)
    
96.                 {
    
97.                     printf("Send File:\t%s Failed!\n", file_name);
    . p  R: h( M4 p, `: D' i
98.                     break;
    $ `0 R( Q2 ^6 h5 l
99.                 }
    
100. 
     : g. x: \% P8 D& {" k3 S( W0 T% r
101.                 bzero(buffer, sizeof(buffer));
     
102.             }
     ! {& j: q) j; m! V
103.             fclose(fp);
     
104.             printf("File:\t%s Transfer Finished!\n", file_name);
     8 L6 b+ N' V/ E  W0 ]# f$ G
105.         }
     $ ~' p" Q2 @9 J" f
106. 
     " R  o& R+ G& V- X/ i
107.         close(new_server_socket);
     : J" H; I) Z: Z4 o+ C: }$ m
108.     }
     
109. 
     
110.     close(server_socket);
     . H$ M. H$ C. Q" w. z
111. 
     
112.     return 0;
     
113. }
     ; c7 m) `4 ], x. s/ N% y
114. 
     

复制代码

4 j: U9 q3 v) e% N, D2 D" L