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

admin

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

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   % [* T0 v2 r! j" o& P% z
6. #define DEFAULT_BUFFER     2048
   
7. 
   # m- ~* F3 A2 i& u4 A; L
8. char  szServer[128],
   
9.      szMessage[1024];
     g4 F9 l8 h! r& Z& \
10. int  iPort    = DEFAULT_PORT;
    / v& i1 @1 L- `/ o. }5 K
11. 
    
12. int main()
    4 E" m" O6 v" d9 G6 g. T
13. {
      D9 l3 y4 b0 }
14.    WSADATA      wsd;
    8 ], e+ g4 n( k) `3 f
15.    SOCKET       sClient;
    # E! H7 {  f$ f6 M  j5 A( _+ l
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    # p$ K$ p9 v( `0 I4 a7 g! I1 A8 G0 g
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    ' B; W+ D) k( z
23.        return 1;
    
24.     }
    , Y! U; ?' P& E/ d, L2 `
25.    printf("Enter a string to send to server:\n");
    
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)
    
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    8 d6 v0 w# w! ?' ^
32.        return 1;
    ( a- J7 o. a/ k8 r* C$ m. p
33.     }
    1 O, U. l, e* U% R, h% `  ]
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    , C4 \" b0 C5 x3 Y/ O: |
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    ; r+ a: @) a$ X
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    7 c  _: E- W) r; ?
41.        printf("connect() failed: %d\n", WSAGetLastError());
    6 M& m! E. _" M9 Y; D
42.        return 1;
    
43.     }
    
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    ! Y. V' ^- [1 W
46.     if (ret == SOCKET_ERROR)
    " g3 @0 n; R- n0 Q
47.     {
    4 w/ s: z1 ^! |' `
48.        printf("send() failed: %d\n", WSAGetLastError());
    ( w. T; W+ W% e+ W$ Y
49.     }
    2 }- t/ k9 F- ?8 z" S
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    9 s  d+ {9 r3 w/ z) @9 q
53.        if (ret == SOCKET_ERROR){
    7 H5 y0 n5 _8 X2 `. j9 J
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    
56.        else{
    7 h5 W  ]. G" x: _0 G& r& L
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    $ o4 V6 m% M2 f; k& M4 k! l3 }
59.        }
    3 J5 W$ b9 T" h4 a* F
60.     }
    3 a; M/ `" ^- q- o: \
61.    closesocket(sClient);
    
62. 
    
63.    WSACleanup();
    
64.     return 0;
    
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   7 a% }( _2 M# M2 @2 W; ^6 E
2. #include <stdio.h>
   & L& T' b1 ]& o7 u, }+ ]3 s
3. #include <stdlib.h>
   ) G+ \4 w# e7 z. g
4. 
   8 H" e& P! \9 @0 B
5. #define DEFAULT_PORT       5150
   5 e% P; E6 N; o
6. #define DEFAULT_BUFFER     4096
   
7. 
   
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    $ M1 t: P! u' E9 D; A0 U
15.    int          ret;
    # `0 Y; O/ H% l  w8 n+ @% n7 g9 R
16. 
    
17.    while(1)
    ; y; Z1 G6 z( n
18.     {
    
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    ! E4 t$ }; p" [  D. Z$ I( z5 u
20.        if (ret == 0)
    
21.            break;
    8 W1 s4 S; t1 A$ w6 g2 C
22.        else if (ret == SOCKET_ERROR)
    8 K6 i: M9 p( M( b( c5 r' ]
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    7 N6 u$ G5 m( l1 N% N: s! y# }* s# U+ U
25.            break;
    
26.        }
    3 {% ?* W- [9 t1 y' h& o7 \( e  R
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    
30.          memcpy(szBuff,"Send the correct string!",25);
    ) M8 ]9 H' D8 [* b, j. V
31.        }
    ' g5 ?' `2 @4 f; o( I, ]
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    : j  s7 N6 f: \8 o( p; @
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    
39.     }
    - k4 A% C5 E: u. ]# [
40.     return 0;
    . L, {' g" f2 Y; i/ R
41. }
    6 R" b$ F" g3 D, t6 t  J
42. 
    9 L! K$ z9 g+ w  w3 q/ s" V- V
43. int main()
    
44. {
    2 X( H7 f+ W9 G. r
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    % [5 i2 J+ ~5 n4 Y4 b, a0 j' ~4 r
48.    int          iAddrSize;
    . H1 n9 k/ I$ C8 r
49.    HANDLE       hThread;
    0 m" _0 d+ u* Z2 ^8 _3 s5 P
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    
52.                       client;
    
53. 
    0 j& l+ u! b# H" z4 l
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    
58.     }
    
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    ) j- E+ P( ~& e2 T5 f
62.     {
    . g& J0 _) y: @3 ?. Y( S( E
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    + z* {6 V" A# x% t
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    ; V0 k9 p# S6 u/ p4 f; |
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
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.
    / u8 K: K/ U" N  \& k/ v
79.     while (1)
    + _) H. N; A" ?6 T( |; c
80.     {
    
81.        iAddrSize = sizeof(client);
    $ p" ^1 Y/ B$ _$ e) C! `
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    " J4 r1 o% W" S, v( r  G
84.        if (sClient == INVALID_SOCKET)
    % k) ^; d7 W$ M
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    ) {* X* N6 p5 O& l  V
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    % s1 I. s/ _6 X2 J
91. 
    , K- L. @% x. P' y: M/ Q
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    ' a' P- ]3 H) M* |4 W5 {  V
96.            printf("CreateThread() failed: %d\n", GetLastError());
    0 C' U2 j5 T5 k/ w6 P$ J
97.            break;
    0 p  s+ n: Q% n9 _8 S% _7 e
98.        }
      f( |/ P& D( q$ g
99.        CloseHandle(hThread);
    ) M) ~. g* ]$ D
100.     }
     7 o- [/ C, k  R* M, I; Q% v
101.    closesocket(sListen);
     $ v6 }; H' v6 R4 F) P! k; I
102.    
     
103.    WSACleanup();
     
104.     return 0;
     : y# h: K8 y, x% a% q* m# i2 h( q
105. }

复制代码

! W) c0 ^$ M, T1 F" `

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   1 }' T  G) p/ `' ]% A
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   3 h' ?4 M/ e$ l8 S+ @
5. 
   
6. Server：
   2 [+ f( M! e4 C# Z
7. #include <winsock2.h>
   " ^/ Q5 i. D; ~( g
8. #pragma comment(lib, "WS2_32.lib")
   4 B2 m, A% }: r. k/ }
9. 
   
10. #include <stdio.h>
    
11. void main()
    ' }" q; s# p; Y, }
12. {
    
13.     WORD wVersionRequested;//版本号
    * q* k- v0 z3 a4 n! R; y
14.     WSADATA wsaData;
    6 |! Z5 x0 }, ~( n$ c( [! X7 U
15.     int err;
    $ T" e6 _9 ?& m0 _- b+ F7 ]# q) S# |5 M
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
    
21.     {
    # M( d$ l% A  e3 S0 n" z4 O$ f  v
22.         return;
    6 O- j( v! A' c7 T5 h
23.     }
    
24. 
    . G! v7 j6 Z& d0 L8 `$ N
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    2 c0 Q2 Q4 m# h4 }- Q( @
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    ! ~& x+ @" \& ?' X; T( p
27.          
    ) q% s3 |0 q! a3 ?9 H9 e
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    
30.     {
    
31.         return;
    ; K# w; }; i6 Z+ s6 ~4 e
32.     }
    
33.      
    8 O! L$ ~3 c! }
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    8 ], p# ]( E6 p8 d, X; y3 I; y
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    
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);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    + o% m& N) f$ X' B: D7 c
47.          //将套接字绑定到一个端口号和本地地址上
    . e3 K1 b. y1 u) X
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    % N: T1 W! J; d% V5 d& e# G
50.          listen(socSrv, 5);
    
51.          
    0 Z9 m+ Y0 b: v" o
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    + Q+ J' u5 [! ^' t6 M
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    * K4 k" y9 U% l# ^; ~
55. 
      @: T8 q; U' Y2 H% m
56.          //循环等待接受客户端发送请求
    
57. 
    : W7 d7 y8 k4 J# u2 k( f, o
58.          while (1)
    * ^7 i+ M# a0 l/ S3 N
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    * E, k0 [" l# g( h6 v
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    ' B5 e) i& P( \4 |  R- o
63.                    //此时程序在此发生阻塞
    
64. 
    ! w0 v# B, f6 c: Z0 Q# g
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    ' w+ y; W  D9 X( z  _
66. 
    
67.                    char sendBuf[100];
    
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    & }2 {/ C, d; ]7 N0 F' I& m
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    
73.                    //用返回的套接字和客户端进行通信
    . F9 |( W6 m. u
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    9 ?1 S8 c$ f9 F/ n2 O6 s$ X
76. 
    
77.                    //接收数据
    * T! H. i! A4 N
78. 
    
79.                    char recvBuf[100];
    / j. g) z1 M! h9 Q
80. 
      W: D; H  ^; f+ b, W5 i
81.                    recv(sockConn, recvBuf, 100, 0);
    2 m% c" s: m) u( t5 }! \& |
82. 
    
83.                    printf("%s\n", recvBuf);
    8 k$ p% x6 G8 f$ b
84.                    closesocket(sockConn);
    $ t: c- R/ q2 K0 D
85. 
    
86.          }
    2 |6 [/ ^! ?, R8 J" F; b$ d
87. }
    3 n  n! a; ~0 Y' _+ ]3 X3 T
88. 
    
89. 
    $ V+ W2 g- G" X- X: y! W
90. Client：
    
91. 
    / I* R% A& [! y
92. #include <winsock2.H>
    0 U7 U: \0 A, c
93. #pragma comment(lib, "Ws2_32.lib")
    . m8 U  e2 ]" p) V% u( G1 R6 E8 b
94. #include <stdio.h>
    , C; {; e1 k% y" E, @! g7 x
95. #include <string.h>
    
96. 
    8 I. V8 ?2 g: I2 K& ~$ r/ I+ C
97. void main()
    
98. {   
    
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
     
101.     int err;
     ' H# \$ Y3 k  c# O# s8 z% P) P
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     1 E  w+ H& n% D# t/ e" b* p
107.          
     
108.         return;
     
109.     }
     ) i2 g2 l6 m2 K
110.      
     ) Z+ F7 L% _) D) G7 p5 ~8 o9 F
111.      
     * ~' Q$ _4 M( n2 R1 x9 D
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     , i7 |5 i# Z9 t$ D" K% @! k$ c
115.          
     % Q0 |/ x( l9 ]
116.         WSACleanup( );
     ; {! H" v' u, T! c" `$ V
117.         return;
     
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     + D: Z+ H8 ^: a1 ]9 X$ O2 ^
121.     addrSrv.sin_family = AF_INET;
     
122.     addrSrv.sin_port = htons(6000);
     
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     ( R; C1 P( |8 w! R8 S) K
124.      
     * E  |( q9 f% d5 L  Q5 y  E2 L" u. ~
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     . k) L; a+ g- I. }9 L8 T2 H& O
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     0 J' Q9 f3 ^+ K4 ?+ G; J9 d7 k
128.     recv(socketClient, recvBuf, 256, 0);
     ! I; l  N, V: {, e
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     $ P: k& h0 M5 S6 E9 E* o# r
132.     WSACleanup();
     6 Q( y! V) w2 F5 i& _# _) o
133.      
     * W6 ?3 r" E! J( O
134. }

复制代码

) a$ q" Q6 g+ S+ p7 c8 I& d9 w