一个简单的C语言的socket服务器和客户端程序

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
客户端程序：client.cpp

1. #include <winsock2.h>
   4 r9 \# g1 w) T
2. #include <stdio.h>
   , T& P2 h+ R+ p2 }* g! Y! A1 }6 V
3. #include <stdlib.h>
   0 b$ W( Z  M) L2 ]' ]
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   ; r8 p: A. r& D" _# e+ k. J
7. 
   % ^* W& o( l3 g$ D& p
8. char  szServer[128],
   " e  X0 W- e, P! x2 E; {# Q. ?0 ?' [
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    " ^% J/ v0 Z* K+ H
11. 
    ; _0 Z! k. z, Y9 ?
12. int main()
    
13. {
    $ u. r0 o0 s/ {" z, g
14.    WSADATA      wsd;
    $ {4 O$ n, D( h3 J
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    4 g. {( @, Q# P/ t6 N
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    8 h) G. e/ q' ?% T7 K; c7 F# u8 K
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    . ?4 c3 A9 k% L) B- |
24.     }
    
25.    printf("Enter a string to send to server:\n");
    
26.    gets(szMessage);
    
27.     // Create the socket, and attempt to connect to the server
    
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    % W8 f! T) q/ U
29.     if (sClient == INVALID_SOCKET)
    ( r4 r- s8 i# |% ~2 m
30.     {
    " k2 u2 E* r; M
31.        printf("socket() failed: %d\n", WSAGetLastError());
    6 A4 S- G& F% }6 J5 T0 j: P* t
32.        return 1;
    8 y. y! ]0 @2 B0 }% m* K
33.     }
    . R8 ]2 \4 ]0 J3 U$ Y3 n
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    & Q' q* `( ~! Y
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    1 v4 b/ p2 m& E! K7 }
39.        sizeof(server)) == SOCKET_ERROR)
    7 c! ?: M% {4 Q8 s8 k$ O! o
40.     {
    # r+ h$ p+ u  w* w) R1 o
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
      g: C  E+ U, m( i
43.     }
    
44.     // Send and receive data
    4 \8 \0 Z; e0 z, w  ]. [
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    2 x/ f! _0 d7 x
49.     }
      K# R* M6 r6 _8 c% ?6 q" l/ g
50.     else{
    3 A3 Q* X' D& l( o
51.        printf("Send '%s' \n", szMessage);
    - p; R/ x6 h4 M, S( S  s8 |
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    9 y; v2 y0 t4 P; a9 n1 ]
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    1 P! k7 j/ h4 ^' H! _9 D
55.        }
    7 z7 D. T- d+ g7 U9 ^) A( f
56.        else{
    ! a: F$ U# s% P! ?& l: E% u5 A. s
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    ' y' i; M+ ~: I
59.        }
    9 L* C6 p, Q  Z, i! L/ a1 ?3 R' ?
60.     }
    
61.    closesocket(sClient);
    : Q5 z% G+ N3 r# a5 W5 `" Y
62. 
    
63.    WSACleanup();
    
64.     return 0;
    
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   
2. #include <stdio.h>
   * ~  X! m9 m8 A7 t% y
3. #include <stdlib.h>
   " p. y, z3 D% H( B, s# t4 }
4. 
   
5. #define DEFAULT_PORT       5150
   . b% b; {5 M' E+ y! J  J9 Y
6. #define DEFAULT_BUFFER     4096
   
7. 
   
8. int   iPort     = DEFAULT_PORT;
   / [. {" y5 O0 C, Q" o- W( T6 E: I; E
9. char   szAddress[128];
   
10. 
    * ]6 ~+ h; H+ K) Q; R
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    $ z, r; J# w6 H4 H: v9 i9 j
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    & A: q: [4 d4 q; ~
15.    int          ret;
    
16. 
    
17.    while(1)
    $ f! O& ?( f% f: b/ J& c6 q
18.     {
    9 f3 d. V) z1 c8 r, n5 M( v. f' v
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    : [2 v! z3 ~% k0 s! W
20.        if (ret == 0)
    2 \7 J1 u4 k  [
21.            break;
    + o( j+ m1 `' Y% V' k; s# l
22.        else if (ret == SOCKET_ERROR)
    8 K3 l, m  t1 d7 ~9 \( t4 o
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    
26.        }
    1 T, l  o; b) \9 i7 c$ _" X
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    9 B  a, n5 S+ c( O7 r
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    # |) _- o! C2 _
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    1 ~% y5 C, T8 r
39.     }
    
40.     return 0;
    
41. }
    
42. 
    , F! \: y1 m+ R; a# x& t
43. int main()
    5 D. }4 j. i# w( X0 G# W3 e0 ^
44. {
    
45.    WSADATA      wsd;
    - z# p  }$ ^  H! l6 S( O
46.    SOCKET       sListen,
    8 z9 l! G5 o2 `0 X0 q
47.                  sClient;
    9 @7 E! H9 k1 d3 o
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    / p2 \- X; ]) R5 u- e3 f
51.     struct sockaddr_in local,
    ! H1 u3 C1 W7 U( J* w2 ]4 M8 j
52.                       client;
    
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    ! ~: c& }( @: `- ~/ \
56.        printf("Failed to load Winsock!\n");
    6 _' |2 h8 w/ T- ]& d8 Z! d
57.        return 1;
    
58.     }
    
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    * I  C! p: P6 S4 I, o+ H: V
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    $ x" ]$ ^6 M- u3 x. n* Z! u! j
65.     }
    / }0 T- {; @1 M( l5 J
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    + u8 Y- a: Q9 `5 u2 `
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    # v+ _; E/ ?( Q
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    8 u! q8 G. Z6 I1 D; Z
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
      ?2 u  o* N9 i6 P! Y4 j
75.     }
    / ^" E& s% d2 F% E# V1 w
76.    listen(sListen, 8);
    & e* Q8 l4 P0 j4 S
77.     // In a continous loop, wait for incoming clients. Once one
    7 n+ s6 ~* {. o2 s2 h/ h, W, m
78.     // is detected, create a thread and pass the handle off to it.
      @5 L/ @: s- ^5 ?  j4 z
79.     while (1)
    ) R$ }9 l6 `- n, p9 i: }
80.     {
    / k+ u: j; n0 X# q, P6 _
81.        iAddrSize = sizeof(client);
    - N/ |$ o* o5 N2 c% R
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    * ^% r9 p8 H" D( {1 J0 B. |
85.        {      
    ' p8 v/ l6 b2 e7 i
86.            printf("accept() failed: %d\n", WSAGetLastError());
    # j5 ~. Y7 V4 I6 N1 S
87.            break;
    
88.        }
    
89.        printf("Accepted client: %s:%d\n",
      S  F/ r( Z. x. Z" v; C
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    8 v' I0 f$ H% [5 o
96.            printf("CreateThread() failed: %d\n", GetLastError());
    ! [8 a; z/ k+ ?1 P1 K) E
97.            break;
    
98.        }
    1 L# A5 F+ Y; q
99.        CloseHandle(hThread);
    : x* e2 V" t5 V
100.     }
     
101.    closesocket(sListen);
     # {6 V% x! Z! R9 o  k$ y
102.    
     * X$ y% Y+ U$ o7 I+ l  ^
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

( U6 A# V3 z& l( U% C! r

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   ! [7 }0 ~3 `6 B& G8 z) Q* v4 x6 X
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   + I& A3 F% L# v" s
6. Server：
   
7. #include <winsock2.h>
   
8. #pragma comment(lib, "WS2_32.lib")
   / o( f0 S7 [- T
9. 
   " [  {/ o. C* R7 l) e  y3 p) B- g
10. #include <stdio.h>
    
11. void main()
    
12. {
    . T3 {+ ^6 J' @5 D- M  S: U
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    # i* O5 w- |" P# I, ~2 W
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
    , g4 Z8 u% l( _
21.     {
    ! Q4 B( b' k2 O# v! A
22.         return;
    
23.     }
    
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    . I  U' k, L* a, o' m
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    : g7 I* t4 n' H# @1 w6 c
27.          
    9 ~. x- j' O: g3 I. Y2 d/ y
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    " D) N4 g% u/ S; O& s
30.     {
    % v4 S5 Q+ u; V; [( }  m2 `
31.         return;
    
32.     }
    ( g2 r( F7 [2 f5 x& s, L1 \
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    5 P  W0 w6 \0 j1 \  n- N
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    $ s( D: G0 B! X( l6 Q/ i! b& w
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    5 T# K( ?" w/ A* ^, w
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    : v& a" L/ [4 q) T9 v
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    
50.          listen(socSrv, 5);
    
51.          
    ) f0 j* d- u1 I" [* i* V
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    7 O3 n6 v- c2 o3 r$ r) H& d
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    , R' M- t9 U; K" d! T
56.          //循环等待接受客户端发送请求
    
57. 
    . B+ N8 S" e, B
58.          while (1)
    * g) I9 p- w1 r2 r
59.          {
    ; v( Q' [& f$ p8 N+ T3 f8 }0 A! `
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    $ u1 E1 H, H4 X5 p) q0 a! t# ?
63.                    //此时程序在此发生阻塞
    & O  ]5 {- D* R$ w# r* X- `
64. 
    & ^7 L: s% x  y4 \
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    0 E4 V* }# t- ]6 N: F; A' k
66. 
    ; G: C- `- i) Y1 A
67.                    char sendBuf[100];
    0 H; w9 i7 |7 d0 m: a
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    ; j" f! y2 u8 T% o$ a( E4 S
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    1 @3 S& q  u: w! l' w1 b
73.                    //用返回的套接字和客户端进行通信
    
74. 
    3 r0 {$ F7 i# J4 B
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    
77.                    //接收数据
    " U' A1 K" j! K
78. 
    # F2 K4 o# u: d' ^8 l
79.                    char recvBuf[100];
    0 b- f5 t4 A, ^3 a
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    0 T5 f- ~5 `( v8 n  r7 r+ L4 [
83.                    printf("%s\n", recvBuf);
    . ?. b! X3 d7 Y! v. m
84.                    closesocket(sockConn);
    # n4 J2 X1 O0 d+ `- A5 x1 y4 L
85. 
    $ w" _; D, h' L2 L
86.          }
    4 Q& O8 I$ k6 |, Y) ~/ K, f7 {1 t
87. }
    ' R7 h, c$ J2 [0 e
88. 
    " m5 _4 [. N- T) ]1 ]8 L2 I
89. 
    & v3 o8 b1 B+ w3 c0 f+ K& H
90. Client：
    
91. 
    
92. #include <winsock2.H>
    9 |0 r8 ?( F9 z, o8 M
93. #pragma comment(lib, "Ws2_32.lib")
    8 r& U0 g) L4 c# K' t
94. #include <stdio.h>
    
95. #include <string.h>
    
96. 
    
97. void main()
    * O& [+ V8 t4 V3 i
98. {   
    / e* K4 E1 c2 ~5 J( a# e
99.     WORD wVersionRequested;
    6 P" E9 i( D" a# \+ q9 a6 W
100.     WSADATA wsaData;
     
101.     int err;
     ( R1 H' ~2 }7 W1 U5 `4 Z6 c6 @
102.      
     3 Q8 w, n' x' x+ l5 W% g
103.     wVersionRequested = MAKEWORD( 2, 2 );
     ! \1 L# K9 X4 i( y: O) @# ^
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     
107.          
     
108.         return;
     
109.     }
     
110.      
     
111.      
     % \  p0 }* s: ^/ o- K
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     3 n3 S5 O3 G! T
113.         HIBYTE( wsaData.wVersion ) != 2 )
     # }: a) j/ L) n; z! p5 F# A
114.     {
     8 y8 u$ G) y0 J7 @, f# R
115.          
     ' ^  M5 t6 Y2 p8 s: e5 ?
116.         WSACleanup( );
     / C2 m$ s6 D$ e& M- Y
117.         return;
     ( U8 R2 ?+ p: W9 [- ?# _- Y
118.     }
     7 G! o5 @$ r/ C0 K
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     ( V4 D# q/ E. T: h. D4 Y- u
121.     addrSrv.sin_family = AF_INET;
     
122.     addrSrv.sin_port = htons(6000);
     
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     0 U% i: U2 L; N5 r* U8 _) [% i9 H
126.     char recvBuf[256];
     ( t( _% q* p5 v2 g+ N
127.     char sendBuf[] = "This is Joychou";
     2 v  P) |- |# F0 H3 M  F
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     ' _+ z4 I  y" {0 `# s% c3 P
132.     WSACleanup();
     0 o0 w/ l: ?: h. B1 o
133.      
     % D# U: n5 K- Z9 p+ c- t; {5 g$ t% [  ^
134. }

复制代码

, h5 n4 ?" k* O9 P: h