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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
0 n$ o! D$ h- m# o$ C( l客户端程序：client.cpp
  N  u3 A2 i- |# E! O

1. #include <winsock2.h>
   - e, L! M0 @# Y2 T# {, |3 O, p
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   * j3 ~4 U. ^/ f1 E* o  P; X! F1 ~' K
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   6 E: t" y5 D) e# |0 A: `7 L
7. 
   
8. char  szServer[128],
     D4 t( A$ n4 ?5 G) B) T
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    / x+ F7 ^( L* c0 }/ G# z
11. 
    : J- u9 m" ?* C. y( v
12. int main()
    ! f# C. u' B2 B3 w
13. {
    
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    / D6 T' p. i& d5 _
17.    int          ret;
    
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
      j, x2 |( d8 `, d1 F1 R. g% `
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    ) t0 j4 }4 q0 A* i% X5 g
24.     }
    7 @- F2 N( k2 K  q
25.    printf("Enter a string to send to server:\n");
    7 S7 ~- b  I' c& y
26.    gets(szMessage);
    
27.     // Create the socket, and attempt to connect to the server
    
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
29.     if (sClient == INVALID_SOCKET)
    / C0 y1 D6 c+ F: {; Z# C
30.     {
    - H6 q  |- @9 l
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    
33.     }
    4 c$ \. ^2 P% X$ W; P8 W
34.    server.sin_family = AF_INET;
    & r! b, S  @0 T& {# `. |
35.    server.sin_port = htons(iPort);
    8 h" i7 T6 t. ?5 ^0 i4 \9 V" @
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    - [6 b: n/ w1 U
39.        sizeof(server)) == SOCKET_ERROR)
    3 H% e5 q* Y0 }- d& |8 G
40.     {
    - ^' X* N3 t& {
41.        printf("connect() failed: %d\n", WSAGetLastError());
    - \2 d' z; g+ W
42.        return 1;
    
43.     }
    . W5 p% B. Y" |  ]' z% n+ Y
44.     // Send and receive data
    ) S8 A* X- a: u% D% t! y/ ?
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    ' O, b# C' |' M
46.     if (ret == SOCKET_ERROR)
    
47.     {
    5 h7 @9 B% L& N2 X
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    $ `5 j. u1 c" ?0 k% h
50.     else{
    9 d- |. U  {' `& |" V
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    
56.        else{
    / Q  d& o0 y  k: p$ ~
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    " j7 k# f4 a: T( ]! \7 b
59.        }
    7 a( g- y* K  m" {: k" Y7 |* h
60.     }
    
61.    closesocket(sClient);
    : V0 |# E5 X  p- w. Y: ?
62. 
    7 g# j$ _, ]' d. F& X
63.    WSACleanup();
    ( k, e% a. E3 {- ~% R6 q8 F2 ^
64.     return 0;
    
65. }

复制代码

服务器程序:server.cpp
4 o. w* ^9 Z7 `, k! v( x- i

1. #include <winsock2.h>
   
2. #include <stdio.h>
   # ]' @" J. K6 i
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
     _: @3 ]  O% y* ^7 K. J9 s* E( o
6. #define DEFAULT_BUFFER     4096
   , j6 U! X& o3 M% [6 w8 f
7. 
   
8. int   iPort     = DEFAULT_PORT;
   ( k2 c" J) s" ~, p# a0 v
9. char   szAddress[128];
   5 I' j- h  C8 t* T
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    ' v9 q- @1 r/ ^7 E8 u  Y
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    6 ]+ o; m6 y7 v" o" ]- V/ y6 p
16. 
    - X. ~% [: H: k9 i9 R
17.    while(1)
    , B4 x1 V- [; k- P4 Q( Q, {
18.     {
    9 y( }* R5 d5 @5 ]0 E, @
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    $ |# _8 K2 D7 j2 d/ l- M% E
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    ) L. x  N- g7 E8 b. X
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    
26.        }
    : C1 n4 E$ p! l, m
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    % _8 C& Z" \( @$ k! m" y5 E& B: F' D
29.       if(strcmp(szBuff,"abc")==0){
    " v9 V6 ]1 D# e( _2 R+ k
30.          memcpy(szBuff,"Send the correct string!",25);
    ) x0 q; {& c' V0 b6 Y' r' J6 W
31.        }
    
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    $ p1 E" k& S' x; K3 r
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    & E* S1 j3 D8 u
39.     }
    ! v) \2 U; }9 b; T8 E1 U1 D
40.     return 0;
    
41. }
    
42. 
    2 V9 y2 V0 J9 _0 ^
43. int main()
    ( l+ E: B% |  P
44. {
    
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    - T# j1 u& _  J+ F) _; h" k. O
47.                  sClient;
    
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    
52.                       client;
    3 S; |6 K8 n1 l9 B+ w
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    0 D2 w# S2 B$ ?0 u7 u8 F+ ?0 V! |, B
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    " @% z2 b$ W/ ]) d, M
58.     }
    
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    2 d) d+ Y$ o+ X
62.     {
    ' K( R- _$ l4 m8 U0 d* e
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    
65.     }
    1 [1 e( h0 Q( @" @% c! Y
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    ! A7 M4 ^2 E0 B9 S, z  {1 @/ Z) N3 m
67.    local.sin_family = AF_INET;
    : n# p8 W1 \) F' ^
68.    local.sin_port = htons(iPort);
    5 m$ U5 F' ]2 V! y& k% H
69. 
    : z) R- Q& q( B, p) C/ ?
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    * V6 v  X3 D9 Z% `6 H. ]
72.     {
    * X9 n. B0 `7 L) y1 A% U) B+ ]. ]. I
73.        printf("bind() failed: %d\n", WSAGetLastError());
    " {" n. G, o4 D/ }, D
74.        return 1;
    " m' K1 c, l. x6 U/ O" S' t* g
75.     }
    
76.    listen(sListen, 8);
    ( W) N4 p3 v. {( g, s% g; x/ v; B
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)
    4 K/ P- `! X0 d" x6 s
80.     {
    # L: U- U" j& m* y0 T
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    " b; w9 `- s$ \9 E' D" j# R4 N* ~! p
84.        if (sClient == INVALID_SOCKET)
    : }5 z/ L5 T& e. x3 a/ J0 D6 u* T/ c
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    ; ~! D+ w0 u# ?
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    0 c. |, j) j& @( a
92.        hThread = CreateThread(NULL, 0, ClientThread,
    8 _! a6 N  |. v
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    4 z; b% Q/ G9 S2 t
98.        }
    4 `2 r2 c$ I( C
99.        CloseHandle(hThread);
    2 D' b1 a0 K! y0 p
100.     }
     8 J: K# ~4 w2 e7 h4 m0 b: A
101.    closesocket(sListen);
     
102.    
     - T% r8 y% t0 Q) U9 [
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

2 [* T# i8 S% Q
  n$ {4 K# I, h* C& P
, m, S; @6 k* L2 X* j$ _$ V% d* K
. i& U! K. y. Q) [* I9 N
! Z8 H/ @! r/ h9 e/ v6 ]  T

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   2 ]& ^5 w3 O) d$ W+ Y
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   3 \* x2 A# \9 `" }! Z% O
5. 
   
6. Server：
   
7. #include <winsock2.h>
   $ |  i4 ^6 G" I. R: q; T9 k# d
8. #pragma comment(lib, "WS2_32.lib")
   ( I% A" _4 q. N, _
9. 
   $ W. e# ]- Y: Y# N
10. #include <stdio.h>
    2 k$ w+ t0 y' `
11. void main()
    - A  U/ z$ B7 C+ O9 G4 A
12. {
    ) m( o8 \, J! {. {: \' F9 N- k8 G
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    & z4 V! n# F9 Q; u4 G- q
15.     int err;
    $ ?2 w% I9 w4 O% x: k' y" @
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    ' f6 r) K6 `* j, O
18.     //加载套接字库,如果失败返回
    $ M5 p2 q3 {; L2 e) T' B
19.     err = WSAStartup(wVersionRequested, &wsaData);
    4 X0 P2 y6 i( ]0 n; D
20.     if (err != 0)
    4 y) E1 \: q* O5 V- @
21.     {
    , Y" E3 ]' f6 S  j+ R
22.         return;
    
23.     }
    
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    ; y5 @/ R/ N$ `+ U/ D# d
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    $ B( |1 ?4 K8 Z: `+ O
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    
30.     {
    
31.         return;
    
32.     }
    9 P1 v/ O' S' S; R
33.      
      N4 i- c" W+ }1 e+ ?( ?
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    # }; O: _/ k- c
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    8 i, V8 f9 G+ P
37. 
    8 M' A8 Y+ @) m, m
38.          //Socket地址结构体的创建
    
39. 
    - c$ W9 `9 J) z; h" ~
40.          SOCKADDR_IN addrSrv;
    / }! u8 {, X3 Y7 P2 |. V
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    ! {  L+ b& _4 v: q. H# J
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    - P* |6 E# L. |2 n+ o
44.          addrSrv.sin_port = htons(6000);
    5 P: x. h* X  W9 Q5 Y
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    6 ?( B+ `0 q6 o5 I" N
46. 
    ' ^+ g/ Z7 }+ P$ T! l* I8 i
47.          //将套接字绑定到一个端口号和本地地址上
    0 Z+ i3 t8 X; M7 v# ~3 z
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    3 e; q: z: @$ L1 m+ }
49. 
    
50.          listen(socSrv, 5);
    
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    / f# E/ S6 A- o0 C
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    & b' t' W, v, a' Y
55. 
    
56.          //循环等待接受客户端发送请求
    0 m1 b! G3 r) Y8 h2 U
57. 
    ; D: M2 S3 r0 n% D0 y
58.          while (1)
    & g8 @/ _( D' [: \; ]
59.          {
    1 ?2 |3 j& |( L6 H! U% N5 s
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    # s! K7 q1 t. L) G$ e
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    
64. 
    / h* |& M9 Y$ Y
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    . X+ R6 F4 S$ X) z- [' i
66. 
    . m1 L. G6 w# i: g
67.                    char sendBuf[100];
    
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    ; p1 {5 B0 i  E/ K; o8 E
73.                    //用返回的套接字和客户端进行通信
    
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    3 G2 T' R0 i& L. m" j/ }
76. 
    
77.                    //接收数据
    " P9 X1 e! q0 _) ]( j0 W
78. 
    $ f' j& |* }# [
79.                    char recvBuf[100];
    * I, V- p3 B2 U4 A& m8 C; |
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    + |( p% b2 S& _/ b7 A! n
82. 
    + }' W0 g* ^1 P/ Y+ X. `; n
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    8 S) m. d9 T; |1 t. R+ t: K
85. 
    
86.          }
    
87. }
    * |" ~1 M) x# b8 j  S
88. 
    ! g8 y2 D$ I& j9 w- @
89. 
    
90. Client：
    
91. 
    % V  q/ V! [9 w
92. #include <winsock2.H>
    " ~, u1 g; r: ^* ?5 ^; @
93. #pragma comment(lib, "Ws2_32.lib")
    9 r8 N3 W$ a1 c( K( Z+ j# O1 h
94. #include <stdio.h>
    
95. #include <string.h>
    & R4 `: }( Q: K  ~6 A
96. 
    
97. void main()
    9 W( b  C+ x% s- m: u6 G- o. B
98. {   
    
99.     WORD wVersionRequested;
    5 Y$ L0 R5 w  f8 h: l6 a' h
100.     WSADATA wsaData;
     * t) t& p# g3 t6 I* t- o7 x
101.     int err;
     
102.      
     ! ~' ]) ^+ F: Z2 ?
103.     wVersionRequested = MAKEWORD( 2, 2 );
     ; ^8 g' p; p# O/ W
104.      
     6 `5 i8 W; g$ \  T
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     
107.          
     3 c! U& w+ ?! G# R% W
108.         return;
     
109.     }
     3 ]3 V$ ?3 T: s  x2 B+ d
110.      
     
111.      
     0 F) J" ^4 G) ~+ d
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     
115.          
     : c9 j( K& w# |, B1 {- G, U4 C5 m
116.         WSACleanup( );
     : z: }$ A' T! J$ |
117.         return;
     
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     6 b* D! t8 S5 `- W5 U4 [5 k9 ]
120.     SOCKADDR_IN addrSrv;
     3 J7 q$ [9 [1 `1 L! }
121.     addrSrv.sin_family = AF_INET;
     : u2 m0 f# m. ]0 Y) _+ ]$ W
122.     addrSrv.sin_port = htons(6000);
     
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     % H! e; U( T* u) G% x- f
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     5 X, m2 u) Q! B! A3 ^
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     + ~' m4 Y/ K9 q( L) }  p" w% x
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     & W( Q: h( f  |; p
131.     closesocket(socketClient);
     
132.     WSACleanup();
     
133.      
     , H) o) R: I/ _- }- I
134. }

复制代码

- C  ~% [8 q$ F+ }