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

admin

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

1. #include <winsock2.h>
   
2. #include <stdio.h>
   . Z% t; x# e( j' O% L/ ]
3. #include <stdlib.h>
   ' n2 {& J/ L) [- T/ E6 x
4. 
   " [8 b2 ^: b8 `, O
5. #define DEFAULT_PORT       5150
   # Q0 q' Y; }4 @1 f
6. #define DEFAULT_BUFFER     2048
   : Y8 o: x0 e7 S; n+ M4 K3 K
7. 
   ! Z6 F* _- H" G9 }' ^/ A+ D
8. char  szServer[128],
   7 }0 p9 _* J4 l% ]  A& r# U
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    
11. 
    
12. int main()
    
13. {
    
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    % _1 `3 k  z8 ?# R3 w0 \: P- {* U
18.     struct sockaddr_in server;
    . b( X( X0 G* w, \
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    : B2 U# U- G* P( {0 c& k3 m& O" d
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    6 |" Q" C! g# [/ [0 \4 G! ?
24.     }
    
25.    printf("Enter a string to send to server:\n");
    7 }- r! I/ g; Q0 t  h% I! e5 h
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)
    ( t7 i2 A4 P" O& Q5 M
30.     {
    4 j7 D' }! Q1 D9 h! Y6 ^& u. U5 o
31.        printf("socket() failed: %d\n", WSAGetLastError());
    9 K. e0 I. Q: Z  @
32.        return 1;
    * L) C$ Y' s$ X
33.     }
    
34.    server.sin_family = AF_INET;
    # j5 q1 o) y+ t5 J/ n
35.    server.sin_port = htons(iPort);
    " Q) p/ o% v4 ?* {- T) D6 w
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    ! s7 O/ N# ?6 K( C( h+ o
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    , y4 h1 A0 ^+ D! Q* P* B) k
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    ' `2 y# A1 w% L+ q8 a
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    % p& E& g( t% j3 V% Z, S
43.     }
    
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    $ l. C" T. o+ e( r9 y
46.     if (ret == SOCKET_ERROR)
    ' n) B' l3 ]# T/ [
47.     {
    " t7 X' P  \& Z1 d: x
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
    + U; K' u8 w* h& C
54.          printf("recv() failed: %d\n", WSAGetLastError());
    8 Y$ v6 m) @$ n8 U
55.        }
    
56.        else{
    2 E$ p% {6 b) w/ _4 y' e' {
57.          szBuffer[ret] = '\0';
    ( I  O  e9 q; J+ d( {- D# M) q$ ]
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    
60.     }
    
61.    closesocket(sClient);
    4 \7 l0 j3 e. y7 d# A
62. 
    
63.    WSACleanup();
    ! T( ~% |  M$ U- z5 r
64.     return 0;
    ) g3 h! ]0 V; q* {# C
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
     l: Q! J! B( L" z$ E( h+ Y
2. #include <stdio.h>
   ' f* Z# M8 K, G. q0 |
3. #include <stdlib.h>
   * e4 q& z8 J7 b
4. 
   * J$ _# R! A" Z! b5 X
5. #define DEFAULT_PORT       5150
   + ]' a" }2 P  r1 ^5 f  t4 g6 C
6. #define DEFAULT_BUFFER     4096
   
7. 
   
8. int   iPort     = DEFAULT_PORT;
   ) m; s; v  t) _- @) Q$ {% B
9. char   szAddress[128];
   : l1 |, W, {( {5 i9 B9 O' z" m
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    $ m: {, V  S+ ?
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    2 Z+ f6 }; S/ H% s
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    ! l! ?: ~8 V9 d+ w4 j8 t  r
16. 
    
17.    while(1)
    
18.     {
    
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    
21.            break;
    . Y7 B1 J9 y/ |* ^( ^& u9 |
22.        else if (ret == SOCKET_ERROR)
    ; I: y0 c# P$ `5 z3 Y( n
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    4 U* l( j; ^0 m$ \& z
26.        }
    
27.        szBuff[ret] = '\0';
    9 z) c2 E  O# b' [
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    - {2 X' y5 t8 N
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    ( v3 X% R/ P' E
32.        else{
    9 L! B0 i% s* _, M: K' V- m9 C1 F
33.          memcpy(szBuff,"Send the wrong string!",23);
    # P9 P) y9 {: a2 w4 J1 z9 {
34.        }
    ; r. _. v2 z: }' s7 r. q% F$ \2 Q
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    / A1 V' @6 |* i5 g5 g7 [7 Q
36.        if (ret == SOCKET_ERROR){
    7 U! j) R0 y( i5 o+ o
37.          printf("send() failed: %d\n", WSAGetLastError());
    % ]/ z8 J' C( U4 r( l$ h$ `1 f
38.        }
    . @: A; b* Y# Y8 c- d# j
39.     }
    
40.     return 0;
    
41. }
    ! Q1 z  ]2 T8 m" H2 `$ E! z" a& l/ S
42. 
    / `' o8 Z6 J1 A7 ]6 a' s- X  d
43. int main()
    
44. {
    + C; ]5 L& H5 \; d2 {& I* Q) j
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    # e4 K, J* |- o( q5 S3 o7 ]4 o
48.    int          iAddrSize;
    3 @) a, M2 t0 F7 {+ J% q
49.    HANDLE       hThread;
    ; x# [3 `3 h7 o7 N  C  Z
50.    DWORD        dwThreadId;
    % r! Y& e$ F' _3 U/ l  X/ C" F
51.     struct sockaddr_in local,
    0 d' s+ i' e5 g) T5 t5 P3 x# {$ S" D
52.                       client;
    
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    : ~' S% H# o6 m
56.        printf("Failed to load Winsock!\n");
    9 V& R, @; N& U5 |
57.        return 1;
    
58.     }
    
59.     // Create our listening socket
    ( E* B1 M' C; W# E0 l* Q: D
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    # F8 \5 e& |; {2 y3 H( V. o5 ?
62.     {
    3 x8 G' c9 J3 G/ ^$ j8 B
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    
65.     }
      b4 m0 D. y# m' x. @3 ]
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    8 I5 ^' m+ V% U' b# t
68.    local.sin_port = htons(iPort);
    
69. 
    - n' ~& }; i! W' K: n# T, B+ r
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    / B. g# g6 Z4 }4 V" A: j5 @7 x
72.     {
    7 d% H7 k/ Y% U% o
73.        printf("bind() failed: %d\n", WSAGetLastError());
    ; b- v# a' L) z
74.        return 1;
    
75.     }
    
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.
    1 B/ @7 ?# E! ?; r
79.     while (1)
    
80.     {
    
81.        iAddrSize = sizeof(client);
    : I2 i4 _) Y6 b, A! o1 K
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    ! W% h* D' Y' w  |9 i8 z) p- l4 v
84.        if (sClient == INVALID_SOCKET)
    & p4 A% O- W; n& P" y  Y
85.        {      
    ; D0 A4 g( M  }' j# S
86.            printf("accept() failed: %d\n", WSAGetLastError());
    9 D- P' B: a" [1 K# ?% u* Z
87.            break;
    " M+ |$ r$ O; o' }% m) m  g9 Z1 X
88.        }
    . X! F  D/ X# k7 ^/ i5 T' a% `; B0 u
89.        printf("Accepted client: %s:%d\n",
    * z8 g+ |$ O1 C! O# y: U. L0 u8 g
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    ' c3 ?) h" |' |/ k  r$ b
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    3 ^4 I5 O, D: A; [
95.        {
    # ?( ]( s  l# n
96.            printf("CreateThread() failed: %d\n", GetLastError());
    : I% R/ N' Z: Q' l8 O7 v) G$ H" l
97.            break;
    - p' I, b0 m/ O# ^
98.        }
    
99.        CloseHandle(hThread);
    
100.     }
     % v: x& I2 N, ]% F
101.    closesocket(sListen);
     * S  x' g; c/ Y+ u& ~7 y
102.    
     ' F, E. m5 n+ ?( m! z& f5 R0 F2 R
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

: |- e& X# H8 c' Z% u


& x  p1 D  u! C; y% y$ s

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   * Y* B& o' l1 C& U: @; r: e. v
2. 
   2 q# P# Z& D7 s! p7 J7 K4 U( p' ~
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   4 `1 ]6 {/ G2 |0 l4 d; }2 X
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   
6. Server：
   
7. #include <winsock2.h>
   9 D# v- f+ U2 }2 c$ g
8. #pragma comment(lib, "WS2_32.lib")
   2 ^: K7 D# Y0 q6 T0 ^$ c; W
9. 
   $ t% ~# k* T. R% a) Z# y
10. #include <stdio.h>
    * Y2 l8 l: C" s! K6 W
11. void main()
    
12. {
    
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    # c5 t. ~* y5 }- c
15.     int err;
    
16. 
    ' k- J+ p* g! b+ K+ I+ p& l: G
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    # j/ z; y  m: [2 Z. U/ c/ }
19.     err = WSAStartup(wVersionRequested, &wsaData);
    . P/ U( @- r- ?. q
20.     if (err != 0)
    1 \+ ~0 x+ F8 g6 l  G
21.     {
    
22.         return;
    
23.     }
    
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    1 }, R( w, u3 ^# U% _; i4 ]
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    6 f6 d0 _9 ~6 a) {* z9 }  y
27.          
    ( r2 `: h  Q5 C* w( [4 O/ B! F3 O
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    
30.     {
    0 I% B! H% r6 w$ H* a, R& I% E  A1 s
31.         return;
    
32.     }
    
33.      
    + _6 h) q& \: `$ q
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    " }4 Q' z; y$ v0 D; e$ ^' \8 o
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    % e5 T5 r& [$ i
37. 
    $ b9 Y0 f2 ~& o- }+ U6 w1 d4 I3 K2 i
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    
41. 
    7 h/ w0 Y: Z4 @" A# @
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    & o1 k; X6 O( b& G' O
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    - M& [4 Q* F" |( S& w* D
44.          addrSrv.sin_port = htons(6000);
    7 |6 E' F6 _, |
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    . Q0 X( P. r$ G. T! R  e) v2 V
46. 
    0 @5 j4 g, ]. r/ B. p& h' D. ^* f
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    
50.          listen(socSrv, 5);
    . n: @5 N! D! B; v
51.          
    : Z, H# {6 Y# ^0 y' e! d, `
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    5 X: Q* c: D" {, M2 k* Z
53. 
    3 Y; m0 H0 N4 s3 M( B# Z
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    . Z0 h' ^: T' D$ u2 F% Y/ e; j
55. 
    ; K  e; x. m* Q$ f1 A" e
56.          //循环等待接受客户端发送请求
    1 @/ S8 ~3 @" p9 g- _  H
57. 
    & G+ g* b& `. i" z
58.          while (1)
    
59.          {
    + s  w4 C( d8 S, H& w. s' z
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    / }6 n! J; s) Y3 y/ H" N! E2 u; \
63.                    //此时程序在此发生阻塞
    
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    
67.                    char sendBuf[100];
    & r/ ^. c# A/ z+ f& |
68. 
    3 e5 H" O6 N5 N8 U( N
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    5 w( d! Y7 @7 X" U/ K- `9 ~( }
72. 
    & s1 r: f! D+ z3 A
73.                    //用返回的套接字和客户端进行通信
    
74. 
    ; B0 B2 A3 o1 ^
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    ) D( i* p) B9 `
76. 
    ' d/ x9 ~) b+ w
77.                    //接收数据
    
78. 
    8 f0 m0 u: a8 j! u1 k9 s5 f' m) Y
79.                    char recvBuf[100];
    4 c; J9 Y! a4 O( k8 J
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    ; \: ~* q' X- _* X2 f1 \7 [
82. 
    
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    3 {% }* E3 [) ~7 \. ^$ z# p1 d
85. 
    % @: {. W2 F$ ~" t
86.          }
    ! @% T) V) W6 K0 C" E' q" G
87. }
    
88. 
    
89. 
    
90. Client：
    % \9 ]9 P* o0 V; c5 m" H4 x
91. 
    
92. #include <winsock2.H>
    # g$ d+ K8 v& _$ ^
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    + l1 c/ V* A: k6 l" E" @7 `
95. #include <string.h>
    8 Z" S* |, F0 B) Z
96. 
    * n( U- r1 M( {% c. D/ Q
97. void main()
    
98. {   
    
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
     
101.     int err;
     
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     & g4 o! L  |3 o$ N" k+ X
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     0 r5 n" e! t/ e) \
106.     if ( err != 0 ) {
     6 I$ q$ x& `% c$ W
107.          
     
108.         return;
     9 G; r" v% H/ D. s& @5 N: i
109.     }
     3 S6 J( c( }" f" M" T; H
110.      
     
111.      
     6 y+ x, P8 I0 _* q+ F
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     - G0 m) t- @7 w. r1 ~# `
113.         HIBYTE( wsaData.wVersion ) != 2 )
     7 [" j  e2 o# ^& y  c$ J; E" a: D
114.     {
     . V: l; o% T" b# a, Q, |
115.          
     
116.         WSACleanup( );
     
117.         return;
     0 E* m7 @3 r% V, q
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     5 _  k4 f0 L/ W( `. V. M
122.     addrSrv.sin_port = htons(6000);
     : A9 L+ `) F$ e/ D) H* a. O
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     - Q% L" e* w4 N4 S0 [2 O
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     4 H& a1 `6 Y0 ^3 u8 E! ?
131.     closesocket(socketClient);
     
132.     WSACleanup();
     
133.      
     & O8 Q* A$ i; r( M
134. }

复制代码

& V! b5 o) f) \) g% U/ z! C
+ i4 F5 w$ l! E5 b# [0 t; L