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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
- ~2 C" e/ P( p7 a3 _# J客户端程序：client.cpp
9 k; m' k$ i2 a  j2 s/ u

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   " Q+ B( S4 e0 m7 i
5. #define DEFAULT_PORT       5150
   , j+ N& D- F8 f/ X+ M
6. #define DEFAULT_BUFFER     2048
   
7. 
   + k  Q+ V0 ~: ]) @! u" _' i3 R
8. char  szServer[128],
   ! C: j; K6 N! b( M6 D
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    
11. 
    
12. int main()
    * Y. O! R+ x' j& g4 `  J
13. {
    
14.    WSADATA      wsd;
    " }0 V2 N" A  {5 @" ^$ f, F* g
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    4 y: r3 ^5 |$ ^1 J, L8 e6 P  l, G
18.     struct sockaddr_in server;
    % v# ]/ l" f# `, d0 C' Z- z! r
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    1 H. `/ y5 T! w  u  e% Z. j
23.        return 1;
    $ r, W$ L: h9 I' F0 R. X1 f) j7 ?# W
24.     }
    ; V3 H4 w0 g' ?% Y2 A
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.     {
    . q1 f+ {* a3 F
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    
33.     }
    2 m9 k8 x/ m8 ^- R9 ]) ~, x
34.    server.sin_family = AF_INET;
    / d7 N- ?9 _/ `/ ~
35.    server.sin_port = htons(iPort);
    
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)
    
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    + b9 L+ w. v! Z9 W# x! }9 g
42.        return 1;
    ' m6 q0 e% g# s
43.     }
    
44.     // Send and receive data
    4 S  ?+ w: g) P' {5 @0 b# [
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    ( y3 k9 n0 `9 r8 V; S
46.     if (ret == SOCKET_ERROR)
    $ w# _; B+ M7 R8 m
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    ) u! j% C% u. G4 F0 r- l3 P
49.     }
    / }- e% k. S5 L/ p, C7 k6 G3 @" z
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    + h7 K7 K, O9 u& U" m" t
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    
56.        else{
    
57.          szBuffer[ret] = '\0';
    / |/ }+ @9 z" t
58.          printf("RECV: '%s'\n",szBuffer);
    ) N; H' `/ b, {: M% p
59.        }
    0 l8 J; K* N' k" B4 P  O! l  l
60.     }
    
61.    closesocket(sClient);
    
62. 
    ; K# S! K5 m8 R- g  R! f5 m
63.    WSACleanup();
    
64.     return 0;
    . M" ]& g0 ?5 g( A' n
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   
2. #include <stdio.h>
   9 L! T) ~  c7 J: L1 C6 X
3. #include <stdlib.h>
   
4. 
   ! U3 C. v5 d4 U0 M. w
5. #define DEFAULT_PORT       5150
   , \9 f$ i7 w7 _$ d. M! q
6. #define DEFAULT_BUFFER     4096
   % M% z% W& j' I' |- o2 {
7. 
   ; U- I$ ?* {, S. l; M9 B1 O. ~: `
8. int   iPort     = DEFAULT_PORT;
   1 L9 @4 O9 \8 Z
9. char   szAddress[128];
   
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    - \. D1 B6 T' X$ B* Y
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    - t  {& s3 {0 J# a
16. 
    
17.    while(1)
    0 a& U# p4 }' Q: C' d9 T8 R, }
18.     {
    " D3 @0 v" d" x5 e  A0 t
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    2 ]5 e2 L- N7 W: Y. k% i; D4 v
21.            break;
    ( j+ `7 F/ c2 V7 n  I( [- c
22.        else if (ret == SOCKET_ERROR)
    6 ~6 S2 `7 M5 s, r$ U6 |0 @
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    % [6 c7 p/ c2 j4 I/ ?2 b2 X/ H
25.            break;
    ) g: {7 D6 l: C. V! O9 ^
26.        }
    / Q6 \( D) z. ]5 L' ?! C3 W! a, q$ @
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    * v$ I- q& Y2 v$ v2 i+ I& X- _( Z( @
29.       if(strcmp(szBuff,"abc")==0){
    ( k- v/ h! M' |2 s
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    ( X; \" P4 k( b  H
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    8 R  X  t. Q) x; a2 M7 K  S
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    1 R, S, P+ t+ m: Y; |- B
38.        }
    1 r9 V  r' w$ N; T! z" A" e
39.     }
    2 d8 a: n; _, W$ C* H
40.     return 0;
    . Y9 b6 X5 D9 E9 H  I% |
41. }
    
42. 
    " K* u- C* U1 O1 L' p+ A1 B6 u
43. int main()
    
44. {
    
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    ; @6 `& m6 D' n; y9 N9 B7 m
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
      ~: q' ~0 X3 v2 h* p9 x
52.                       client;
    5 _; Q$ i( ]0 R1 v+ g" ?
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    
56.        printf("Failed to load Winsock!\n");
    ; @" v, i' e. Z. N; j
57.        return 1;
    9 t8 k" ?8 r3 y/ d
58.     }
    
59.     // Create our listening socket
    0 _/ w) Y3 T$ v) N( s- X
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    ; P! u/ d& I2 q  d* u, X5 d  V
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    " p. L! u6 v7 O3 P8 C7 x
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    ( M: P7 ~5 t- m
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    / y6 e( E& f+ x) H* w3 y
67.    local.sin_family = AF_INET;
    1 ^  h  {( r. `8 M( K
68.    local.sin_port = htons(iPort);
    
69. 
      Q; C9 Z0 E. z- m9 ?& ]3 k0 i2 C
70.     if (bind(sListen, (struct sockaddr *)&local,
    * e3 I& n' W+ \# K
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    / [$ f( I" Z' t$ z& m5 @+ j- z
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    7 k9 l" i9 H* O0 T! {& r7 g
75.     }
    6 W% u0 Z' c) d: W' m$ I+ I
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.
    " p( a! i6 I+ i
79.     while (1)
    
80.     {
    
81.        iAddrSize = sizeof(client);
    0 [% d1 ~+ W6 g# x0 i
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    1 M0 ?1 G. L7 N2 W$ A
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    " h( m1 C( Q: Z3 C' c
86.            printf("accept() failed: %d\n", WSAGetLastError());
    2 z" t! {  n' [- m8 Z+ p) u- I
87.            break;
    
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    ; `# j0 M2 C( `
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    ' D; G5 A. r- B6 Z% P# F
93.                    (LPVOID)sClient, 0, &dwThreadId);
    " g6 i. o( `- L6 y* [4 e
94.        if (hThread == NULL)
    
95.        {
    5 t- e" W! V' Q: k4 O
96.            printf("CreateThread() failed: %d\n", GetLastError());
    0 @# b8 }( T" }4 J+ J
97.            break;
    
98.        }
    
99.        CloseHandle(hThread);
    
100.     }
     / \/ N/ d$ x7 {) U$ J5 L
101.    closesocket(sListen);
     / ?6 O- b! ~; I. t" G
102.    
     
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

2 h% u$ I  x/ W
" Z1 v; z7 I) ~: N- ~7 N
5 b! W  H( t, [  u9 l6 Q
) X5 ]6 ^* a  N* u

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   8 }9 w2 Y/ K4 r7 V' J
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   $ D3 W' @" {+ K; a3 E% d) B
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   $ M2 d# h; j" v! l6 p4 d
5. 
   
6. Server：
   " C$ N$ h* u& j5 z. f
7. #include <winsock2.h>
   
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   
10. #include <stdio.h>
    8 _: r& l( f& A; x2 M2 l9 u9 b% c
11. void main()
    
12. {
    2 k3 v# }# D7 B* \. _# b
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    ' r) P+ u3 }1 z0 ~( i) A
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    ' s0 E: b# i# l/ P
20.     if (err != 0)
    5 S: e$ g6 [) E
21.     {
    ) {) E2 h' W* g6 ?
22.         return;
    
23.     }
    
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    4 J* q* j6 v$ k6 W( O- E( t- Q
29.          
    - `1 T, @/ \/ }$ y! q9 @) H
30.     {
    " n) p# E3 Q/ W$ x' F/ d; A% ]. u& }
31.         return;
    $ Z7 s6 f  w, u! b) W5 J5 E9 Y2 h: Y
32.     }
    ! ]+ q+ x( E' K
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    ( T# U' r6 }3 H' F; ^/ Y
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    : G% z+ P* K2 M, `7 {
37. 
    
38.          //Socket地址结构体的创建
    
39. 
    - i" M9 x' g3 e  x" I: ?, W
40.          SOCKADDR_IN addrSrv;
    
41. 
      a- P- v  d3 E6 P
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    5 p. C2 \+ T3 ~4 J8 F8 f+ G" m; f
44.          addrSrv.sin_port = htons(6000);
    * K8 y, l; m- X, M) r$ j9 b" n  Q
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    2 P% Q6 Z" e4 E* m5 G( A' L
46. 
    3 d" @- n/ R# {
47.          //将套接字绑定到一个端口号和本地地址上
    % b2 z) A3 i9 h' U: i; m  }, y- L
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    6 [1 X, h5 }8 I8 o3 i
49. 
    
50.          listen(socSrv, 5);
    9 K4 U' \1 k( h% p6 ?! ^. S
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    " v$ E/ ?4 M& w# W% @% r; e/ I
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    
56.          //循环等待接受客户端发送请求
    . e; q4 L+ H: O
57. 
    5 [- D+ W1 X" M1 e* F
58.          while (1)
    2 \2 S( p  u9 g+ _8 W
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    1 ^; N- \& T2 `1 b5 A8 h
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    
64. 
    5 y3 |+ b4 a) Z8 D  B
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    + n$ V: z: p$ m: B+ S# F2 r* b
66. 
    
67.                    char sendBuf[100];
    8 }0 p0 G) m* P4 I8 Y: D
68. 
    # S0 L8 ~: M: q
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    $ `5 n& G% D6 ~
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    7 |' S9 I8 h" y" |  U
72. 
    
73.                    //用返回的套接字和客户端进行通信
    
74. 
    2 i3 e! d3 w2 L7 B8 q0 {8 ?8 A
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    
77.                    //接收数据
    
78. 
    2 t5 x+ B& V4 I' D: i' e
79.                    char recvBuf[100];
    
80. 
    ' J7 Q, F( _' N6 B
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    7 R2 S6 a  d" d5 s
83.                    printf("%s\n", recvBuf);
    1 w9 {( t8 e; Y8 m' g
84.                    closesocket(sockConn);
    
85. 
    
86.          }
    
87. }
    
88. 
    
89. 
    ) e3 ]4 F/ n  D& c) R3 ^
90. Client：
    
91. 
    2 ^6 X8 w+ V+ b7 }& N, s: E" L+ D; y
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    3 f2 h+ c* J( ?. ?: i# }) O8 q: V3 P5 m
94. #include <stdio.h>
    
95. #include <string.h>
    
96. 
    
97. void main()
    
98. {   
    
99.     WORD wVersionRequested;
    + z4 R8 q8 _+ J0 d7 S5 `* Z2 }
100.     WSADATA wsaData;
     
101.     int err;
     , F) e4 _9 O4 s$ X3 ~' E  M. L0 t
102.      
     5 B4 X% |, `4 Z
103.     wVersionRequested = MAKEWORD( 2, 2 );
     9 Q5 x& Q7 A4 D$ E5 G; H/ o5 ^
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     1 x7 M  S; |1 g
107.          
     
108.         return;
     
109.     }
     
110.      
     ( e& W7 G0 {" h% A( L( H. x5 B
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     6 J9 f' o& F! l) R
114.     {
     
115.          
     
116.         WSACleanup( );
     
117.         return;
     
118.     }
       \8 D$ I. f, _+ E; }2 F2 L! Y) M
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     5 s4 I2 N7 x$ A: x% o6 V
121.     addrSrv.sin_family = AF_INET;
     ' T+ t1 u; U$ `1 B3 C8 v9 A2 N
122.     addrSrv.sin_port = htons(6000);
     ) n4 p( X* _2 C/ f/ l4 \2 I) R
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     
124.      
     / x& X- x* C5 t  u6 h: c6 F0 Y& c
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);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     1 I( V* l& E6 A$ _5 S2 p( i2 L
131.     closesocket(socketClient);
     : m( T* a2 i! @- R
132.     WSACleanup();
     2 V" }# _/ c( a$ B' n
133.      
     4 s; d. G% p2 Q' ~$ x( s+ o
134. }

复制代码