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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
# `2 x$ |) h. b2 v* E0 D客户端程序：client.cpp
) N* I1 e- l) B5 e% ^" G8 ^" v

1. #include <winsock2.h>
   9 l* Q$ w3 {( ^
2. #include <stdio.h>
   : K! F1 h. Q  _5 ?4 h; {6 C2 E) @
3. #include <stdlib.h>
   9 b! x/ X8 B! f, T  g, N
4. 
   + i# ~4 c; F. _2 ^# Y* _+ j
5. #define DEFAULT_PORT       5150
   6 u9 P6 \" B; T- G* Q1 l
6. #define DEFAULT_BUFFER     2048
   " \" W* q  d1 ^# ]6 {
7. 
   
8. char  szServer[128],
   
9.      szMessage[1024];
   . e( d' {& H# s, ^" l1 w+ V
10. int  iPort    = DEFAULT_PORT;
    9 H$ t; M: \9 `8 ]8 Q0 l6 V# E' \9 m
11. 
    1 n& Z% L' m+ Q, s
12. int main()
    
13. {
    
14.    WSADATA      wsd;
    + s% `( i1 G8 K8 i$ g5 A
15.    SOCKET       sClient;
    4 ^/ m- `- Z8 j" E* L( A
16.    char         szBuffer[DEFAULT_BUFFER];
    7 C% `9 J0 g" e! ^
17.    int          ret;
    * P) q/ f1 u& L* x: F9 L
18.     struct sockaddr_in server;
    " P' R* ]9 |9 D+ Y4 S4 v6 p8 a
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    ) H( _* q; B; N% f4 b! M
21.     {
    7 [8 U8 `. v+ s, R- ~! M
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    * q/ j& _) [; |( r4 B8 v, Y
24.     }
    
25.    printf("Enter a string to send to server:\n");
    8 [2 E, w/ W0 ~* H6 e8 B
26.    gets(szMessage);
    0 Q- B7 Z5 W, R3 r. f, b
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)
    5 C3 h* B4 ]8 ?! f6 y. B
30.     {
    , w# J9 E" Z$ t- q: F, J& k$ E/ u
31.        printf("socket() failed: %d\n", WSAGetLastError());
    ' I) z4 B/ v2 z' [5 W
32.        return 1;
    
33.     }
    # B0 y7 C8 l, @2 c$ g" k" Y
34.    server.sin_family = AF_INET;
    3 B% q4 D- ?3 p
35.    server.sin_port = htons(iPort);
    6 C% T6 `1 S* L' H  F7 S7 q5 i) {
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    ; B9 h+ W% ]4 N- w. Z& g6 ^2 x
37. 
    6 w0 C# ~7 c+ l' e8 N
38.     if (connect(sClient, (struct sockaddr *)&server,
    7 [7 x3 _4 a1 g1 k. u  w
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
      N- t$ X  `9 m( l5 k# f. w4 j
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    
43.     }
      @, h4 R7 m6 l7 f$ f
44.     // Send and receive data
    4 B% z9 H* }9 f" g# a" z) U' G
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    ! G8 |8 U% n! W1 a& h# o; I. ~
49.     }
    
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    7 ?# r! N. U+ K0 s
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    * y' A# }* O. z% x; l" _+ ^
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    4 X9 @  t( N& f# c1 |
55.        }
    
56.        else{
    ! {8 ^* Q: ?7 C+ I7 k
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    + z4 p$ O1 E6 B6 {5 ~$ J! o
59.        }
    
60.     }
    7 ^% \9 u; m: E4 K  Z3 r
61.    closesocket(sClient);
    
62. 
    5 V, \9 p9 n* k  e# c
63.    WSACleanup();
    & k+ W5 ^* w* ?3 ^6 A$ A
64.     return 0;
      i+ O4 J1 a& k5 B+ W* R' R
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   0 G) o3 n9 y& R/ J
2. #include <stdio.h>
   : S7 |- M. Q: V
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   ' W1 F8 v- X9 U- {' o3 B
6. #define DEFAULT_BUFFER     4096
   
7. 
   " N; x9 V4 i* Z! ?* e
8. int   iPort     = DEFAULT_PORT;
   ; X% K6 j# V  P' e% L/ s4 H1 J
9. char   szAddress[128];
   
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    1 }* {. S# ~% O* ]
15.    int          ret;
    # q( C( T& D% t4 I, ]5 e( S; L
16. 
    
17.    while(1)
    . Y& ~2 t$ c6 I( J: G
18.     {
    ) Q) G; S7 W* ^$ N7 |6 e) R
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    5 Z" r, {! X6 A
20.        if (ret == 0)
    
21.            break;
    4 Z) a  @3 {/ Q. N
22.        else if (ret == SOCKET_ERROR)
    5 H! f  R- @( H$ I
23.        {
    # |9 K8 H% _9 e8 d9 v: b8 T
24.            printf("recv() failed: %d\n", WSAGetLastError());
    / ~2 k! Y0 i- ?0 S) V
25.            break;
    ( V" Y% r# S, \
26.        }
    - i6 g7 I; u4 u4 f3 @
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
      ]! h( G4 N" b) [. \
32.        else{
    ) L/ s2 {+ G% G) l7 S6 A% V
33.          memcpy(szBuff,"Send the wrong string!",23);
    " E4 i+ v/ }8 x5 `. J3 ?2 V4 }" D) a
34.        }
    8 w" p% h: }5 S) P$ Y4 C
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    9 s* h6 b. s# y3 `8 b/ E$ l- i
37.          printf("send() failed: %d\n", WSAGetLastError());
    5 @7 d; B3 [, o: ?6 ]6 ]" m8 {  \3 P
38.        }
    " h0 F) R8 D$ t. }- X
39.     }
      v% a5 }* s$ b- l: F% l) ^
40.     return 0;
    : w) S5 B) D7 I
41. }
    
42. 
    
43. int main()
    
44. {
    , J* c& ^/ Y/ D4 Z& a6 a
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    - N& n7 Z. M( }$ }* \/ }8 ~7 U+ w
47.                  sClient;
    
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    % |# t7 W# p; `0 i; f) `
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    ! U! U9 Q1 p: _( e5 ^* a5 a
52.                       client;
    
53. 
    " \7 X1 |$ r6 O) W) f% f8 J$ `
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    ! W8 B# G- j$ \: G3 i
56.        printf("Failed to load Winsock!\n");
    9 p, z" m- C) a
57.        return 1;
    
58.     }
    9 M# v! a8 @  Z0 X" e# B1 q) M
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    - p7 [) n5 ^0 |9 P  W; R" E# O
61.     if (sListen == SOCKET_ERROR)
    6 B, w* s/ e8 T
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    # D, `" M% l3 r! ^' e0 N' j! S, l
64.        return 1;
    0 \$ @( J- @$ |/ E
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    : N. E! M* f, P# X0 Q" o2 t$ d1 `5 X' K8 u
68.    local.sin_port = htons(iPort);
    % Y7 v6 W9 i7 b( F1 y
69. 
    ) f& D1 s( @1 a
70.     if (bind(sListen, (struct sockaddr *)&local,
    & p5 ?: H- v. m9 X4 j% E( z
71.            sizeof(local)) == SOCKET_ERROR)
    9 F, O6 P1 q8 p* [% ~; X  }
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    & v% V+ C5 ?$ ~% ?( P( Z
74.        return 1;
    2 X# O  G8 \, u# r. T4 ?
75.     }
    7 J/ t# c, ]' q6 d: n' e2 B
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.
    
79.     while (1)
    4 i( n4 I0 P. R" o! X2 p4 Z
80.     {
    
81.        iAddrSize = sizeof(client);
    9 d% E6 i' i  Y8 O
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    ) t1 T+ P- o1 w0 v9 f
83.                        &iAddrSize);      
    + z* Q) m8 n- B" [
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    * t6 k' s3 P4 t! ]. W/ p
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    8 Q( B) U. d% i# r: J, p# S, a
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    4 I/ _4 T3 V3 [& k' ]0 D
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    / {  C1 C& S2 F. ?/ m
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    , _5 N- J/ R' ~2 V3 s7 _
93.                    (LPVOID)sClient, 0, &dwThreadId);
    + \$ ]: o5 T7 y& R
94.        if (hThread == NULL)
    - u6 H8 U9 f+ h) _' B
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    
98.        }
    & Q. l/ u; O  J$ f
99.        CloseHandle(hThread);
    6 B0 U( p) [0 P
100.     }
     ; x5 j- ]9 D6 u1 e( |
101.    closesocket(sListen);
     
102.    
     . @8 @" f. P7 h1 H' x' H2 Y$ z; E/ Q
103.    WSACleanup();
     7 ^: u) {8 p$ G% P
104.     return 0;
     % o( q$ _' {2 C5 H, l3 g- t
105. }

复制代码

& i. ?. R* Y" F; ~, M$ _
1 q4 [) w5 s* l2 _: J$ `
2 d7 d( O( C% [' o6 |$ p  H/ j/ N4 p* h
3 }$ k  d3 v0 c5 Q( f8 n

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   ' S" y. D; q" V+ j% v  Q" U
2. 
   . K0 \$ J" B# R6 ?4 d6 _
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   ( L4 q% u1 ?* F, L& }
5. 
   
6. Server：
   4 s! j: x" X+ i7 `# s( `  t
7. #include <winsock2.h>
   
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   8 h' D) o; Q# U9 s
10. #include <stdio.h>
    
11. void main()
    ( o: o4 M* g  v3 T
12. {
      @0 J5 o6 d: T) Q$ j  Q: u
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    
15.     int err;
    3 U% Y' X' e) p2 R% Z: h
16. 
    8 q; B0 a0 L: x+ e6 L  Y1 g% N
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    9 o0 m9 T9 a6 ~
20.     if (err != 0)
    
21.     {
    ( h2 x+ t7 E& ?/ o& w
22.         return;
    ) a% u5 e+ G8 g! y
23.     }
    : k' }, Q2 x: z+ r& H+ [8 f
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    # ?9 D0 D* Q# C9 t/ j
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    7 c  d" }( k9 [5 f0 [, Z! O# \
28.         HIBYTE(wsaData.wVersion) != 2)
    0 _" q4 S3 P; R5 G2 j
29.          
    
30.     {
    * x1 i- x! \# B1 S  v/ q
31.         return;
    + ~2 e9 i' g8 K% {' r
32.     }
      C( J" S0 j! O0 s0 T8 h- H
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    ( v, I( ~; ^# d( ^
38.          //Socket地址结构体的创建
    
39. 
    # P/ Q* }; p( C) ?" v
40.          SOCKADDR_IN addrSrv;
    ! D; @$ {7 n+ s8 ~( ^' ]. `% G8 C
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    4 v3 U* Q- R$ S4 Z0 U  H" ~7 ?: ~: [
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    
44.          addrSrv.sin_port = htons(6000);
    8 Z! c# ]& {$ N0 R
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    ' @7 I6 D! K+ h4 M% w
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    8 |0 z# v3 O7 {
49. 
    
50.          listen(socSrv, 5);
    
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    6 H4 g$ g( v2 X4 o7 w9 q& K
55. 
    
56.          //循环等待接受客户端发送请求
    & F" u0 T/ x" H1 C! q% d6 O, a
57. 
    ( A3 y5 |4 l5 L& S
58.          while (1)
    ' H/ m' q& t" w) y* R3 W4 E
59.          {
    # O( f1 X/ ^3 C- ~$ a5 H9 R) G
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    $ b/ c2 w! j1 G" f7 ?
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    , s4 z5 M; \- x% t4 s0 R
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    - a7 \5 b" ]) w8 n9 f
67.                    char sendBuf[100];
    # c! i4 w* G8 ]* k& ?& h$ Y' r8 I
68. 
    $ C! h/ U7 V! Q) e& h9 y9 c
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    ( P7 o0 Z  L& I, o3 Q- ~- b
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    8 L) ?. D% w( X5 b* Z) c& _
73.                    //用返回的套接字和客户端进行通信
    2 \4 l9 H+ n; G  h# M: c! X
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    1 J2 U5 k, a& h5 O8 ~. K4 c
76. 
    5 K7 N* m7 ?* Z7 g9 N
77.                    //接收数据
    & C3 U' A1 ?( q9 W1 n& Q# g
78. 
    
79.                    char recvBuf[100];
    8 x3 u/ \$ @; C, [
80. 
    ) \1 C) C- h4 r. `8 n8 \
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    ) W: `' J* f! e4 k
85. 
    " C' b9 Y: E1 ^$ V' @: V# `$ M
86.          }
    
87. }
    4 P$ Z9 J: z* F* S
88. 
    ) b! {$ ]! Z/ C9 N5 ?
89. 
    
90. Client：
      s0 g: @0 f+ H3 h6 F+ S* I
91. 
    
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    ( Y( D) v: R$ g
94. #include <stdio.h>
    
95. #include <string.h>
    9 M5 c' W) A8 L, ?$ |$ L: K2 O
96. 
    + j; v$ e2 [1 ~* u2 x, b9 P6 ?
97. void main()
    & D" w( D4 J# X
98. {   
    
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
       e9 |5 ?+ a9 T! ]
101.     int err;
     
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     9 A. u" d* @! T2 r
104.      
     + y' F" s) f  C
105.     err = WSAStartup( wVersionRequested, &wsaData );
     2 ?$ p- I& j' {' j# l' L' r
106.     if ( err != 0 ) {
     7 @) n' H3 f& A4 [
107.          
     / C/ c8 {  N# d* T9 S% [
108.         return;
     
109.     }
     # m( d5 I4 \& ~5 ]& g
110.      
     
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     ; ~  m1 w! L  B: W
115.          
     
116.         WSACleanup( );
     9 h, ?  ^# \8 |! J' B
117.         return;
     4 N4 g3 v8 x( h5 Q/ U: h% D. q
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     - d% s# u  v! L3 b
122.     addrSrv.sin_port = htons(6000);
     , ]3 x: @$ K! _2 F
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     . j, m8 @3 p8 w! g' n
124.      
     7 P+ y3 T- M; z+ l! p: A: B
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     9 e; w" j! a. _9 R" ?) a) w' {
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     : i; K2 }$ x; ~1 I/ u" p  H5 v
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     9 s1 J0 y: j# h) l! I8 F/ c+ I% e1 {/ G
131.     closesocket(socketClient);
     % P) J. W, |) ^1 n# ^# B' L
132.     WSACleanup();
     & }! W- V4 s; j2 H8 ]; }5 ]
133.      
     & t5 l2 v: Y& l
134. }

复制代码

/ }2 _- W; G5 |* l4 h1 E6 E& Z