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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
3 J/ Y1 s2 u* y/ d( ]8 b客户端程序：client.cpp
4 |+ O, B) J+ l' S% @- b

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   
7. 
   + T' ^$ _2 t  W
8. char  szServer[128],
   
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    # u/ `- X$ |: b% f  h
11. 
    ' n# k1 b" K2 Z
12. int main()
    
13. {
    4 _0 W  ]$ g/ H" n7 \+ {/ x
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    ( ?$ o5 \: V' I% C' |9 K" R4 q+ W
17.    int          ret;
    
18.     struct sockaddr_in server;
    ( ?, Z$ ]: w9 q1 P( B3 g1 r
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    * h+ }6 ]0 H; r* N- f3 P* G
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    
24.     }
    
25.    printf("Enter a string to send to server:\n");
    2 Z; _4 _' x* B5 a
26.    gets(szMessage);
    4 Y5 F5 a8 c6 S+ C' n7 l, {
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)
    
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
      {- P/ Y6 @7 X6 u6 s' j' I
32.        return 1;
    1 @! w% w0 s4 `
33.     }
    8 ]* A' g% J2 d( V1 S
34.    server.sin_family = AF_INET;
    & j, @4 P# Q/ r' B' I
35.    server.sin_port = htons(iPort);
    
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    9 f/ g5 X0 a5 p7 l6 z. @
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    & V0 X4 z/ ]1 s, i* N
40.     {
    , ^0 g# A) m! B' {
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    
43.     }
    ' G/ m3 p) U$ g! C' A
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    % N  L& {, V# y! i
46.     if (ret == SOCKET_ERROR)
    + v. s6 t# w+ Z4 X- a
47.     {
    ) e- L  f! G) c
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    1 U  E( ^" P* H, D) X
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    
56.        else{
    
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    
60.     }
    . y* v  G, `8 x- u# G% }
61.    closesocket(sClient);
    1 h. j* `5 O3 j& Q" G0 ?
62. 
    9 G+ h$ e2 s" v0 Z/ W, [, t/ K
63.    WSACleanup();
    $ P# ]2 v! M" m; \
64.     return 0;
    7 C$ R: F+ U% [0 }) A
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   # J6 e- o2 z. m: w# [2 o
2. #include <stdio.h>
   2 o  I- M+ c* f$ G- C
3. #include <stdlib.h>
   1 U% I9 P6 d/ n  Y
4. 
   ( A( \1 ]) ^" e' n
5. #define DEFAULT_PORT       5150
   $ r; |7 x& Q4 p3 G0 W8 L! X
6. #define DEFAULT_BUFFER     4096
   " S2 `( n! q# h! G0 w6 `
7. 
   
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   
10. 
    ; w; e! b) q4 C0 B8 e  C3 t
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    & F: z  p$ L3 }+ j; D0 f
14.    char         szBuff[DEFAULT_BUFFER];
    , R4 K; _' @3 ?3 D0 z$ Z
15.    int          ret;
    2 e% Q9 x, j" f8 D; k
16. 
    $ S/ v3 a4 y* m7 v& s9 z
17.    while(1)
    
18.     {
    9 P5 h) T" ~: m6 e" c& N# U  R
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    9 f# ]# Y; q* Y7 W  I8 M  J( O" y* `
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    - s' _8 J0 p' P9 i/ N0 [; {; X& F
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    3 `6 V9 ?3 X! r7 c4 l8 R8 B
25.            break;
    
26.        }
    $ x, |% s8 P+ [9 |
27.        szBuff[ret] = '\0';
    ) g0 w' a% O) t. a+ _
28.        printf("RECV: '%s'\n", szBuff);
    9 E" L0 i2 A5 S  B6 l6 ?% n
29.       if(strcmp(szBuff,"abc")==0){
    0 ?$ {6 a1 \% a1 P/ I! ^* f
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    $ K2 K5 }" }- Q+ c& c5 e  V
32.        else{
    8 b' A, N" x7 [
33.          memcpy(szBuff,"Send the wrong string!",23);
    4 D6 m0 t0 u$ t6 [: A! s# A
34.        }
    , {1 Z6 d" u5 J6 R& ?
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    - J; I' i" @! s1 f+ d& d8 h
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    
39.     }
    
40.     return 0;
    8 U6 S. f) i/ g& J/ j1 G, a( A
41. }
    7 A7 u8 U% ]+ p) r# F; w3 ~" e
42. 
    
43. int main()
    
44. {
    
45.    WSADATA      wsd;
    $ f  `: k" [" y) _
46.    SOCKET       sListen,
    
47.                  sClient;
    
48.    int          iAddrSize;
    1 ]: E8 R6 q6 G* U0 B/ ^( p: }
49.    HANDLE       hThread;
    2 [( a- H" \. h% Z2 W) s; A
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    
52.                       client;
    ' a  A/ f/ H( {6 L7 p
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    
56.        printf("Failed to load Winsock!\n");
    8 J$ t3 s: U1 d& l* `9 x6 A5 O
57.        return 1;
    * {  J% q7 d/ k
58.     }
    4 l# b9 _  C- w2 P4 O7 Z9 s
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    ) |8 n/ B" }5 a: ~
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    & Q- s; b4 w, d# r5 D$ X
64.        return 1;
    
65.     }
    + P9 p' u6 B" d' ?
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    ; |9 o. @  |3 Y) u( {
67.    local.sin_family = AF_INET;
    & E+ L! A+ a% U' j# H1 M; v
68.    local.sin_port = htons(iPort);
    & q& g  @. X6 H: _' f
69. 
    : Y% a" u" o7 i5 V: H2 S5 w
70.     if (bind(sListen, (struct sockaddr *)&local,
    , Q9 ~' s/ v2 W2 c% Y
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    ' _3 |& v5 o# {
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    % O8 F* J9 |% j* ^: j' |, l
75.     }
    ; O5 K$ D8 W, v+ v
76.    listen(sListen, 8);
    3 E7 d1 ~2 B, O$ a6 m& A6 o
77.     // In a continous loop, wait for incoming clients. Once one
    8 _: ^3 f4 h+ w, A, f
78.     // is detected, create a thread and pass the handle off to it.
    
79.     while (1)
    & W# P# W5 j+ h2 n
80.     {
    
81.        iAddrSize = sizeof(client);
    8 I" @& ^6 B. c: m
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
      u$ Y' T) A3 P
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    4 L1 A1 v6 K8 u+ N% O
86.            printf("accept() failed: %d\n", WSAGetLastError());
    * {+ ]2 u! K" I( a8 J4 U# o
87.            break;
    
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    . b' Y# F5 ~, T! E' |* f
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    , i: ]$ Q8 K  N6 n
93.                    (LPVOID)sClient, 0, &dwThreadId);
    ; U4 i% T& P1 C1 m
94.        if (hThread == NULL)
    6 z- ~' s0 W0 |9 O/ \) F
95.        {
    - b8 x1 J3 x* L2 X1 M& [
96.            printf("CreateThread() failed: %d\n", GetLastError());
    2 a, J! t* v) @7 T; _4 t0 O
97.            break;
    
98.        }
    
99.        CloseHandle(hThread);
    ' }- S# w( Y' R2 K
100.     }
     
101.    closesocket(sListen);
     / v/ I( M3 u* {
102.    
     
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

4 u3 _' _/ {' y, g
6 h* r8 |4 S! _3 }/ E$ M4 y9 A
+ N0 l6 r1 g9 t2 m# F% \

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   % z* b7 X: `; s
2. 
   3 |; N9 K  C! l( y/ D7 U0 R
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   * m' _5 K( q: e, m
5. 
   ! x( ?' \5 L4 f& R8 G4 h3 N' w' u
6. Server：
   & F; `5 \5 Q7 b% p3 ]- H
7. #include <winsock2.h>
   ; Q- N, `- [9 t- e2 F
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   9 g. n9 n* g  J
10. #include <stdio.h>
    . U$ t  x' K1 ]; _! {6 k7 K
11. void main()
    ! n0 k  X' l7 `+ O, r* U
12. {
    
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    
15.     int err;
    
16. 
    : Y, B" n6 m+ o  ?8 P4 l) O* j
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    + E3 A6 z7 f4 J( A& [+ l2 S( f9 j* \
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    ; x0 i1 d3 A0 h; j+ U! g; x! m; F5 R
20.     if (err != 0)
    7 ]9 y% d9 z7 z# @8 I1 _; F7 r
21.     {
    
22.         return;
    
23.     }
    
24. 
    ; Z3 F2 E# t6 x! Z) m
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    7 H" w7 n& j% L) n2 y) t
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    : }5 k) ]! i0 h/ y: x: s0 m
28.         HIBYTE(wsaData.wVersion) != 2)
    ' E+ G. J& e) s4 R( z
29.          
    
30.     {
    
31.         return;
    
32.     }
    7 o. A) k( N8 _. U# A2 S9 a$ I
33.      
    ! K) z' B, ?& n$ E
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    " g" i# F! n; q$ s9 P: q
37. 
    3 i1 h9 U) I, _6 C; ?( {" n4 K5 F
38.          //Socket地址结构体的创建
    
39. 
    ( w% {" G+ S4 {/ }' _% Q
40.          SOCKADDR_IN addrSrv;
    
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    " F6 b. S( b8 }  h  T, i0 T
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    * l! M" G. Q8 A0 a* ^) d+ ]
47.          //将套接字绑定到一个端口号和本地地址上
    " ~! a* w: n! \9 C4 ?
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    
50.          listen(socSrv, 5);
    / y& T1 C; p; O4 `( ~, \0 D# f- k
51.          
    , d, L3 y/ _9 ]
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    9 _: D3 L5 g6 ?! r
53. 
    5 M$ o% U6 Q& T# ^
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    
56.          //循环等待接受客户端发送请求
    , x+ O: u% k% ^  P3 H+ ~: K
57. 
    7 N0 V, l/ o2 o
58.          while (1)
    
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    8 [' |) w1 A9 k4 ]( R& b+ N1 T
63.                    //此时程序在此发生阻塞
    4 l: ?- t1 x1 Z: s+ g; N7 U5 m2 E) s
64. 
    0 [, M8 d/ U" `4 n' ]1 I3 @, V
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    
67.                    char sendBuf[100];
    7 f1 u& E6 j6 K
68. 
      @2 B' x* Q2 @$ \  a
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    . `2 Z- A! W1 Q- B% K: c
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    : {$ n1 d9 M5 ?9 E5 y
72. 
    , Z4 n3 V6 C9 G6 q2 |9 v
73.                    //用返回的套接字和客户端进行通信
    8 ]4 g: ]6 |$ I- O; m
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    
77.                    //接收数据
    " `, Z" A7 _5 Q( I, z7 i- ]
78. 
    
79.                    char recvBuf[100];
    
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    
83.                    printf("%s\n", recvBuf);
    8 D1 r% ~+ x8 G) {1 N$ {6 j- z5 q+ O
84.                    closesocket(sockConn);
    
85. 
    
86.          }
    # f* ?( z" H; b: l) k5 h7 Q" J' D" J
87. }
    
88. 
    ! s. E! N1 |2 p& e+ P* y/ u* |
89. 
    
90. Client：
    % S& x  L" K4 k6 F& b
91. 
    + }8 A) B6 C) X( r' [2 v5 d
92. #include <winsock2.H>
    " {3 l1 w3 K1 g
93. #pragma comment(lib, "Ws2_32.lib")
    ' f+ C3 B4 q0 ^% [- o
94. #include <stdio.h>
    
95. #include <string.h>
    ) J6 ?3 Z0 ]4 |: m" T, M& q2 r: D
96. 
    5 V' j2 K( q' ~  p6 a
97. void main()
    
98. {   
    . B0 z, ?5 X+ k; N& h! E6 w5 e) p
99.     WORD wVersionRequested;
    ( n# l1 z. `7 W' \0 s$ k) J" p
100.     WSADATA wsaData;
     
101.     int err;
     : }, F1 L) F6 r4 k# v& f. w7 D1 J
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     ; b. y8 F# b) Y& V$ U& O$ i+ j
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     ' w( D8 e: n- c9 i) W
107.          
     
108.         return;
     
109.     }
     : u) O* `; f: X
110.      
     
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     
115.          
     8 p9 d" U; o1 x# K& ]
116.         WSACleanup( );
     
117.         return;
     3 P, \* W+ [. ~& f7 B5 ?7 o
118.     }
     0 P, s8 z' T0 T4 e
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     7 W+ K; z$ F& J+ a4 N  t& C1 i
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     + o0 j, c- E: ?- D* D7 U
122.     addrSrv.sin_port = htons(6000);
     7 T" p& o0 e  r
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     - F% k0 y, T! c4 U, B3 j3 J  _
126.     char recvBuf[256];
     ( t4 R& V  Q8 O: g. H" `$ z4 F, Q7 S
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     ! |, p, a5 [1 f8 I2 l9 c
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     + i' L6 g: i- n! X4 C; ^3 l7 A
132.     WSACleanup();
     & L  d8 G1 C- z  \& |: M0 q" P3 j: p
133.      
     
134. }

复制代码

5 z* T" A  _' a" V6 z