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

admin

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

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   % h+ P* \, x# p. {* R( w' j6 [; n
4. 
   , T) O3 w/ Z% B% r
5. #define DEFAULT_PORT       5150
   . x2 m; i+ `. w( I% ?7 H' e
6. #define DEFAULT_BUFFER     2048
   
7. 
   * v7 ?- N* ]9 r5 t0 J+ H. \! x4 w$ Z
8. char  szServer[128],
   3 w* l% S, j; }( q2 u0 U9 B4 T# h* b
9.      szMessage[1024];
   . `- ?6 Q! {( X4 j
10. int  iPort    = DEFAULT_PORT;
    5 _4 N/ K: P/ h( E6 P
11. 
    & v1 s5 v/ y2 n" Q" w* C6 z
12. int main()
    
13. {
    
14.    WSADATA      wsd;
    + Z$ i# i" F( C4 U. p
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    8 h) \; T7 W9 x% M  H. h
17.    int          ret;
    
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    & b; \1 i* I" i% r
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    3 D! ?! w& W  o
24.     }
      d3 I3 |# _  r& y
25.    printf("Enter a string to send to server:\n");
    7 m- N9 R8 L* M' @- ]( O
26.    gets(szMessage);
    
27.     // Create the socket, and attempt to connect to the server
    2 O! V% G7 S* ~6 h, c8 a
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
29.     if (sClient == INVALID_SOCKET)
    
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    1 ^' ^) Q, s+ d
32.        return 1;
    
33.     }
      X$ |& f$ H  y. h1 R7 h4 d
34.    server.sin_family = AF_INET;
    0 F( i1 y8 F  W& R! x" Q
35.    server.sin_port = htons(iPort);
    ; y6 }% R: f5 }7 i0 W6 E' k5 W
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    5 _2 m8 M, ^% B: L( K* d
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    . l2 L+ y: V8 K, D6 ~% L$ b- O, @1 F
43.     }
    8 P) @8 m5 h8 m' ^# h, ?  o
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    ) G# z& y0 t: j' C
46.     if (ret == SOCKET_ERROR)
    + ]+ U2 O; Q4 h4 Q) d
47.     {
    " r3 L! L% o2 S& e5 W
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    , m% f8 R0 r, b* r9 {! H( z
50.     else{
    
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());
    , O3 u6 J" s& z/ e; i# z
55.        }
    
56.        else{
    
57.          szBuffer[ret] = '\0';
    ! a/ w9 v2 A$ c, O  J. h& l4 }
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    
60.     }
    % }2 {/ U! b1 b! |" J7 t' n
61.    closesocket(sClient);
    2 u* X4 [% a9 Y$ \7 Y; I5 A
62. 
    
63.    WSACleanup();
    
64.     return 0;
    ; N- E3 O# q* w" u$ N1 q
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   7 k' f, e+ g$ Y. i8 x/ Y- J$ C- w$ c
2. #include <stdio.h>
   
3. #include <stdlib.h>
   . Y7 T. E% v  K7 L
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     4096
   
7. 
   ! Q+ c9 G! X3 D, A- a
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    2 I5 R: e; x# {) U$ k
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    
16. 
    2 p) Q- _, \0 V
17.    while(1)
    % U+ z2 M: F) B3 _! b: F
18.     {
    1 g1 F3 Y, |! n# P8 y* j
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    9 z+ N5 e, F) I7 b
26.        }
    " C) k0 g" }! C% [0 v+ s
27.        szBuff[ret] = '\0';
    - U2 T% t) c# p' O8 w
28.        printf("RECV: '%s'\n", szBuff);
    0 @4 H  q! e! p
29.       if(strcmp(szBuff,"abc")==0){
    
30.          memcpy(szBuff,"Send the correct string!",25);
    . t7 L2 z) g7 |/ L3 q2 o! ]# z* t
31.        }
    
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    1 I, G6 Q* H: Q/ N; C  f
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    / r8 _, E; r) ^1 R! ^
38.        }
    
39.     }
    
40.     return 0;
    
41. }
    
42. 
    
43. int main()
    
44. {
    
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    " ?3 `7 n0 Y- o5 n
47.                  sClient;
    
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    ( a  _1 g% E/ P; r7 C
51.     struct sockaddr_in local,
    0 V  x; b: O; h7 g
52.                       client;
    * B: F6 r! e, d+ h# ~9 y! e2 F
53. 
    * o! t& k, u% V6 h" g) I! ?
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    % x6 f$ [* ?$ p9 D$ z
56.        printf("Failed to load Winsock!\n");
    - X! k* H$ T0 O; S7 S' u/ l
57.        return 1;
    
58.     }
    
59.     // Create our listening socket
    2 q$ d+ M2 L  V5 |; E8 D
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    + s0 [" C5 K" [
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    ( d$ z. t, N9 B' ^( b4 f7 P1 a
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    5 Y  A" q$ U: [( w
65.     }
    9 A5 r1 M/ q9 t7 V2 }' f
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    9 K9 k3 o- ]* t2 h
68.    local.sin_port = htons(iPort);
    
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    " o2 B- O& a) E& }3 f
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    ! ~  t1 d. K8 {! \
75.     }
    1 V' ^: C& g( |9 m
76.    listen(sListen, 8);
    0 O0 `3 M8 l9 H  d: c. e
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.     {
    6 h' J. r3 G5 e4 w0 s0 _" G
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    5 j9 v  a. ?1 z- ~; o" A
83.                        &iAddrSize);      
    3 K1 c( q3 I, c% x" c% a. g; B
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    & ]6 W0 @7 ^: k2 u
87.            break;
    
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    + M! d* G2 ^& i9 D7 C
91. 
    % P: z! Q! v7 \) C* b9 y- j* x( a
92.        hThread = CreateThread(NULL, 0, ClientThread,
    7 B( e* V$ o3 |6 n5 v3 g9 l
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    # `7 e8 j5 F9 R0 T0 O- N- X2 y
97.            break;
    % V7 G% E* f" \& G# y2 u5 e
98.        }
    
99.        CloseHandle(hThread);
    & K' P/ S9 B+ C$ w+ E
100.     }
     
101.    closesocket(sListen);
     
102.    
     ; M9 V& [/ N! E2 T
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

2 p) I8 G* h$ S4 h% j0 |

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   3 ~4 B* ^- L, N/ U- S1 K
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   % \# d$ D- A& ~# Y
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   
6. Server：
   
7. #include <winsock2.h>
   
8. #pragma comment(lib, "WS2_32.lib")
   & s3 R8 z1 B8 Z
9. 
   1 \, c' I2 u* `8 P
10. #include <stdio.h>
    
11. void main()
    8 d" P0 \7 c% [
12. {
    * {- q0 i) a6 [! x! _
13.     WORD wVersionRequested;//版本号
    : g! y& [! r% H$ c
14.     WSADATA wsaData;
    
15.     int err;
    ! ?8 c% H( G% n" x& o
16. 
    % f  x$ m2 P: }9 t; L! l
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
    
21.     {
    
22.         return;
    " b2 L, B2 L- e/ I: X
23.     }
    8 ]+ r, q+ ~: R# e
24. 
    # ^$ I3 d% d, N/ z. f
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    5 _" S0 \$ Q5 C7 j4 s
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    1 X% r' n' ~; k( u& {; J4 l- V
27.          
    - \0 ^! _& o6 A% {
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    % Q: [" k7 Y8 }( A
30.     {
    - e# [& t/ ]# s4 }) {
31.         return;
    
32.     }
    
33.      
    9 c$ E% g2 _( w
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    # p$ }/ b  L$ U' k( i: R" @# ?
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    . G' H' v5 `: ]7 G6 @% c5 U
37. 
    5 r/ ^8 L+ _! O
38.          //Socket地址结构体的创建
    8 X  G1 N1 {* I( B3 M" q' x+ Z
39. 
    * u9 L7 c* I' B2 h" T/ V! y
40.          SOCKADDR_IN addrSrv;
    & ^& v, I% T9 B% S3 N0 {  @3 ?
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    
44.          addrSrv.sin_port = htons(6000);
    / h0 V/ C, o. G9 y  D+ k' {$ w& _9 j
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    + x- Z# B( v) k& c
50.          listen(socSrv, 5);
    
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    ) S) A  F0 A( K- L
55. 
    
56.          //循环等待接受客户端发送请求
    9 H' p/ P+ Y& `! \0 c; o+ H* O
57. 
    
58.          while (1)
    - W) }: Q4 l: r' z" B$ |' ?3 F
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    + K8 j; v# E# F0 P0 S
64. 
    ; z1 q% j3 h+ o1 w3 x
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    
67.                    char sendBuf[100];
    
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    5 E2 ^- I7 m; R, t: f" x8 A# E6 b
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    9 k' v6 w/ E( S( J6 J3 L
73.                    //用返回的套接字和客户端进行通信
    5 e! Y; D* W6 C' g
74. 
    6 I! i& q4 m7 G0 @
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    6 X: T0 j, k% w1 M( A
77.                    //接收数据
    
78. 
    
79.                    char recvBuf[100];
    , a! ], X( ?, p4 O8 w9 b) f
80. 
    1 V" \/ Z* Y: q
81.                    recv(sockConn, recvBuf, 100, 0);
    9 {, @+ K. f7 w* j$ ^" V
82. 
    
83.                    printf("%s\n", recvBuf);
    ) E, s2 ]2 n3 f( f! X" k: x+ }* V
84.                    closesocket(sockConn);
    
85. 
    $ `& O9 y9 }& H2 S" p
86.          }
    * K) {, R, Q- d3 ^0 f
87. }
    7 M8 N( M& Z9 K) r; G9 T0 H% e
88. 
    ; X1 t% n0 t+ q7 Y
89. 
    
90. Client：
    
91. 
    4 Z6 o% Y0 x: X' O/ |$ ~: @
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    / S! L% L6 g) \6 y7 U5 F
94. #include <stdio.h>
    
95. #include <string.h>
    
96. 
    8 O- ^8 |# j8 Y* m/ U
97. void main()
    ! E" W) g7 |0 P0 v5 Z
98. {   
    6 J  L/ }4 K& s* l0 s9 X
99.     WORD wVersionRequested;
    + y; p4 _- H9 V3 `2 M; e) R8 K
100.     WSADATA wsaData;
     ' Q8 n- w* i2 n2 }% A
101.     int err;
     
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     $ r& |+ }. d* ?/ _  R3 Y
106.     if ( err != 0 ) {
     ) z0 V0 {3 N: `& L, C$ m& N9 i8 T. y
107.          
     5 t: `& G! i5 y; H, o, {; \9 _1 p
108.         return;
     
109.     }
     
110.      
     * f* I  o" d8 c1 ~$ |
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     : m- ^2 w) _, _7 ]/ _" Q5 k( @
114.     {
     6 e* i/ L& g! G: r+ h6 e% g' h) L
115.          
     # |3 _) j, f+ ?+ V+ y
116.         WSACleanup( );
     9 Y9 ^+ e8 p7 X# C* u5 |
117.         return;
     
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     
122.     addrSrv.sin_port = htons(6000);
     ; X' j. o2 v6 Q: t
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     
124.      
       v- b' p/ }( W
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     8 Z+ Y* y- l, P, G5 a
126.     char recvBuf[256];
       m5 C% m) Z1 M) Z6 r0 c
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     : R" F: Y. @9 A* E5 B+ W6 L
129.     printf("%s\n", recvBuf);
     4 p/ @! x% B$ X9 z! D
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     - P7 p4 G6 Z. E" @
131.     closesocket(socketClient);
     , V$ c4 j; B: x
132.     WSACleanup();
     # [/ u/ w- i3 N2 |. @4 F! O
133.      
     
134. }

复制代码

8 V4 J4 @3 g( x) S- O. K' j. O0 E