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

admin

本文给出一个很实用的服务端和客户端进行TCP通信的小例子。具体实现上非常简单，只是平时编写类似程序，具体步骤经常忘记，还要总是查，暂且将其记下来，方便以后参考。
7 g% {2 l/ [. _" M5 I1 }, ~# R（1）客户端程序，编写一个文件client.c，内容如下：
9 ?* K2 L+ P, ^5 o

1. #include <stdlib.h>
   
2. #include <stdio.h>
   
3. #include <unistd.h>
   
4. #include <string.h>
   
5. #include <sys/types.h>
   
6. #include <sys/socket.h>
   
7. #include <netinet/in.h>
   7 q0 r$ v# H3 o! }& E
8. #include <netdb.h>  /* netdb is necessary for struct hostent */
   
9. 
   
10. #define PORT 4321   /* server port */
    
11. 
    3 k+ o1 t& l: ^! a
12. #define MAXDATASIZE 100
    6 z9 Z2 t" F; X2 w8 O* t
13. 
    
14. int main(int argc, char *argv[])
    # i  G; O2 |- ^! O1 K
15. {
    
16.     int sockfd, num;    /* files descriptors */
    - a; N( f* b; D" @$ @1 R, S
17.     char buf[MAXDATASIZE];    /* buf will store received text */
    % |' v9 O7 D- D* Q& _9 K# W
18.     struct hostent *he;    /* structure that will get information about remote host */
    * k2 H$ w, u8 Z9 i2 P) h
19.     struct sockaddr_in server;
    , F" f* G9 Q7 M2 w9 z( g$ H( r+ p
20.    
    ' U/ ]2 h4 M$ K
21.     if (argc != 2)
    
22.     {
    % K9 W' r5 c) s
23.         printf("Usage: %s <IP Address>\n",argv[0]);
    5 O  {$ k( w8 A
24.         exit(1);
    
25.     }
    ! P% `! @) _* ~" L
26.    
    6 J, p4 U# h) V& ^$ @  L' t  X
27.     if((he=gethostbyname(argv[1]))==NULL)
    ! z( F2 Q* D$ p0 q
28.     {
    
29.         printf("gethostbyname() error\n");
    
30.         exit(1);
    ) ?5 c$ @- F: \- e0 y/ ?6 _
31.     }
    4 L2 T/ T/ B0 _0 h
32.    
    
33.     if((sockfd=socket(AF_INET,SOCK_STREAM, 0))==-1)
    0 p+ @: Q" h  s$ m9 A; w
34.     {
    : Y2 m( g1 ~- G
35.         printf("socket() error\n");
    
36.         exit(1);
    
37.     }
      ~1 @  Z, |# ~2 a7 A1 @; ?
38.     bzero(&server,sizeof(server));
    / D  e7 I3 |3 l) o
39.     server.sin_family = AF_INET;
    : f5 J$ [% h* V+ c4 ^8 v, }4 J" A
40.     server.sin_port = htons(PORT);
    
41.     server.sin_addr = *((struct in_addr *)he->h_addr);
    ) m: q+ @+ |5 c5 a7 s% t* B# f
42.     if(connect(sockfd, (struct sockaddr *)&server, sizeof(server))==-1)
    
43.     {
    2 e& U$ K; S" G, Y6 i
44.         printf("connect() error\n");
    
45.         exit(1);
    " H' {2 v3 p. U9 u4 y
46.     }
    
47. 　　
    % R0 b  ], O' q/ v* M) N+ D
48. 　　char str[] = "horst\n"
    
49. 
    % x/ ]; `: v# ?
50.     if((num=send(sockfd,str,sizeof(str),0))==-1){
    
51.         printf("send() error\n");
    : I+ B) O0 b7 T* s7 o9 p; B
52.         exit(1);
    ! D! W. l2 o5 y/ m; z& T
53.     }
    0 Y/ P9 I% Z( T
54.     if((num=recv(sockfd,buf,MAXDATASIZE,0))==-1)
    ) _) b2 O8 C$ k' m- ~' Z% g7 X: e8 {3 {
55.     {
    & Z" s! Z: t) f9 b3 Z( e' ?; N6 l
56.         printf("recv() error\n");
    
57.         exit(1);
    
58.     }
    5 K6 i" k9 M6 z/ C
59.     buf[num-1]='\0';
    
60.     printf("server message: %s\n",buf);
    % M6 d# z9 C0 x% u# w
61.     close(sockfd);
    ) t2 D; y4 i3 _+ C
62.     return 0;
    
63. }

复制代码

（2）服务器端，编写server.c，内容如下
% S  l/ C) ?* n

1. #include <sys/time.h>
   ' L% k* H( |+ j& L7 n
2. #include <stdlib.h>
   
3. #include <stdio.h>
   
4. #include <string.h>
   # T' [; a1 ~3 Y# }0 H
5. #include <unistd.h>
   ) t9 |$ F" Y1 Y: t8 W8 G3 y# b8 {
6. #include <sys/types.h>
   
7. #include <sys/socket.h>
   
8. #include <netinet/in.h>
   ) t. b' ^* b  H  |* F" C$ b
9. #include <arpa/inet.h>
   5 }7 w  a4 V% p
10. 
    8 {5 ^3 @5 \. w! V; y5 g" ]
11. #define PORT 4321
    . q- {- v3 C0 \7 e  _
12. 
    ' _& ^( t5 ]" |8 v  `/ z& N) t
13. #define BACKLOG 1
    ( f. @+ ^" D5 W& d, C
14. #define MAXRECVLEN 1024
    
15. 
    / a: y9 Y0 Q6 n8 V1 ?; L
16. int main(int argc, char *argv[])
    
17. {
    
18.     char buf[MAXRECVLEN];
    $ q* G( G: j" o' ?2 c, p
19.     int listenfd, connectfd;   /* socket descriptors */
    
20.     struct sockaddr_in server; /* server's address information */
    
21.     struct sockaddr_in client; /* client's address information */
    & l  l) K6 a! }: ?2 p7 D
22.     socklen_t addrlen;
    : ?6 l. v+ I, g. u* X, A$ k
23.     /* Create TCP socket */
    
24.     if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    # O% [: ?$ U! b6 m. R; H. j* i7 u9 i
25.     {
    & D' Y0 w: J( {3 u) w
26.         /* handle exception */
    
27.         perror("socket() error. Failed to initiate a socket");
    
28.         exit(1);
    
29.     }
    
30. 
    
31.     /* set socket option */
    
32.     int opt = SO_REUSEADDR;
    & Y' Q9 u3 d( m9 S0 M% S
33.     setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
    5 V! \! S! Z& d* |0 T' d
34. 
    
35.     bzero(&server, sizeof(server));
    0 ^: H( V! L5 g. k
36. 
    - _6 t/ H2 Q$ h# W. y
37.     server.sin_family = AF_INET;
    8 j% c/ f$ @% c, M
38.     server.sin_port = htons(PORT);
    
39.     server.sin_addr.s_addr = htonl(INADDR_ANY);
    " J  `0 D# R% ]; E
40.     if(bind(listenfd, (struct sockaddr *)&server, sizeof(server)) == -1)
    
41.     {
    : x$ N5 H: P1 k' Z1 _+ L
42.         /* handle exception */
    ! D( l* \3 w( A3 N: l8 a: v3 A$ w
43.         perror("Bind() error.");
    ) B; U! c# ~; W) N$ G9 ?. F& E
44.         exit(1);
    ' N9 b6 P6 k6 d- z' B" ^: ?3 X4 A
45.     }
    
46.    
    , F: a8 a. e3 ]; i
47.     if(listen(listenfd, BACKLOG) == -1)
    $ E# ?# I- _* ^7 b1 a. O; K0 u  S
48.     {
    1 G: l/ t) y6 V# I
49.         perror("listen() error. \n");
    1 u2 [/ g/ y0 f9 i* `( B* x
50.         exit(1);
    5 \' |/ y" l8 w( K
51.     }
    * u9 J2 |8 F" k3 g" O$ s
52. 
    
53.     addrlen = sizeof(client);
    . D4 q+ m% O& _4 F
54.     while(1){
      m" S. c+ i8 f) f4 ^
55.         if((connectfd=accept(listenfd,(struct sockaddr *)&client, &addrlen))==-1)
    
56.            {
    ( g* D' g+ F) K
57.             perror("accept() error. \n");
    1 w! k& Y: L6 g4 K8 r
58.             exit(1);
    ( b9 T2 @2 Y& Y- `* K7 w* t
59.            }
    ; _- h: S1 m- D. n' P6 A
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);
    4 n& ~# T& n% p' w* a3 F4 G/ N5 T
64.         
    
65.         int iret=-1;
    ; R/ g1 z: q9 L% p5 `9 e
66.         while(1)
    5 T2 m# F9 u: i% C
67.         {
    : e; _  y* _- b7 Y- c) V
68.             iret = recv(connectfd, buf, MAXRECVLEN, 0);
    
69.             if(iret>0)
    
70.             {
    
71.                 printf("%s\n", buf);
    
72.             }else
    + D6 @3 a/ S5 _+ [* e4 R8 P2 S
73.             {
    
74.                 close(connectfd);
      v0 d& K& K# t% K5 t5 q
75.                 break;
    " l/ ~$ e+ Z: D3 F/ I+ C$ W
76.             }
    
77.             /* print client's ip and port */
    
78.             send(connectfd, buf, iret, 0); /* send to the client welcome message */
    
79.         }
    . A( ^! }2 G7 j: i# X& w/ O
80.     }
    
81.     close(listenfd); /* close listenfd */
    : S: d" M7 r# I! n( X
82.     return 0;
    
83. }

复制代码

& ^0 y& @! h6 ?9 E$ h

（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
   % E3 B9 W- k1 \9 l7 S1 L
2. 
   
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端口等待下一次连接。

( _' N5 a+ d- [; u+ M, N2 `
9 V; d+ B9 \. m

6 ^/ y$ J% o4 |" F0 H: k6 s( E

admin

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

1. /*client.c*/
   
2. #include<netinet/in.h>                         // for sockaddr_in  
   9 b# E( l1 q! q: q& I8 A3 G& x
3. #include<sys/types.h>                          // for socket  
   7 c. `: K5 N, F9 T  _
4. #include<sys/socket.h>                         // for socket  
   
5. #include<stdio.h>                              // for printf  
   7 ]* n' c8 u; u5 @6 N% I/ `; v/ ?# y
6. #include<stdlib.h>                             // for exit  
   
7. #include<string.h>                             // for bzero  
   
8. 
   2 b3 A) _$ I7 `
9. #define HELLO_WORLD_SERVER_PORT       6666  
   5 J4 K0 b- J+ C6 M* n
10. #define BUFFER_SIZE                   1024  
    
11. #define FILE_NAME_MAX_SIZE            512  
    
12. 
    ( g  |, c* S& }
13. int main(int argc, char **argv)  
    
14. {  
    4 V5 X: f, W* p- R" {" p
15.     if (argc != 2)  
    ( |' m1 |0 ?, P6 I7 l9 u: A
16.     {  
    
17.         printf("Usage: ./%s ServerIPAddress\n", argv[0]);  
    
18.         exit(1);  
    
19.     }  
    : b: K( N- n7 {( C
20. 
    4 i0 m' J; a3 k' M1 r) n  U
21.     // 设置一个socket地址结构client_addr, 代表客户机的internet地址和端口  
    
22.     struct sockaddr_in client_addr;  
    6 p% p( F9 y: T$ F& l5 \0 d) }: H
23.     bzero(&client_addr, sizeof(client_addr));  
    
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, 让系统自动分配一个空闲端口  
    5 j/ f/ O- m/ i' a0 [3 G7 |9 |- {
27. 
    
28.     // 创建用于internet的流协议(TCP)类型socket，用client_socket代表客户端socket  
    
29.     int client_socket = socket(AF_INET, SOCK_STREAM, 0);  
    / s+ U8 w2 ~, ]: p2 B3 p! z
30.     if (client_socket < 0)  
    % k" u( K) g7 R- Q
31.     {  
    5 N- m! f2 l1 ~0 w! ^9 ^
32.         printf("Create Socket Failed!\n");  
    4 h" s2 {  r7 R9 C0 s% c0 ]: L
33.         exit(1);  
    
34.     }  
    
35. 
    
36.     // 把客户端的socket和客户端的socket地址结构绑定   
    & _# X+ g+ X7 s1 K
37.     if (bind(client_socket, (struct sockaddr*)&client_addr, sizeof(client_addr)))  
    
38.     {  
    - g9 z: b0 x2 C
39.         printf("Client Bind Port Failed!\n");  
    
40.         exit(1);  
    # }+ Z6 h% I! B( H# E* ]3 Z; F
41.     }  
    * f& a! m8 p: m/ ^3 s7 Y9 g' z  E
42. 
    # f9 G% H; m2 G. ?8 Q" k$ U
43.     // 设置一个socket地址结构server_addr,代表服务器的internet地址和端口  
    
44.     struct sockaddr_in  server_addr;  
    ) P, {+ ^2 c: q$ w4 X
45.     bzero(&server_addr, sizeof(server_addr));  
    
46.     server_addr.sin_family = AF_INET;  
    . b7 j$ p2 R: N8 q
47. 
    
48.     // 服务器的IP地址来自程序的参数   
    5 ?  O4 z8 Y) H
49.     if (inet_aton(argv[1], &server_addr.sin_addr) == 0)  
    " U0 U1 Y/ b: J6 L. u4 H1 Q' C
50.     {  
    
51.         printf("Server IP Address Error!\n");  
    
52.         exit(1);  
    ( J3 C% ^# R2 I3 f2 `2 [
53.     }  
    
54. 
    
55.     server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);  
    . O) L+ l4 {- q4 {8 ?8 X# Z8 i5 I
56.     socklen_t server_addr_length = sizeof(server_addr);  
    / J+ G. M2 _8 S. x) z) {
57. 
    
58.     // 向服务器发起连接请求，连接成功后client_socket代表客户端和服务器端的一个socket连接  
    & q: a& u0 e0 D2 D, X: i
59.     if (connect(client_socket, (struct sockaddr*)&server_addr, server_addr_length) < 0)  
    
60.     {  
    
61.         printf("Can Not Connect To %s!\n", argv[1]);  
    0 j, z( Q, z  L1 S% [
62.         exit(1);  
    2 ]! t( o9 _2 D7 k
63.     }  
    0 V; C2 q. h$ {7 o" K
64. 
    
65.     char file_name[FILE_NAME_MAX_SIZE + 1];  
    
66.     bzero(file_name, sizeof(file_name));  
    ; f9 I3 [" b- W$ G( E% R
67.     printf("Please Input File Name On Server.\t");  
    
68.     scanf("%s", file_name);  
    " q( r6 t0 ~4 B0 a( V
69. 
    . k0 o0 t. H5 c/ P( i! x  L* J& y
70.     char buffer[BUFFER_SIZE];  
    # R% E( {$ K3 o$ L6 F1 r
71.     bzero(buffer, sizeof(buffer));  
    
72.     strncpy(buffer, file_name, strlen(file_name) > BUFFER_SIZE ? BUFFER_SIZE : strlen(file_name));  
    ( @1 X, s! s0 A  a& f! f' h5 T
73.     // 向服务器发送buffer中的数据，此时buffer中存放的是客户端需要接收的文件的名字  
    
74.     send(client_socket, buffer, BUFFER_SIZE, 0);  
    $ F8 p7 H8 e8 @- p2 w
75. 
    0 D( u$ u0 u: P! E2 K& {
76.     FILE *fp = fopen(file_name, "w");  
    4 a4 y5 c  j2 Q1 w* ^/ F. o- y) G
77.     if (fp == NULL)  
      k# b8 e0 y* E7 o
78.     {  
    
79.         printf("File:\t%s Can Not Open To Write!\n", file_name);  
    
80.         exit(1);  
    
81.     }  
    ( F8 e$ q) q2 L9 L  E5 m
82. 
    & |' o& A9 J/ l. Z: X
83.     // 从服务器端接收数据到buffer中   
    / Y. |* i2 ^, p+ p& z: u
84.     bzero(buffer, sizeof(buffer));  
    & {! Q1 H  u( \/ @( }- C7 [  {6 X
85.     int length = 0;  
    8 U# I- H& P4 U- ~
86.     while(length = recv(client_socket, buffer, BUFFER_SIZE, 0))  
    
87.     {  
    
88.         if (length < 0)  
    ) B% ], m/ y; ?* b* r
89.         {  
    3 T9 h- q% R, A* {: K6 c! I
90.             printf("Recieve Data From Server %s Failed!\n", argv[1]);  
    1 T: p' F% g, C2 H
91.             break;  
    , `4 [6 W1 {4 L$ h% y1 G
92.         }  
    ' C& ]" M2 [* L4 @" G, A' L
93. 
    
94.         int write_length = fwrite(buffer, sizeof(char), length, fp);  
      `! ?0 W- w. X4 [- C0 I# F0 h3 b
95.         if (write_length < length)  
    8 O9 c# ^0 t4 t1 X3 f% K
96.         {  
    
97.             printf("File:\t%s Write Failed!\n", file_name);  
    
98.             break;  
    
99.         }  
    9 E, j5 r+ Y" T( E# s
100.         bzero(buffer, BUFFER_SIZE);  
     
101.     }  
     
102. 
     ' }2 h5 b) b; z: k! m
103.     printf("Recieve File:\t %s From Server[%s] Finished!\n", file_name, argv[1]);  
     $ Q) J; [; M$ R- w! U
104. 
     
105.     // 传输完毕，关闭socket   
     
106.     fclose(fp);  
     $ i$ w/ k. K* f" X
107.     close(client_socket);  
     
108.     return 0;  
     8 q! \  U( u: l; |( p. y/ R9 q6 E0 S
109. 
     
110. }  
     & o# ]7 }$ t( ^; g: L
111. 
     ( @9 A  d; x' Q) P

复制代码

1. /*server.c*/
   
2. #include<netinet/in.h>
   
3. #include<sys/types.h>
   
4. #include<sys/socket.h>
   
5. #include<stdio.h>
   ' |) h, b, n7 w8 {
6. #include<stdlib.h>
   
7. #include<string.h>
   
8. 
   
9. #define HELLO_WORLD_SERVER_PORT    6666         //端口号
   0 y5 q2 K/ K( J# P3 {
10. #define LENGTH_OF_LISTEN_QUEUE     20
    
11. #define BUFFER_SIZE                1024
    
12. #define FILE_NAME_MAX_SIZE         512
    
13. 
    
14. int main(int argc, char **argv)
    - _1 @' q3 u# ~  h
15. {
    $ H4 G: |8 F0 v- Z* O8 D  K
16.     // set socket's address information
    
17.     // 设置一个socket地址结构server_addr,代表服务器internet的地址和端口
    * X3 v- m7 d& K2 v; q" o4 e% G# V1 X. L
18.     struct sockaddr_in   server_addr;
    
19.     bzero(&server_addr, sizeof(server_addr));
    % ?. \  q, b, T; ^9 h+ ]! o
20.     server_addr.sin_family = AF_INET;
    
21.     server_addr.sin_addr.s_addr = htons(INADDR_ANY);
    
22.     server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);
    
23. 
    , `; ], A( E6 B% X2 c
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)
    ) g$ [/ m/ }' ]) M
28.     {
    8 r1 I. V7 o0 a% f4 I" N' b
29.         printf("Create Socket Failed!\n");
    
30.         exit(1);
    # M) o# ]2 y5 n" N5 I  b5 A% l
31.     }
    ' f9 G/ P) Z3 b7 r' o/ K
32. 
    4 @% i! Y# G9 ~+ H4 _* t
33.     // 把socket和socket地址结构绑定
    
34.     if (bind(server_socket, (struct sockaddr*)&server_addr, sizeof(server_addr)))
    , {5 ?, H$ b; }# V
35.     {
    
36.         printf("Server Bind Port: %d Failed!\n", HELLO_WORLD_SERVER_PORT);
    
37.         exit(1);
    
38.     }
    + M$ X7 v5 u* i0 @5 A( [
39. 
    
40.     // server_socket用于监听
    : q! Z! f1 {8 B1 C7 @1 c  Q
41.     if (listen(server_socket, LENGTH_OF_LISTEN_QUEUE))
    
42.     {
    % {4 d) \3 o( f
43.         printf("Server Listen Failed!\n");
    . }- b1 K& ^; ^2 Z
44.         exit(1);
    2 P  ]6 n2 F8 O* y1 y3 K, f
45.     }
    
46. 
    
47.     // 服务器端一直运行用以持续为客户端提供服务
    
48.     while(1)
    
49.     {
    
50.         // 定义客户端的socket地址结构client_addr，当收到来自客户端的请求后，调用accept
    
51.         // 接受此请求，同时将client端的地址和端口等信息写入client_addr中
    
52.         struct sockaddr_in client_addr;
    , j- T0 w1 e8 Y* f
53.         socklen_t          length = sizeof(client_addr);
    2 Q6 d& x' ]) l  g/ v
54. 
    ; a$ x2 i+ R# E3 j$ `
55.         // 接受一个从client端到达server端的连接请求,将客户端的信息保存在client_addr中
    
56.         // 如果没有连接请求，则一直等待直到有连接请求为止，这是accept函数的特性，可以
    
57.         // 用select()来实现超时检测
    
58.         // accpet返回一个新的socket,这个socket用来与此次连接到server的client进行通信
    . ^: t4 J6 r' J$ }. v! i6 y/ j
59.         // 这里的new_server_socket代表了这个通信通道
    * Q( |4 e1 q4 A8 ?$ Z, |2 K
60.         int new_server_socket = accept(server_socket, (struct sockaddr*)&client_addr, &length);
    
61.         if (new_server_socket < 0)
    ! m3 V* H0 z/ h8 H
62.         {
    
63.             printf("Server Accept Failed!\n");
      `4 e7 G, |& ?) h
64.             break;
    
65.         }
    6 }" c/ t" z! k/ Q
66. 
    
67.         char buffer[BUFFER_SIZE];
      K$ Z1 N! t3 Q5 K5 n8 g, o
68.         bzero(buffer, sizeof(buffer));
    ' Y# V: D! y3 ~, m8 l/ p7 e
69.         length = recv(new_server_socket, buffer, BUFFER_SIZE, 0);
    
70.         if (length < 0)
    
71.         {
    
72.             printf("Server Recieve Data Failed!\n");
    . r/ v9 O( O$ r: }
73.             break;
    ; \: i9 ^: N" R6 y  m) z8 |
74.         }
    , Y; E" p% C+ a; t7 U
75. 
    
76.         char file_name[FILE_NAME_MAX_SIZE + 1];
    ! \% A6 y& b% N
77.         bzero(file_name, sizeof(file_name));
    
78.         strncpy(file_name, buffer,
    ' z0 Y. I& W- @" T. m# V
79.                 strlen(buffer) > FILE_NAME_MAX_SIZE ? FILE_NAME_MAX_SIZE : strlen(buffer));
    7 Z" R! M0 l2 E; q1 Y$ t
80. 
    
81.         FILE *fp = fopen(file_name, "r");
    $ [+ d( y, e9 t9 C- }% |
82.         if (fp == NULL)
    ( v6 F! E+ r; T
83.         {
    
84.             printf("File:\t%s Not Found!\n", file_name);
    8 E. t" H( a9 }* g/ J3 ^: Y) N
85.         }
    
86.         else
    7 [: p' S" r  Z4 ^* K/ w- _7 s
87.         {
    0 C0 s, v4 K' b: h! U
88.             bzero(buffer, BUFFER_SIZE);
    
89.             int file_block_length = 0;
    % U1 r, [3 x# r7 J
90.             while( (file_block_length = fread(buffer, sizeof(char), BUFFER_SIZE, fp)) > 0)
    , M3 V1 c1 y2 Z+ }7 y( Z
91.             {
    / Z' a3 `6 n+ L+ n+ G. q
92.                 printf("file_block_length = %d\n", file_block_length);
    - a  c$ ?$ `  A1 N( L$ I) `
93. 
    
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);
    
98.                     break;
    
99.                 }
    
100. 
     
101.                 bzero(buffer, sizeof(buffer));
     / u: _, ]( l6 ]; x. g' X
102.             }
     * i" U" x. k5 n7 \0 t
103.             fclose(fp);
     
104.             printf("File:\t%s Transfer Finished!\n", file_name);
     
105.         }
     8 Q' Y3 {; X! v4 \: O1 X/ L
106. 
     ; K8 w, g! c9 X) P: V
107.         close(new_server_socket);
     ) o5 A4 M( d* `, e; Z
108.     }
     
109. 
     6 i. q* {% n' H1 C( U# `# G
110.     close(server_socket);
     
111. 
     
112.     return 0;
     
113. }
     
114. 
     

复制代码

" n+ J! j' X& K# R5 o

6 [( P1 t2 V) F- x/ y3 c