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

admin

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

1. #include <winsock2.h>
   
2. #include <stdio.h>
   4 d$ E0 m  p) L4 C' D' C. ~; ?
3. #include <stdlib.h>
   
4. 
   ) @6 o, B2 A2 S
5. #define DEFAULT_PORT       5150
   2 i) O1 r3 D1 u3 I: N+ T
6. #define DEFAULT_BUFFER     2048
   
7. 
   
8. char  szServer[128],
   0 m( A& }0 G9 m/ J
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    , t* o5 R: Q* ]6 z: \* l% g
11. 
    ; i* U) S8 b4 J& |% z9 E, H5 e: T
12. int main()
    ) z! a2 w; r; S" `
13. {
    1 I: a: W8 [7 W/ z- T! s
14.    WSADATA      wsd;
    6 P2 r" P6 f( i* r9 p
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    5 r: T- Z; J- c  U1 R
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    
24.     }
    
25.    printf("Enter a string to send to server:\n");
    - G$ M5 d) Y: S, [" ^
26.    gets(szMessage);
    
27.     // Create the socket, and attempt to connect to the server
    
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    7 @# }( H9 t5 u; x
29.     if (sClient == INVALID_SOCKET)
    
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    4 U6 x9 k! D, K9 J. m/ J2 p
33.     }
    : v, i% [7 H& u8 U! {2 J2 t
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    & `4 h  V" f# F. h/ \
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    " P0 X$ v' B% \% A0 j. O) n
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    * a# Y. E& h! l6 l9 @0 g
39.        sizeof(server)) == SOCKET_ERROR)
    6 p8 c9 v$ N$ d% d2 z( H2 h
40.     {
    " H2 X% {' E. S$ }" I+ R' u) B
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    0 E/ ?, ]' A; h
43.     }
    
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    . c4 o5 U5 J6 j: T
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    8 ]9 W# t9 p  @0 o6 Y3 f
53.        if (ret == SOCKET_ERROR){
    * X5 t2 n$ ?; n
54.          printf("recv() failed: %d\n", WSAGetLastError());
    % @. I9 a: ~  _; a9 C* z
55.        }
    
56.        else{
    , {/ |5 ]& e7 r; M: G+ k
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    
60.     }
    
61.    closesocket(sClient);
    
62. 
    - J( Y# J. A: b6 A4 k: G' I
63.    WSACleanup();
    9 \/ ?" W6 G$ n& q5 q/ w
64.     return 0;
    ; c. O" a3 d, x$ O1 @! U
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   4 K, O* M* `9 y1 }0 q
2. #include <stdio.h>
   6 n, g# U1 e3 f) P
3. #include <stdlib.h>
   " H, r  A& l4 G
4. 
   * n8 ^( I0 D! y
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     4096
   3 ^( I% Q( W" q
7. 
   
8. int   iPort     = DEFAULT_PORT;
   3 M# n" [1 y  y: c! `: m& }
9. char   szAddress[128];
   
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    
16. 
    ! o! F; Y' O1 f
17.    while(1)
    : E" w. R2 r( I) V' L
18.     {
    5 a! q4 }8 _! C) W! i7 u, y
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
      d# n* i; E5 a  T8 |' t
20.        if (ret == 0)
    
21.            break;
    6 S+ P4 e- E  @
22.        else if (ret == SOCKET_ERROR)
    8 a; r% W- B# ?) ?; k
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    & J1 _0 ^2 D& e9 r/ P
26.        }
    1 i2 I3 m. e9 @" y) J
27.        szBuff[ret] = '\0';
    - F+ n: t3 f6 n" _2 b- @
28.        printf("RECV: '%s'\n", szBuff);
    + L& z& H7 {$ a5 F9 _8 A
29.       if(strcmp(szBuff,"abc")==0){
    6 r! y4 I7 {. ^4 d( L
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    ) Q- p% Q& B/ d
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    
39.     }
    ' l  W/ X# A& Q$ P( j* v
40.     return 0;
    
41. }
    
42. 
    
43. int main()
    * K$ q3 @1 n- W. I! e9 {( t, w+ c
44. {
    
45.    WSADATA      wsd;
    # N8 h% C6 A1 ~+ }
46.    SOCKET       sListen,
    # w' Y# S, f5 r
47.                  sClient;
      h/ v9 J9 G# `: d7 P- Q. e6 i; X
48.    int          iAddrSize;
    . v" Q" ]) v# x5 [" s) j. [1 g
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    4 {; i  ^: h, W* ^
52.                       client;
    
53. 
    3 @3 |( ^& e. Y0 G1 V& W( p
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    * \( H$ i4 y: u- y0 {
55.     {
    & L: |4 [! C% c  ^+ ?0 J
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    * |% e  y8 Y' i! I9 A4 N# H4 d1 q
58.     }
    * @+ B' N9 B$ P1 R0 K
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    ! d) G) Y" v  x9 Y& l) ~) t# O7 x
61.     if (sListen == SOCKET_ERROR)
    - d) s5 L& t% s) I2 K
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    0 m8 A* u6 Y8 A, t( B4 [
64.        return 1;
    
65.     }
    / _  ~8 e/ U2 q5 g3 O, m% l6 P
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    7 q5 i; f* m8 V0 ?
67.    local.sin_family = AF_INET;
    # f2 r$ i) U5 k; H
68.    local.sin_port = htons(iPort);
    
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    5 y9 k' Z& r( ^) G1 V
71.            sizeof(local)) == SOCKET_ERROR)
    * Z. G* Q4 u8 e' A4 _: X
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
      I6 T- Q; I% q
74.        return 1;
    
75.     }
    * _1 }% r+ q% n/ C! T
76.    listen(sListen, 8);
    
77.     // In a continous loop, wait for incoming clients. Once one
    
78.     // is detected, create a thread and pass the handle off to it.
    
79.     while (1)
    
80.     {
    1 p: V& K$ [; l5 P
81.        iAddrSize = sizeof(client);
      S1 k$ w8 ~+ J2 E5 g( H
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    8 P: q0 o' }- v" R* S! D  ^
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    
88.        }
    # S7 S: [5 Z3 J; G5 D$ `- s
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    8 u+ g. x  |9 F, ]
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    4 Y- ~, F# M$ r1 J& d8 ~$ _" A& u3 \
94.        if (hThread == NULL)
    & f& I. j$ h3 U% L& N
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    5 O8 r5 e+ I& ?$ g/ e
97.            break;
    
98.        }
    ; I1 q) {: g( G+ r' f/ T
99.        CloseHandle(hThread);
    
100.     }
     * W- k6 `9 Z" O
101.    closesocket(sListen);
     
102.    
     
103.    WSACleanup();
     : n( \' y: N, O: O" y7 \4 `
104.     return 0;
     ' Q$ e+ _7 g0 A! j
105. }

复制代码

, b, P: k- G& A2 T3 k7 Q

: E1 Z" Z& h7 ?2 K% e

5 z: }! {7 ^0 y+ u& k3 K

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   ( M3 f$ _/ _+ {" R2 h
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   + t. x& G: n6 S9 D8 h
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   5 E  @0 Z( D. u0 ?* S& M  x
5. 
   ) G2 c3 {) ^$ K# _2 ], k% w
6. Server：
   4 F4 j! H4 q) A9 x' x* K/ ]
7. #include <winsock2.h>
   . t( L8 k- ]) E# _4 p3 r
8. #pragma comment(lib, "WS2_32.lib")
   5 x4 Z7 W% R5 Z( o2 ]
9. 
   
10. #include <stdio.h>
    
11. void main()
    ' d/ ?3 T  G: }! ]3 q
12. {
    
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    4 c2 q& c: X' G* t
19.     err = WSAStartup(wVersionRequested, &wsaData);
    2 ]+ s: h" @& x' |. M
20.     if (err != 0)
    3 x% c" L$ B8 x& t) n0 V& U
21.     {
    $ }1 ^# \- T- y4 T2 R
22.         return;
    
23.     }
    1 p- d. g$ X5 ?
24. 
    , {! P4 T! p7 {7 e) _
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    ) A: }$ ^8 ~: T0 L. A9 G
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    8 Q1 [  u  ~7 K5 R% L1 _6 C6 I
29.          
    
30.     {
    6 S: w* s4 D! m9 T% D+ R
31.         return;
    2 O( f4 v. i: T4 J8 ?( m6 }
32.     }
    1 D5 a; z* d4 J; j2 E" b1 ?, v
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    * h: ~; ~3 s# T  I! ]3 [" T
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    / q7 ~2 ^+ Q6 E  i3 P# p  _) Z6 E4 p
37. 
    7 z7 }  n, Q& g6 u. [8 R
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    
41. 
    - L* N) C& ~) Z; |
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    9 t; M( j6 R# I; J) a6 T
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    ( m, ~0 ~. H: i# V
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    / \2 O8 ]  e' R- n* y: V
47.          //将套接字绑定到一个端口号和本地地址上
    3 |' _9 o; O  Z& f# j7 |
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    3 U4 X4 C4 s% `8 k5 |
50.          listen(socSrv, 5);
    
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    
56.          //循环等待接受客户端发送请求
    ( i, G& p9 N  C) d
57. 
    . O5 ~; C. Y) ^! ?
58.          while (1)
    5 y  J0 \; f* ^& ~8 o$ W3 g
59.          {
    8 X" Y- J9 X' m8 m: u( [; y+ M
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    0 W0 a- I# V  q+ O1 `/ p
61. 
    ; c: x, F! X5 a
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    & n: S7 r& W7 @3 M4 f$ k" Y+ g
64. 
    4 P" f7 b/ [8 W
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    1 b% z: w- r' u) _! w, c) N7 x6 V
66. 
    ! p  N5 L$ v) q! L  A7 q
67.                    char sendBuf[100];
    2 [- U& I. y1 L
68. 
    : W9 r5 j4 Q/ ^: J
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    ' a: W3 _  z# M" G% W5 N
73.                    //用返回的套接字和客户端进行通信
    
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    0 r$ M& z1 F& u
76. 
    / _: r; J$ J9 v$ Q1 w  p$ S; u6 R
77.                    //接收数据
    
78. 
    : ~/ z3 `" ?0 I/ _/ B: z
79.                    char recvBuf[100];
    
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    ( w( T2 K: J6 O# j  Q
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    8 z% X% u0 y/ y( e: l( ^, z3 b5 }
85. 
    
86.          }
    
87. }
    2 S; Q1 c- ~* \! p) T0 k, X
88. 
    7 H1 Y, ?! N0 x' d; \
89. 
    
90. Client：
    
91. 
    ( h% e+ k. K  i) i. ?7 n
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    
95. #include <string.h>
    
96. 
    
97. void main()
    
98. {   
    
99.     WORD wVersionRequested;
    8 j- K! d9 U5 h3 [9 G# [( O
100.     WSADATA wsaData;
     / A) U! I3 ^2 R6 W8 B
101.     int err;
     
102.      
     % K: L% {: H7 O  H: p$ Z- B1 D
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
       h$ y8 k* A5 \# R  s
106.     if ( err != 0 ) {
     % m4 g" \" k- v+ w- O; b5 N
107.          
     ) o5 _2 v# H1 Q9 e
108.         return;
     
109.     }
     
110.      
     
111.      
     ; F+ Z3 X1 _* j4 G8 o7 N
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     5 S, N: |9 X" c- ]4 v
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
       W/ }- Q* a- ~2 u5 }* _. x
115.          
     ' L: j/ R- t& W& B+ \7 u
116.         WSACleanup( );
       m1 F) F% A! r4 l5 j  `: F
117.         return;
     
118.     }
     0 l: t" X! ~! x' f, Q$ D
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     3 O: v+ I3 u' Z2 O8 ?5 w9 K& }
122.     addrSrv.sin_port = htons(6000);
     
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     ( z8 p4 i# |% y4 v4 A
124.      
     ' T# _" I4 \! ]+ R
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     : D: j! v) x1 |2 Z8 C
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     4 P* P( k; o& q9 p$ h* h
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     + a* M, i: G4 R) @
131.     closesocket(socketClient);
     
132.     WSACleanup();
     
133.      
     
134. }

复制代码