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

admin

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

1. #include <winsock2.h>
   ; H* w2 E5 n; L% U
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   ! Z  _3 k9 }" U: c
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
     ~. G- }7 O+ u
7. 
   
8. char  szServer[128],
   1 m' D2 V+ ?& V9 Q3 a' \
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    , }* ]* a3 F2 T* F+ E+ D
11. 
    - y3 z# j# H- U  p6 r& d" b0 V! H
12. int main()
    4 n! `/ F6 e3 K7 y$ P5 }
13. {
    
14.    WSADATA      wsd;
    . w+ {% N  h  C) F* {7 X! u
15.    SOCKET       sClient;
    ; P  p" U' R2 h
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    
18.     struct sockaddr_in server;
    2 W  D: J' @& L$ ]
19.     struct hostent    *host = NULL;
    7 E1 ^. U3 J7 h. X( W2 y* ^
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    - e) t' r' U2 r& k
21.     {
    6 r' X3 S' j& u3 H8 A
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    2 ]( k5 I; |) o; s& z
24.     }
    ; @+ g& t4 R6 O9 z
25.    printf("Enter a string to send to server:\n");
    
26.    gets(szMessage);
    / N5 E9 i. n- [- H: D
27.     // Create the socket, and attempt to connect to the server
    , k# b9 R# t2 d0 {) x2 [
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
29.     if (sClient == INVALID_SOCKET)
    $ G( X8 I3 M! A& |8 N! i
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    , O/ G) f- a. U: v: T5 g
33.     }
    % }) N* g' E" e" D
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    , Q: T4 ~% G) f% j# B$ o7 E7 `# q/ q: q
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    8 p4 w$ W( I3 j) @) }
37. 
    - H+ W% j8 Z) T' s
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    4 O/ W. J. p! }: t
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    
43.     }
    
44.     // Send and receive data
    2 M# s1 K" U# ~9 J( d3 ~
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    8 ?5 V' u6 p  Y
46.     if (ret == SOCKET_ERROR)
    $ t/ W4 B" T9 q1 ?6 o1 M
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    : B3 e9 Y. A9 z) t) o9 a
50.     else{
    : D! Y8 `) c; ~$ z# M( L
51.        printf("Send '%s' \n", szMessage);
    * ?! k  h; H( P! S: \$ Z3 E
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
    , f% G5 t; b. z5 j
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    
56.        else{
    7 i; d0 F$ O% l
57.          szBuffer[ret] = '\0';
    - d3 X( t8 l' c$ e3 z: P: s
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    
60.     }
    
61.    closesocket(sClient);
    7 G' t# Q  U) u$ g2 i, O+ y0 t
62. 
    ! j* m3 B/ @) d% Y8 u; a
63.    WSACleanup();
    
64.     return 0;
    . o1 S% @$ E5 m2 M9 \+ y) u6 h
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   # v7 M: n& j5 b0 j
2. #include <stdio.h>
   + B5 @6 g0 s/ K( U2 {
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     4096
   4 @" \+ _0 W5 `2 b2 H
7. 
   
8. int   iPort     = DEFAULT_PORT;
   ! B  r7 i% o" O
9. char   szAddress[128];
   
10. 
    6 W2 J7 o# x5 Q' v! a5 T8 D6 v
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    8 \9 t- w7 M6 ]/ R
15.    int          ret;
    
16. 
    
17.    while(1)
    0 p: ^3 a  y- C0 |% f% I
18.     {
    
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    + S$ T' T/ [/ a) ?& ?: C
20.        if (ret == 0)
    / _: `; _* b) l! A
21.            break;
    9 H) Y4 T; {" ^
22.        else if (ret == SOCKET_ERROR)
    % ?4 d1 D% N6 }5 m
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    
26.        }
    
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    1 Z1 b1 n- O9 g
30.          memcpy(szBuff,"Send the correct string!",25);
    % A0 {3 a7 z9 w7 Z4 j, R
31.        }
    ! E' B* s- u7 \. U' O) F* f
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    5 \0 x: k9 P) m
36.        if (ret == SOCKET_ERROR){
    2 `' r2 Y) d/ W& L
37.          printf("send() failed: %d\n", WSAGetLastError());
    & {& c2 ]2 p: b4 Q+ @; S4 K+ a
38.        }
    * r" S  r: U1 i# q% o/ Y4 W
39.     }
    
40.     return 0;
    % V$ h6 w) S$ }3 \. Q2 h3 y1 W
41. }
    
42. 
    # I: Y7 W8 ?' q0 Q6 b
43. int main()
    
44. {
    
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    8 O; e! t- J3 p, e* P% ^5 q
47.                  sClient;
    
48.    int          iAddrSize;
    ! H. \/ I0 C% G) n( @' ?- w
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    . A+ y& m8 J# |
51.     struct sockaddr_in local,
    
52.                       client;
    
53. 
    - ^" e) Q3 R5 i+ K' X
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    ; m; b( f+ m& ^6 ?$ M( k
55.     {
    8 K# t0 _9 F: k& B) ?- F5 E
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    
58.     }
    
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    + A9 M" J7 p* F5 e, }- K: ~
61.     if (sListen == SOCKET_ERROR)
    & e1 \0 i8 \* k% G. ]9 p( A) _
62.     {
    & E+ t5 k* z: A" t+ j& x$ [5 F
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    6 v, B6 Q( m, v0 z( K$ n4 X
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    / ~; c7 r- L* l  r8 ~
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    . [9 y- X$ B+ \9 ?3 w- g8 J5 w
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    
75.     }
    
76.    listen(sListen, 8);
    
77.     // In a continous loop, wait for incoming clients. Once one
    / S- J' n& a1 d8 F! y4 \
78.     // is detected, create a thread and pass the handle off to it.
    
79.     while (1)
    * i1 O. ~7 [, q6 V9 w+ a
80.     {
      D7 a' @4 Q7 X7 W+ L! Q$ b) _
81.        iAddrSize = sizeof(client);
    5 R# F" Q& ~1 b" D" d
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    ' a) r) i/ ~9 u5 Q, w3 \4 v' \
84.        if (sClient == INVALID_SOCKET)
    1 P& H, `8 |3 x4 {% I6 J
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    , L6 D& N1 D! d7 X- ?3 @- w- Y
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    # y, u# ?! }& x! _/ b
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    2 r* ]1 h# @) A" s" C9 `
91. 
    / z) J/ h) p. n4 M. v- a0 w( z2 w/ X
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    , I0 w; d% s2 Y% G* @
94.        if (hThread == NULL)
    
95.        {
    / y9 C& x4 }! u) m. s" j! a
96.            printf("CreateThread() failed: %d\n", GetLastError());
    ! j- k2 u8 z& m6 h3 \
97.            break;
    
98.        }
    ' E4 \) v4 o! m' w6 X8 u3 u
99.        CloseHandle(hThread);
    4 W- j! X8 w/ e7 P9 ]: C1 ]; [
100.     }
     
101.    closesocket(sListen);
     0 Z1 N6 ^- ~; J, U/ G
102.    
     : V- t; C7 h6 V0 [! O' H. Z
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

, V3 z; z/ L% B/ T

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   1 m6 K4 d1 w) Q: b: [7 J
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   . V/ ~) _; D( h0 c+ i/ q8 m( u" q
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   6 @2 C& k) G+ O8 O
5. 
   
6. Server：
   
7. #include <winsock2.h>
   ; ^2 L& S) W6 K9 z4 x
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   ! P, N7 g$ P8 I0 w
10. #include <stdio.h>
    5 {- t0 \+ W8 N, F0 n4 H
11. void main()
    & y8 r( j$ }( A: ^! ~1 `
12. {
    1 g' [+ \1 a7 s. s
13.     WORD wVersionRequested;//版本号
    2 O( ^$ f! L& R' D$ s
14.     WSADATA wsaData;
    5 H; B! p$ F5 H8 `" @: v3 w
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    * n1 ]8 q6 `4 P
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
    
21.     {
    
22.         return;
    ' k+ p) e+ v( b
23.     }
    
24. 
    0 C+ V- {/ L; c6 r6 a  P( y8 W
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    ) S: {+ f' u! M( z0 E
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    0 j6 \* [- Y( E+ [
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    
30.     {
    
31.         return;
    
32.     }
    
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    3 j- i7 w: X7 _0 |& R
37. 
    
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    
41. 
    6 `  U9 L' v0 j4 j$ u& e
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    0 {) k5 B6 s0 _; G
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    
44.          addrSrv.sin_port = htons(6000);
    + H2 z! m' v+ O- h' @7 a0 [
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    # o& X% S* v2 Q0 g: M3 ?
46. 
    5 p; r. {% u0 @. R1 x* A+ C
47.          //将套接字绑定到一个端口号和本地地址上
    $ E* E$ m& g+ F0 U# l9 z7 U
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    
50.          listen(socSrv, 5);
    , J' z# x: o& [4 Q9 k3 k
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    , q5 [6 U0 \; {. }# e& ]
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    . k2 @0 G: P! J/ P
55. 
    
56.          //循环等待接受客户端发送请求
    
57. 
    ' V% A' a! m' ?  f! `, S1 D
58.          while (1)
    
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    / E# H6 n' d2 S/ E. v( w7 A
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    0 C7 |" S0 `0 Z
63.                    //此时程序在此发生阻塞
    
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    
67.                    char sendBuf[100];
    % Q& _; ^( P3 S& X: A0 X3 a
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    6 D5 h, `( u) q; H; m0 A) R
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    ; v- ]+ X0 m: A( H" W* g
73.                    //用返回的套接字和客户端进行通信
    
74. 
    + G! l; _, l9 v0 y, i3 x
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    ( d3 w1 c0 o7 W
76. 
    
77.                    //接收数据
    3 l  p& k# t5 k- U% ]- o
78. 
    ) N0 D* B9 v( v  n0 c9 W, Q& _
79.                    char recvBuf[100];
    
80. 
    7 u: [, w. g, p6 M7 Q
81.                    recv(sockConn, recvBuf, 100, 0);
    " |% }+ \" x* B4 J8 C
82. 
    " T' `  \, Z4 E7 \$ a& O* }
83.                    printf("%s\n", recvBuf);
    5 G' u! @; t# a6 @
84.                    closesocket(sockConn);
    - X4 |) H; A- O) u4 G9 e0 V
85. 
    
86.          }
    7 z0 P2 u: k/ B, `/ x) }0 a1 F
87. }
    & D  x4 c* `; _4 Z* _" _) T
88. 
    
89. 
    5 O; ]2 L  j& `# G
90. Client：
    
91. 
    9 F3 S2 ]* g1 A' o& e6 p
92. #include <winsock2.H>
    ( T& Z" U7 \* l7 M
93. #pragma comment(lib, "Ws2_32.lib")
    ; t+ j4 U. c" A0 U4 [# L8 @2 r& P
94. #include <stdio.h>
    : R- x% a2 x2 i
95. #include <string.h>
    : {/ r$ H6 s# ?. a7 c+ {" S
96. 
    3 s& y  t) i$ K& h+ m2 u. i
97. void main()
    
98. {   
    : g8 U+ \3 q0 r4 j, T
99.     WORD wVersionRequested;
    9 p2 J8 Z. g1 O- h: j7 z4 M1 J
100.     WSADATA wsaData;
     
101.     int err;
     ; Q* H3 `+ }+ v/ l0 c" R! F
102.      
     / b4 S& Q" @5 U' s4 V1 [$ e' N2 U
103.     wVersionRequested = MAKEWORD( 2, 2 );
     * L% Z) b) q) l. e- l
104.      
     % u" r$ E6 j6 A2 j
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     
107.          
     ) P. ^0 c2 x: i9 }" I7 Y; m
108.         return;
     
109.     }
     $ p, z1 w* b: m' U
110.      
     - q, Y- R, V! ?! a
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     & Y3 u- W9 g9 M7 W+ d: p
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     * w: O1 F' o3 w0 K1 f
115.          
     
116.         WSACleanup( );
     
117.         return;
     
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     . u* @. _! g" `: r; H
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地址
     ; e' q3 X2 y2 x6 b  v* k) b# u/ C
124.      
     ( R6 p' {3 `$ m3 w9 E' ^
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     
126.     char recvBuf[256];
     2 D) q& x* K, n. b/ `! `
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     " R0 l* I* q4 h
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     $ q; c1 i7 O; Q& v  h/ Z
131.     closesocket(socketClient);
     
132.     WSACleanup();
     & H- e# n& ^3 w3 f
133.      
     + i6 ?* E3 }5 d# @$ Y( n$ H
134. }

复制代码