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

admin

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

1. #include <winsock2.h>
   , \3 J; E7 c2 z2 J  ?9 A6 E" M0 W
2. #include <stdio.h>
   
3. #include <stdlib.h>
   , L1 P8 U$ Y4 x; Q8 l: C
4. 
   ( U" `- w. f2 S+ R8 t% S% h/ b5 D
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   
7. 
   
8. char  szServer[128],
   
9.      szMessage[1024];
   0 [# Y6 ~+ R6 O3 Z6 E
10. int  iPort    = DEFAULT_PORT;
    ! l6 i. R0 p! p7 _1 I& ]1 n* C5 m
11. 
    
12. int main()
    / c1 Z3 [1 N$ z, V% G
13. {
    " E2 n. t- y7 n) m; c8 v* g
14.    WSADATA      wsd;
    6 n2 K/ @( \: e: ]/ n  m; D
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    4 X$ t6 W& ]  ^+ q2 ^
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    6 C. ]1 @. N. l
21.     {
    : s: F' g7 J& F" z" j2 \5 u
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    5 `; z0 ]( Z: }7 O# I) }0 r( d2 p
24.     }
    
25.    printf("Enter a string to send to server:\n");
    1 O7 O1 M/ d3 b7 r7 r8 ]5 h1 A
26.    gets(szMessage);
    . m& t4 I3 [" _6 e
27.     // Create the socket, and attempt to connect to the server
    . K( r" h* e8 N5 Z# v
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
29.     if (sClient == INVALID_SOCKET)
    . J- h0 u# J; v+ z! a' o6 c) B
30.     {
    * Y% G$ ^1 p5 n
31.        printf("socket() failed: %d\n", WSAGetLastError());
    5 E. l; G* r, U9 U, ^( r
32.        return 1;
    - @! n$ p8 |9 t# [: f' K1 g# G
33.     }
    * ?+ _1 A) `9 a
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    ( h) r* h) a6 y2 @: M7 g9 z
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    : Y0 ~/ N5 K( s% d- a
40.     {
    + |, \7 ]9 e& x% C8 G  |" v' G
41.        printf("connect() failed: %d\n", WSAGetLastError());
    ; x4 R3 K4 p9 c* g8 H
42.        return 1;
    2 b2 B5 j7 ^5 W. m. V
43.     }
    
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    ' I+ S' d0 [" C" P/ @
47.     {
    
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){
    : T  b/ A% M# v( R3 {3 O" b
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    * a) z0 `, M6 W' H9 O& }
56.        else{
    
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    
60.     }
    " r- A$ N  k% d; U8 M, ]: x
61.    closesocket(sClient);
    " p* m# D, L6 Z( J  K
62. 
    
63.    WSACleanup();
    # t" @* k2 ~% ?- D2 V' Q1 e
64.     return 0;
    ' E) _" d* O' ]' t( _- ?3 N5 S+ h
65. }

复制代码

服务器程序:server.cpp
9 y) z2 _5 |2 `

1. #include <winsock2.h>
   
2. #include <stdio.h>
   4 U# U! O2 E" ?/ G. T( K0 C# y
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   9 h- P0 k, D+ l" B3 f9 U1 l+ z
6. #define DEFAULT_BUFFER     4096
   3 J* o9 w/ n5 R( A" _; I- e
7. 
   
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   
10. 
    ' y$ h- A. ^, z
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    / T; b" P# K4 S" ?7 e; ^
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    , h8 E) D0 O* d4 [
14.    char         szBuff[DEFAULT_BUFFER];
    + B3 w, d! j" M) M+ M, H9 S" Z: y. I
15.    int          ret;
    
16. 
    
17.    while(1)
    ' h: L) f3 y8 e0 b  h' f5 @
18.     {
    7 d0 H: q! p4 ?, G
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    $ r! h+ A" o0 J5 r/ }6 H! O
21.            break;
    * I1 {: w6 d# {
22.        else if (ret == SOCKET_ERROR)
    
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    2 W% U, o& J3 j- p! V, u* h
25.            break;
    # }3 g+ D( c+ T0 r
26.        }
    3 r) `* J( }8 T8 r, o4 G
27.        szBuff[ret] = '\0';
    6 u% P0 Q; R; m+ ?
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    
30.          memcpy(szBuff,"Send the correct string!",25);
    1 `; S( Z: Y5 s8 h0 I  I* w
31.        }
    # B, S6 l" O5 q5 ]  o! l7 U  J/ k5 `6 o% b
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    4 ?, y8 C4 g  ?$ F0 A
34.        }
    4 Q; s, `( k: l/ |
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    + b, ]4 e& ]! A5 _
36.        if (ret == SOCKET_ERROR){
    . K0 ~& F, x2 E2 a
37.          printf("send() failed: %d\n", WSAGetLastError());
    % R% f& x1 U3 l2 P
38.        }
    ) H: X2 Q. z& m3 N! [6 c( u
39.     }
    
40.     return 0;
    3 A( j# F$ w' c0 ^9 Y! S
41. }
    
42. 
    
43. int main()
    9 }6 \2 \* I* h4 {
44. {
    0 ]9 f/ [% z2 j1 h
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    . q9 ^( ^4 j" A
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    " v4 i/ |6 ]) U1 B" m
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    / A) n9 w* M3 |
52.                       client;
    ( g; g, z: i% W6 D( B0 ^
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    / X2 W- b0 P/ U! P
56.        printf("Failed to load Winsock!\n");
    ( c* D7 X" r6 `1 Z, H
57.        return 1;
    
58.     }
    * T7 }, ^8 U8 ~; r; ]! ]- v" j4 W2 \
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    # T% z" m, F1 w4 l, q( d
61.     if (sListen == SOCKET_ERROR)
    ) @- w  m+ B& r, @0 ^
62.     {
    + r  d  E& f. U" i# g8 h* y3 R# U
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    9 w; ]/ P4 q3 `+ H  L% \
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    $ Q# e+ @' w0 }7 s
68.    local.sin_port = htons(iPort);
    
69. 
    ' S2 B$ T$ _$ {/ f
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    9 l5 B' A8 p* j5 y! R# E; S
75.     }
    1 U1 ?4 \7 y: m* @6 }
76.    listen(sListen, 8);
    
77.     // In a continous loop, wait for incoming clients. Once one
    2 F0 P( ?  T3 k3 ~  J: E
78.     // is detected, create a thread and pass the handle off to it.
    + w5 r# }& z5 a" q0 r, \7 J0 h3 H
79.     while (1)
    
80.     {
    
81.        iAddrSize = sizeof(client);
    ( z- m; J% B! U  p: x
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    5 M1 _) c$ c* B' j, {% x8 v
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
      K9 F, ]4 U: ?7 q, ]- m
85.        {      
    / d$ I" P% y" A  q2 Z
86.            printf("accept() failed: %d\n", WSAGetLastError());
    * l2 ?7 A" \( c- n" I7 U
87.            break;
    
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    + a1 t" p$ |; l* E
91. 
    ( [' L! F5 ~$ ^
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    1 _; S& r; e& k; x
97.            break;
    
98.        }
    
99.        CloseHandle(hThread);
    8 D- e1 @. X3 O3 w$ ^4 }  Q$ g
100.     }
     
101.    closesocket(sListen);
     : y2 c$ C, J+ p" X
102.    
     ! c, Y$ M3 j. Y, F
103.    WSACleanup();
     
104.     return 0;
     ) A7 w6 a0 G5 g; x
105. }

复制代码

) c" Z! d% b& T# O. E1 B3 u
( l" K6 K- n: R$ \

" M5 e! `7 y( E

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   9 h# \9 Q# c5 E( Y/ S( X
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   1 V8 z' V0 P5 p3 C
6. Server：
   9 d/ y9 f8 q: k8 }7 w# H3 G
7. #include <winsock2.h>
   
8. #pragma comment(lib, "WS2_32.lib")
   . e& w& _3 W6 y9 l
9. 
   
10. #include <stdio.h>
    
11. void main()
    ! Y0 K' l5 `9 k' \6 L3 a8 `
12. {
    
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    
15.     int err;
    
16. 
    2 n, o7 E1 @4 k
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    4 I% Q) t" w! j" Y
18.     //加载套接字库,如果失败返回
    & R' A) Z& v0 g
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
    
21.     {
    : ~! M7 |, m# T4 H+ h# `) k
22.         return;
      {: o4 Q, x8 q; g8 f
23.     }
    
24. 
    ; H% X* b& M. \+ g: p
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    - B) t$ k2 j- {3 s" L
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    ( r( K. Q* c8 U5 ^" ?( c7 `
27.          
    ' |* e( s, r' }4 y
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    9 J: ]) F7 R6 N& J
30.     {
    
31.         return;
    2 l! n- K+ A9 q- v' t
32.     }
    4 T+ n# C% j4 n+ Y! l2 S; H
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    ' B* |! N6 `: j. d7 L0 P: G) U  k4 H
35. 
    5 s. [# e2 Y) K' M% c$ R& I$ v1 r
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    
38.          //Socket地址结构体的创建
    / t% [; u& o# O" u: @7 |
39. 
    
40.          SOCKADDR_IN addrSrv;
    
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    ( ?* J; v. ^! i- N2 h( e
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    2 N) t6 r! M; b; h$ _/ x
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    5 h% e6 X/ [! |9 j8 W' S1 I
47.          //将套接字绑定到一个端口号和本地地址上
    . W* X7 B4 j/ D" g; |
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    0 d3 g, u3 \+ l8 p3 D9 I8 a
49. 
    # r  @, @! ]! P2 t
50.          listen(socSrv, 5);
    
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    $ E5 A/ p* l& F& B7 D  \: e- f) B
53. 
    - P# a+ D* B0 y8 ?3 `; Z  ~+ [
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    
56.          //循环等待接受客户端发送请求
    
57. 
    
58.          while (1)
    
59.          {
    0 u. C9 Z8 D1 \8 m7 \( B
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    # C' T- {6 I$ |' G( G* n
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    ' K+ }2 L& c# }. C# {) `6 f) P
63.                    //此时程序在此发生阻塞
    
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    / K4 \& k3 p% z1 w
66. 
    
67.                    char sendBuf[100];
      j2 D0 C/ @5 f- `
68. 
    2 u% t6 \) K9 Q4 k7 I5 q. Y8 s8 H
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    4 u7 K# U4 o8 {3 h
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    / [, D; E" |, C8 U0 d# {, \7 t" h
72. 
    1 B4 @# V, r' F+ h( H9 v, Z
73.                    //用返回的套接字和客户端进行通信
    
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    9 c: V9 _, j7 x5 G  j; `; h
77.                    //接收数据
    
78. 
    & Z% p( D2 _2 M
79.                    char recvBuf[100];
    6 @5 V, I* Q" x
80. 
    5 u! U9 {8 u* r& ^# }
81.                    recv(sockConn, recvBuf, 100, 0);
    " J/ o$ t0 Q' v  @7 z& X
82. 
    * t. Q9 G( i/ |3 P1 p, w
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    ; e9 G# F$ I6 N
85. 
    
86.          }
    , x: x. Q6 n3 ~$ W8 V! o' O6 F, n
87. }
    ) U4 a0 t% m  ?3 M+ n- L) I4 C
88. 
    8 D# r, y& H7 G
89. 
    ( X/ H$ d& o/ Q- }" Y7 Z8 T6 u
90. Client：
    
91. 
    8 c& f( f; [# Z9 [1 F; N9 |& G
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    , L2 P, a* W2 G( F
94. #include <stdio.h>
    
95. #include <string.h>
    . @/ Y. a2 ]* f) y, W! m
96. 
    + f/ B) g+ M( U% Q" n
97. void main()
    $ c, G0 h* V: a
98. {   
    ; Z1 ^, e: m3 w4 u
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
     
101.     int err;
     # M4 @+ C* Q5 {/ ~- y; D" P
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     ' S) y6 _! R4 E7 e2 k$ R- I
104.      
     8 G( v  I; c- X7 y+ A9 g
105.     err = WSAStartup( wVersionRequested, &wsaData );
     $ f9 g3 @4 m' ~1 v* f
106.     if ( err != 0 ) {
     , D1 z8 Z! e) |
107.          
     ) L& M, f+ j/ G3 D
108.         return;
     
109.     }
     
110.      
       J0 U' G: a  T# a5 V- x. x
111.      
     % F7 p! i0 ~0 i! h
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     # n5 {2 B; V) G# N) O
114.     {
     
115.          
     
116.         WSACleanup( );
     ) V  n7 R  X! f
117.         return;
     9 T- q( x' `! w( f0 @1 [
118.     }
     1 K" x6 I/ P3 K" h; y9 M7 r8 ~6 x0 N
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     " t( P2 J$ G4 e5 a) \
121.     addrSrv.sin_family = AF_INET;
     
122.     addrSrv.sin_port = htons(6000);
     3 O# d: F8 a% l5 o3 p
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";
     3 [9 k) y; j  G
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     
132.     WSACleanup();
     
133.      
     
134. }

复制代码

5 _) l/ P# O: Q" i' k* @/ o