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

admin

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

1. #include <stdlib.h>
   % E8 O% X# x: I
2. #include <stdio.h>
   
3. #include <unistd.h>
   + v# Q. ?( B4 N. q+ d+ n
4. #include <string.h>
   - X; r0 k6 b, s- C
5. #include <sys/types.h>
   # P  Y3 Z3 u- j$ R" i" d* _1 R
6. #include <sys/socket.h>
   ( M, V! l+ j( ~8 Z: E) X
7. #include <netinet/in.h>
   ( A1 B4 u1 I# P, V
8. #include <netdb.h>  /* netdb is necessary for struct hostent */
   
9. 
   
10. #define PORT 4321   /* server port */
    
11. 
    
12. #define MAXDATASIZE 100
    * c- T% p7 c+ b  r' W" S; k+ Q
13. 
    
14. int main(int argc, char *argv[])
    
15. {
    # f, j8 @1 W' c! {$ X3 W8 Z. q8 l
16.     int sockfd, num;    /* files descriptors */
    
17.     char buf[MAXDATASIZE];    /* buf will store received text */
    
18.     struct hostent *he;    /* structure that will get information about remote host */
      y' v1 [; ~' A1 W$ d
19.     struct sockaddr_in server;
    8 x: |" H  d" m5 q" n
20.    
    
21.     if (argc != 2)
    
22.     {
    
23.         printf("Usage: %s <IP Address>\n",argv[0]);
    # Z! m3 y% R+ Q/ m
24.         exit(1);
    
25.     }
    
26.    
    
27.     if((he=gethostbyname(argv[1]))==NULL)
    
28.     {
    & o+ U* N; H) o2 I" H7 k
29.         printf("gethostbyname() error\n");
    
30.         exit(1);
    5 a* Z# Y! F# y
31.     }
    / d1 K5 k- L2 K
32.    
    
33.     if((sockfd=socket(AF_INET,SOCK_STREAM, 0))==-1)
    
34.     {
    
35.         printf("socket() error\n");
    
36.         exit(1);
    
37.     }
    
38.     bzero(&server,sizeof(server));
      t3 z9 {# S. E) C7 g
39.     server.sin_family = AF_INET;
    
40.     server.sin_port = htons(PORT);
    
41.     server.sin_addr = *((struct in_addr *)he->h_addr);
    & p8 P8 V' T9 C, M
42.     if(connect(sockfd, (struct sockaddr *)&server, sizeof(server))==-1)
    
43.     {
    
44.         printf("connect() error\n");
    
45.         exit(1);
    & p5 V6 Q- f% B' n2 e
46.     }
    
47. 　　
    / R) _- [5 d+ |% }' p" Z: Z
48. 　　char str[] = "horst\n"
    ' R  I4 ^& u* n
49. 
    
50.     if((num=send(sockfd,str,sizeof(str),0))==-1){
    6 ?: p+ w+ D( U) r/ K
51.         printf("send() error\n");
    8 Z# P: N3 \3 x0 ~& _2 w* y: s, n
52.         exit(1);
    5 e- U7 c- P9 r; G6 z
53.     }
    
54.     if((num=recv(sockfd,buf,MAXDATASIZE,0))==-1)
    , E7 o( ?: d6 Y; j/ N. R
55.     {
    ! N, k6 E  a  l/ `+ d) Y+ @2 a
56.         printf("recv() error\n");
    
57.         exit(1);
    
58.     }
    
59.     buf[num-1]='\0';
    ( K8 n+ `+ d4 \
60.     printf("server message: %s\n",buf);
    ) V# W1 a0 t- [2 ]0 J
61.     close(sockfd);
    
62.     return 0;
    
63. }

复制代码

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

1. #include <sys/time.h>
   * W' \# ^* B. }% R6 E
2. #include <stdlib.h>
   
3. #include <stdio.h>
   ' E6 p/ q, _: z
4. #include <string.h>
   
5. #include <unistd.h>
   
6. #include <sys/types.h>
   
7. #include <sys/socket.h>
   
8. #include <netinet/in.h>
   0 S" P% D! n( E
9. #include <arpa/inet.h>
   8 O! B6 M  `) A0 H
10. 
    . b' R; Z2 Z. w( ^' ~+ z" g
11. #define PORT 4321
    
12. 
    - W( L& h- X+ c: c
13. #define BACKLOG 1
    
14. #define MAXRECVLEN 1024
    1 e8 T+ @. h+ W" }* s' B
15. 
    
16. int main(int argc, char *argv[])
    " ]' ?- U6 M0 u9 w1 y
17. {
    2 z% h# N4 A1 p# s0 L( G' {3 D
18.     char buf[MAXRECVLEN];
    5 r2 X% e! C* a
19.     int listenfd, connectfd;   /* socket descriptors */
    
20.     struct sockaddr_in server; /* server's address information */
    
21.     struct sockaddr_in client; /* client's address information */
    ' H  d% h3 ?3 G, B
22.     socklen_t addrlen;
    
23.     /* Create TCP socket */
    . S$ Z; A( F3 y& f' V/ u
24.     if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    1 Y2 K$ y0 V; w0 m1 |4 C; v
25.     {
    
26.         /* handle exception */
    9 A9 d6 n+ z: H
27.         perror("socket() error. Failed to initiate a socket");
    
28.         exit(1);
      h; N8 v( n/ f- s) M- D
29.     }
    4 K/ k  u  V- x- h( ]1 K* |
30. 
    5 l# B' y3 D; T
31.     /* set socket option */
    
32.     int opt = SO_REUSEADDR;
    $ _3 ~: D3 @7 \, I6 |8 V/ Q
33.     setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
    
34. 
    
35.     bzero(&server, sizeof(server));
    ' V) c! ?# a. d, k- ^
36. 
    1 K8 e& J8 R! |: k% |7 ~& L
37.     server.sin_family = AF_INET;
    
38.     server.sin_port = htons(PORT);
    
39.     server.sin_addr.s_addr = htonl(INADDR_ANY);
    # Z. R( v7 n5 S# H
40.     if(bind(listenfd, (struct sockaddr *)&server, sizeof(server)) == -1)
    
41.     {
    
42.         /* handle exception */
    
43.         perror("Bind() error.");
    
44.         exit(1);
    0 z$ @1 f4 _8 _. d4 p5 a
45.     }
    
46.    
    * s4 T0 Z" P  U+ q# G( ^
47.     if(listen(listenfd, BACKLOG) == -1)
    
48.     {
    ! h4 }  o5 {+ V0 u
49.         perror("listen() error. \n");
    
50.         exit(1);
    
51.     }
    " W' b- \6 x0 Q/ j$ i2 q' s2 `0 Z
52. 
    ; F" x4 m  W, C
53.     addrlen = sizeof(client);
    - ?+ E" t# O# Y( w8 J3 H( n* A
54.     while(1){
    
55.         if((connectfd=accept(listenfd,(struct sockaddr *)&client, &addrlen))==-1)
    * L0 Q3 T3 {3 }: v& s: \  i
56.            {
    
57.             perror("accept() error. \n");
    - `$ O& a+ A+ ]; {3 e! ]- @7 ~
58.             exit(1);
    6 W; J/ c+ |" {* [
59.            }
    ' V7 ?, `0 U8 g) ~
60. 
    
61.         struct timeval tv;
    % Z; ]% c: M, y: [
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);
    8 N- B  F# B! Y
64.         
    
65.         int iret=-1;
    
66.         while(1)
    
67.         {
    
68.             iret = recv(connectfd, buf, MAXRECVLEN, 0);
    
69.             if(iret>0)
    . A2 u; E# n  ?0 Q* s/ T
70.             {
    
71.                 printf("%s\n", buf);
    
72.             }else
    
73.             {
    
74.                 close(connectfd);
    / B2 n9 O+ p) \! U  M- Y7 `
75.                 break;
    
76.             }
    " |: P7 ^3 g; ^  d
77.             /* print client's ip and port */
    ) \  y1 `3 K. ]- {
78.             send(connectfd, buf, iret, 0); /* send to the client welcome message */
    ( E( P. G# R2 k; O5 w
79.         }
    
80.     }
    5 w6 \+ ]! ?7 G3 m! V! u: a; ~3 g1 k
81.     close(listenfd); /* close listenfd */
    
82.     return 0;
    6 N& k- C6 A1 v9 ?
83. }

复制代码

' p6 K/ P  ?9 n5 L- ?

（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

复制代码

- Q, B: _" f; K5 P* {

服务器端：

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端口等待下一次连接。

4 k7 m- o$ }' j' N5 t3 H

admin

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

1. /*client.c*/
   
2. #include<netinet/in.h>                         // for sockaddr_in  
   
3. #include<sys/types.h>                          // for socket  
     R) h" p9 a& U3 ~: {* L
4. #include<sys/socket.h>                         // for socket  
   5 L% U, k7 \  t% P* ~* D' h6 ]
5. #include<stdio.h>                              // for printf  
   . _; h$ R# L9 G9 s6 Z$ a1 E' @
6. #include<stdlib.h>                             // for exit  
   & O5 r. w1 _) ?8 T+ Y
7. #include<string.h>                             // for bzero  
   % g' E6 c$ B/ F/ P9 r, ]" Z
8. 
   
9. #define HELLO_WORLD_SERVER_PORT       6666  
   
10. #define BUFFER_SIZE                   1024  
    
11. #define FILE_NAME_MAX_SIZE            512  
    6 {/ V9 q$ W/ ~; V
12. 
    
13. int main(int argc, char **argv)  
    ' c" ~6 A* i5 H. _% X
14. {  
    
15.     if (argc != 2)  
    
16.     {  
    & X! _% a" e9 d7 d: ]8 L
17.         printf("Usage: ./%s ServerIPAddress\n", argv[0]);  
    
18.         exit(1);  
    ) G  A7 L5 ^( e5 Q* j
19.     }  
    
20. 
    
21.     // 设置一个socket地址结构client_addr, 代表客户机的internet地址和端口  
    + _/ x$ t, S+ N( G2 \
22.     struct sockaddr_in client_addr;  
    3 J, a( H! }( c
23.     bzero(&client_addr, sizeof(client_addr));  
    4 d/ t1 D7 N+ i3 t% W' o- f" t: _9 g& b% J6 r
24.     client_addr.sin_family = AF_INET; // internet协议族  
    
25.     client_addr.sin_addr.s_addr = htons(INADDR_ANY); // INADDR_ANY表示自动获取本机地址  
    , o$ L# O- H. ^0 J' U& \
26.     client_addr.sin_port = htons(0); // auto allocated, 让系统自动分配一个空闲端口  
    
27. 
    - s4 V% W; T+ ]& ^1 j: [
28.     // 创建用于internet的流协议(TCP)类型socket，用client_socket代表客户端socket  
    , r0 A' C& {# ~* x& r& w) w
29.     int client_socket = socket(AF_INET, SOCK_STREAM, 0);  
    
30.     if (client_socket < 0)  
    % n3 _' U$ d4 R% J# [( e. D$ \
31.     {  
    
32.         printf("Create Socket Failed!\n");  
    0 @1 m/ i. M# [: E& b" m. Z
33.         exit(1);  
    * Q2 |2 m# t; p
34.     }  
    
35. 
    
36.     // 把客户端的socket和客户端的socket地址结构绑定   
    
37.     if (bind(client_socket, (struct sockaddr*)&client_addr, sizeof(client_addr)))  
    + x+ h8 V2 i; c* ]+ L6 k1 ^. u  N, g9 ~
38.     {  
    
39.         printf("Client Bind Port Failed!\n");  
    - I8 v$ l5 G8 c" k4 D. Y9 B
40.         exit(1);  
    
41.     }  
    7 v) L7 Z7 f: b8 }
42. 
    
43.     // 设置一个socket地址结构server_addr,代表服务器的internet地址和端口  
    ( Z: Q5 k- c9 B  c
44.     struct sockaddr_in  server_addr;  
    & g, C7 \$ i* j( G
45.     bzero(&server_addr, sizeof(server_addr));  
    
46.     server_addr.sin_family = AF_INET;  
    
47. 
    
48.     // 服务器的IP地址来自程序的参数   
    
49.     if (inet_aton(argv[1], &server_addr.sin_addr) == 0)  
    + L/ I. y% H" A' O" Q1 m* Q
50.     {  
    % N* u% L( D1 H) Q" P  [3 @; l: k
51.         printf("Server IP Address Error!\n");  
    
52.         exit(1);  
    0 _3 P  e; r3 u* E4 |8 `9 F
53.     }  
    ! G/ ]; f8 v" T$ }
54. 
    ( o9 O+ Y- R$ I8 t: M, N6 K
55.     server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);  
    8 H( G- x8 a7 C
56.     socklen_t server_addr_length = sizeof(server_addr);  
    : d) [. j% w: n$ ~& e( f
57. 
    ; e. `, I1 K; X) j7 s
58.     // 向服务器发起连接请求，连接成功后client_socket代表客户端和服务器端的一个socket连接  
    " _0 F% k3 a, V  J
59.     if (connect(client_socket, (struct sockaddr*)&server_addr, server_addr_length) < 0)  
    
60.     {  
    9 u/ ]* o! t7 C* y
61.         printf("Can Not Connect To %s!\n", argv[1]);  
    & o% H6 n4 G! k$ v8 U; H4 e- O
62.         exit(1);  
    
63.     }  
    . }+ h( y9 Z6 U, u1 a+ g
64. 
    0 y" E6 H- T* L& H8 i4 ^+ I
65.     char file_name[FILE_NAME_MAX_SIZE + 1];  
    
66.     bzero(file_name, sizeof(file_name));  
    
67.     printf("Please Input File Name On Server.\t");  
    
68.     scanf("%s", file_name);  
    6 e4 V  Y7 G  _- N
69. 
    7 b" k7 H, \( \+ X8 f" ^3 a
70.     char buffer[BUFFER_SIZE];  
    & }% G" H3 H% Z5 `5 e) g  U1 c
71.     bzero(buffer, sizeof(buffer));  
    
72.     strncpy(buffer, file_name, strlen(file_name) > BUFFER_SIZE ? BUFFER_SIZE : strlen(file_name));  
    
73.     // 向服务器发送buffer中的数据，此时buffer中存放的是客户端需要接收的文件的名字  
    / C( L0 ^% Y+ q5 `. M4 P
74.     send(client_socket, buffer, BUFFER_SIZE, 0);  
    
75. 
    ) Q7 N* g. O. {$ W
76.     FILE *fp = fopen(file_name, "w");  
    , }# y, P/ \1 n  f
77.     if (fp == NULL)  
    
78.     {  
    
79.         printf("File:\t%s Can Not Open To Write!\n", file_name);  
    
80.         exit(1);  
    
81.     }  
    
82. 
    - c6 t+ ~% @6 F8 B
83.     // 从服务器端接收数据到buffer中   
    4 Z2 P( k/ z/ K- P$ J+ h
84.     bzero(buffer, sizeof(buffer));  
    . L, Y% J  L' H% g( f% g1 P
85.     int length = 0;  
    2 q* Y  x: }( a/ I& j
86.     while(length = recv(client_socket, buffer, BUFFER_SIZE, 0))  
    : q4 a$ d' Z7 `7 b2 C
87.     {  
    
88.         if (length < 0)  
    
89.         {  
    
90.             printf("Recieve Data From Server %s Failed!\n", argv[1]);  
    1 T- Z& Z! Q6 m* n  D* @1 ]
91.             break;  
    
92.         }  
    3 B3 b. }- r' I! p" F: V" s/ _
93. 
    
94.         int write_length = fwrite(buffer, sizeof(char), length, fp);  
    
95.         if (write_length < length)  
    & e% D8 h6 i* t1 X5 q
96.         {  
    9 e1 a1 H  |  h' ~) H6 u
97.             printf("File:\t%s Write Failed!\n", file_name);  
    1 Q/ E4 G; v. p$ y8 H* a7 \/ w/ P
98.             break;  
    
99.         }  
    
100.         bzero(buffer, BUFFER_SIZE);  
     
101.     }  
     ' T- a3 \7 A7 N7 P9 U# V
102. 
     
103.     printf("Recieve File:\t %s From Server[%s] Finished!\n", file_name, argv[1]);  
     
104. 
     
105.     // 传输完毕，关闭socket   
     % J5 A, U# {8 |% {4 F
106.     fclose(fp);  
     
107.     close(client_socket);  
     
108.     return 0;  
     ! [' ~0 Q  ?4 b; |# g) y
109. 
     - D+ n' a7 W' _+ q% D! }% W. s2 l" H
110. }  
     
111. 
     

复制代码

1. /*server.c*/
   
2. #include<netinet/in.h>
   ; M) y" v% M# h& j5 O5 p
3. #include<sys/types.h>
   
4. #include<sys/socket.h>
   
5. #include<stdio.h>
   
6. #include<stdlib.h>
   
7. #include<string.h>
   
8. 
   " L3 {  g, l; ^  M, ?# o: j
9. #define HELLO_WORLD_SERVER_PORT    6666         //端口号
   
10. #define LENGTH_OF_LISTEN_QUEUE     20
    ; s7 W( b0 `) W8 g+ Z
11. #define BUFFER_SIZE                1024
    
12. #define FILE_NAME_MAX_SIZE         512
    
13. 
    1 M/ U/ V' L% H7 N2 f
14. int main(int argc, char **argv)
    
15. {
    
16.     // set socket's address information
    
17.     // 设置一个socket地址结构server_addr,代表服务器internet的地址和端口
    4 ?: m; B$ X' f9 [: U9 ?
18.     struct sockaddr_in   server_addr;
    
19.     bzero(&server_addr, sizeof(server_addr));
    , s4 E6 @7 p1 |6 R' d/ W
20.     server_addr.sin_family = AF_INET;
    & W% D5 X, D/ d' G7 ~' o, i% }
21.     server_addr.sin_addr.s_addr = htons(INADDR_ANY);
    
22.     server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT);
    & c8 C* _; G  f+ U. A
23. 
    
24.     // create a stream socket
    4 H; `0 D. @! Y
25.     // 创建用于internet的流协议(TCP)socket，用server_socket代表服务器向客户端提供服务的接口
    / A* r, [# V! G. P  }! ?& g
26.     int server_socket = socket(PF_INET, SOCK_STREAM, 0);
    0 S7 E* T5 H# e) f# I9 L+ x: V
27.     if (server_socket < 0)
    
28.     {
    ( j- y- u1 }: b# w! n9 \9 ~
29.         printf("Create Socket Failed!\n");
    $ m5 d* |" V! Y+ p
30.         exit(1);
    
31.     }
    
32. 
    
33.     // 把socket和socket地址结构绑定
    + O+ s; B' I; R5 B7 q
34.     if (bind(server_socket, (struct sockaddr*)&server_addr, sizeof(server_addr)))
    ( {7 ^6 {! P, x2 B4 [* R  h  y- X
35.     {
    
36.         printf("Server Bind Port: %d Failed!\n", HELLO_WORLD_SERVER_PORT);
    0 q8 E: ~' ]# k( K
37.         exit(1);
    & k# M) T( Q% @9 e3 M
38.     }
    
39. 
    
40.     // server_socket用于监听
    + j! t: D" Z0 r  a- q
41.     if (listen(server_socket, LENGTH_OF_LISTEN_QUEUE))
    7 `- G) L+ V$ A0 ?$ h
42.     {
    
43.         printf("Server Listen Failed!\n");
    ' H1 l4 ^* w7 d5 ]; i; f0 {
44.         exit(1);
    
45.     }
    & p" g$ l, z  k
46. 
    
47.     // 服务器端一直运行用以持续为客户端提供服务
    
48.     while(1)
    
49.     {
    6 q( y! K1 q; I2 c
50.         // 定义客户端的socket地址结构client_addr，当收到来自客户端的请求后，调用accept
    
51.         // 接受此请求，同时将client端的地址和端口等信息写入client_addr中
    
52.         struct sockaddr_in client_addr;
    
53.         socklen_t          length = sizeof(client_addr);
    . L7 h2 q- |: D8 P' X$ Y
54. 
    " u0 ?+ j) W+ t& D; r
55.         // 接受一个从client端到达server端的连接请求,将客户端的信息保存在client_addr中
    
56.         // 如果没有连接请求，则一直等待直到有连接请求为止，这是accept函数的特性，可以
    6 _) f& d' I8 t" N% @9 v+ y1 [
57.         // 用select()来实现超时检测
    
58.         // accpet返回一个新的socket,这个socket用来与此次连接到server的client进行通信
    
59.         // 这里的new_server_socket代表了这个通信通道
    9 `! F9 ^" M3 g, R3 Y
60.         int new_server_socket = accept(server_socket, (struct sockaddr*)&client_addr, &length);
    6 n  I. Y3 X( ], m
61.         if (new_server_socket < 0)
    - W* Q3 Q0 X8 E# Q+ m' D% X) D# K
62.         {
    
63.             printf("Server Accept Failed!\n");
    
64.             break;
    
65.         }
    
66. 
    + K# {- s( S0 ~0 F' Y
67.         char buffer[BUFFER_SIZE];
    ; z3 ~0 _9 B: _
68.         bzero(buffer, sizeof(buffer));
    
69.         length = recv(new_server_socket, buffer, BUFFER_SIZE, 0);
    # S, t5 T3 f' P9 p- g" c
70.         if (length < 0)
    : \7 d% M# K, o; H! W0 c- k
71.         {
    
72.             printf("Server Recieve Data Failed!\n");
    
73.             break;
    " G7 \) W% m! m+ i. t# V( j0 N
74.         }
      a/ c" {0 |% q  y0 C1 B
75. 
    - v' H3 b0 d$ g( p2 ~& w" Y
76.         char file_name[FILE_NAME_MAX_SIZE + 1];
    
77.         bzero(file_name, sizeof(file_name));
    2 k$ A3 O+ }4 z5 g% s" h' F  q
78.         strncpy(file_name, buffer,
    $ ^) i5 F% v0 x3 i# N
79.                 strlen(buffer) > FILE_NAME_MAX_SIZE ? FILE_NAME_MAX_SIZE : strlen(buffer));
    
80. 
    
81.         FILE *fp = fopen(file_name, "r");
    ( s- `+ [' U: A8 n( b8 N9 N
82.         if (fp == NULL)
    - \7 u* m+ k- n% e. a  E% j
83.         {
    ; B$ m6 `1 f; r0 P, ?
84.             printf("File:\t%s Not Found!\n", file_name);
    
85.         }
    
86.         else
    ' y7 K. v- W3 _9 e" |0 S# _  @
87.         {
    
88.             bzero(buffer, BUFFER_SIZE);
    ) O: s! |) w* e7 a! Y6 ?
89.             int file_block_length = 0;
    
90.             while( (file_block_length = fread(buffer, sizeof(char), BUFFER_SIZE, fp)) > 0)
    5 l; @4 b$ z0 U- p. k
91.             {
    
92.                 printf("file_block_length = %d\n", file_block_length);
    
93. 
    
94.                 // 发送buffer中的字符串到new_server_socket,实际上就是发送给客户端
    5 }- O6 x2 Q# l7 j) G* j
95.                 if (send(new_server_socket, buffer, file_block_length, 0) < 0)
    4 I' \( {( |- O8 A7 F8 `
96.                 {
    4 E9 `% ~$ ^3 b: L5 ]
97.                     printf("Send File:\t%s Failed!\n", file_name);
    
98.                     break;
    2 U' p  v/ M9 Y* l1 b7 k- W
99.                 }
    
100. 
     7 P6 P' j5 F$ D3 S
101.                 bzero(buffer, sizeof(buffer));
     
102.             }
     4 P" |6 P% H2 u
103.             fclose(fp);
     
104.             printf("File:\t%s Transfer Finished!\n", file_name);
     
105.         }
     - u5 y1 N" o5 z& s4 J  g. j! q0 [
106. 
     
107.         close(new_server_socket);
     8 {# G( r4 u( O- x
108.     }
     
109. 
     1 M* Q* j3 V, K: `
110.     close(server_socket);
     6 g- ^' S# X  L1 a) v
111. 
     
112.     return 0;
     : b% X" r' q0 t; Q: j
113. }
     
114. 
     : |7 c* P; \) `8 c' r

复制代码

/ b$ W1 J- r5 g# s' x4 d/ x

+ f- y) e1 c/ j. _