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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
" s5 q" |# c# Z1 k2 u! J客户端程序：client.cpp
7 h  \# X: r: Y: n* f

1. #include <winsock2.h>
   
2. #include <stdio.h>
   , L2 |! @% Z5 ^# I7 I9 V2 A
3. #include <stdlib.h>
   
4. 
   $ M; A  g" X& f$ E' X
5. #define DEFAULT_PORT       5150
   5 l4 d$ d: ~& v% y; g% w! p
6. #define DEFAULT_BUFFER     2048
   ' e2 p3 r# @7 ^) v2 j
7. 
   . h* ^6 @3 {, g1 C( [2 k5 j) s
8. char  szServer[128],
   ' e$ g8 ^; v5 P( _
9.      szMessage[1024];
   , x! P$ |* p6 U5 l6 h
10. int  iPort    = DEFAULT_PORT;
    " I' F2 N% j% r  b, H
11. 
    
12. int main()
    ) B4 h0 M4 J/ i" D4 v) t" `" E
13. {
    2 Y" M& o0 g2 l$ M
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    4 B' y7 f$ F6 D( r9 Z& `. }
16.    char         szBuffer[DEFAULT_BUFFER];
    ) {- ~1 E" `3 F: ^6 }8 F
17.    int          ret;
    4 c0 L9 n2 D0 F+ s* i+ B
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    2 P5 \! m% S* [" I3 y+ e
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    . ^) A$ P; j, w0 c
21.     {
    ' s' \$ A7 ~4 I
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    
24.     }
    2 `# B9 L3 R- z5 u5 |( Q
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.     {
    " z' k# D& j9 |- Q1 M1 f4 {6 \' K
31.        printf("socket() failed: %d\n", WSAGetLastError());
    8 f7 q* H/ _- ]( o% _$ b
32.        return 1;
    
33.     }
    
34.    server.sin_family = AF_INET;
    ; N7 ?6 B# H& o
35.    server.sin_port = htons(iPort);
    + C5 q* e, O0 F
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    1 R0 W2 I# l7 |/ b
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    0 F7 D4 u* Z2 H; |
41.        printf("connect() failed: %d\n", WSAGetLastError());
    $ E' P6 M: U0 {# c
42.        return 1;
    
43.     }
    ' d# \, w% |% l3 J; K4 ?4 [. t& v
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    4 Y3 S$ `9 A  n' T; L1 w! Y2 L
46.     if (ret == SOCKET_ERROR)
    
47.     {
    % r  B1 b( `( c4 ?
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){
    # E1 n. ~# z2 r6 }5 L0 R
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    
56.        else{
    
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    0 r- C: ^: V5 X2 B% M4 `
59.        }
    ; d. |9 \/ D- ?2 L* }
60.     }
    
61.    closesocket(sClient);
    
62. 
    
63.    WSACleanup();
    - P1 {# T. A% M! W) b
64.     return 0;
    
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   9 r" q8 c' Y& {) t& Q
2. #include <stdio.h>
   5 K/ G, G9 C1 l  Y' B. L
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   , Q# N$ c8 G+ }% J
6. #define DEFAULT_BUFFER     4096
   ' h/ W" D1 j3 H7 x5 Z1 b
7. 
   8 P$ k( [2 K- @2 E9 B  \3 s; \$ ^+ ?: T
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   # e3 y6 w. C0 y4 A
10. 
    5 U/ @, M* E' f  g( X4 T$ ^9 V
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    ; s: {) H8 F: r
13.    SOCKET       sock=(SOCKET)lpParam;
    2 N) b# ?1 }" T2 n7 V- u8 C7 j$ r0 n& i$ A
14.    char         szBuff[DEFAULT_BUFFER];
      {: [. o/ p' }4 S8 U; v! k, B; W& u2 H
15.    int          ret;
    
16. 
    
17.    while(1)
    5 k0 X, Y: F" R3 G4 b' _) w
18.     {
    
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    ( ]7 y8 q6 C0 ]7 Z, W
23.        {
    $ A" M8 s' ]2 n3 o, c- D5 q/ T
24.            printf("recv() failed: %d\n", WSAGetLastError());
    - R! h! ^( f+ I2 r$ Z6 Q* U
25.            break;
    
26.        }
    0 x8 p" \8 v# G# i9 }: H% f
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    . ?  D" g" }2 F) E+ s. g; c' U3 t
29.       if(strcmp(szBuff,"abc")==0){
    2 X% r% E" |- n: n' A$ v
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    
32.        else{
    ' {/ B7 ?; A/ `. i8 E
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    / T: H5 `  t' n/ H9 \6 }. D
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    
39.     }
    
40.     return 0;
    
41. }
    
42. 
    
43. int main()
    
44. {
    
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    ' B; `6 U3 T" p: F! p
47.                  sClient;
    5 ]8 c  N5 n" K5 ^0 y, N
48.    int          iAddrSize;
    . u4 E, i- B; k* M7 i2 I" U2 @6 x$ E
49.    HANDLE       hThread;
    6 J# G9 I2 \) t3 a7 B& o
50.    DWORD        dwThreadId;
    * h$ R' _5 Y- w" g0 e2 U/ V
51.     struct sockaddr_in local,
    
52.                       client;
    " r0 P- I/ u& a! P* k: F
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    - f' z9 y; o  B1 K$ {' e
55.     {
    
56.        printf("Failed to load Winsock!\n");
    0 a8 @; W& x& v. C9 h
57.        return 1;
    
58.     }
    8 n4 E, N: I, s4 B% ^
59.     // Create our listening socket
    8 y- d% f# @0 T1 D- O: L
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    9 l6 Q/ K+ F( x/ e1 Q
61.     if (sListen == SOCKET_ERROR)
    ' l0 S) l8 o; u" K' z: ~3 w
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    8 x5 g' P1 S' J! d
65.     }
    6 t) Y4 ^6 e  u- a4 p/ Q; R. U
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    8 M. V- p4 h/ g$ m) k' l
68.    local.sin_port = htons(iPort);
    : T. S' e( D( E' c+ I# J- A1 e! a5 r
69. 
      X( v* P* v5 _  I( ?, l& k2 Z  \
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    9 n7 N0 u7 O" h
75.     }
    
76.    listen(sListen, 8);
    
77.     // In a continous loop, wait for incoming clients. Once one
    & c: _0 }# R/ V% X' v( a4 f
78.     // is detected, create a thread and pass the handle off to it.
    
79.     while (1)
    
80.     {
    ! i; m4 ^% w, k7 ~9 i! c2 `
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    1 ]# v- w% c% T  g5 C  t) _0 O
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    0 Y6 X" ^% M; t7 |0 E
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    
88.        }
    & b/ H& I1 a  [' X* J
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    6 {$ B6 O) K/ n
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    ( F# k+ X3 }' [3 K# O1 p, V
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    2 w, M7 t- E' S1 A8 @3 n( z8 x
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    * w# I$ h' E, P3 ~4 m% B
97.            break;
    
98.        }
    & \! ^: ?+ C# H$ ~7 u
99.        CloseHandle(hThread);
    
100.     }
     
101.    closesocket(sListen);
     
102.    
     
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

6 H/ z  u  U1 a- N4 I8 y9 K
$ ?, ^+ W( X, C' X2 L# f

3 T* W4 Z8 u3 F- w0 ]+ Y

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   0 z- A! w/ }0 Q4 K3 P
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   
6. Server：
   ( U# ~. ?- J; l- s: k* e* i8 t
7. #include <winsock2.h>
   . W) J' ]* `6 I
8. #pragma comment(lib, "WS2_32.lib")
   4 V7 l. O8 H* I4 _" p
9. 
   : f" E* G2 g: T0 L6 ^
10. #include <stdio.h>
      x$ g; Q1 Y  F$ n; W0 e3 S
11. void main()
    & ^4 E$ K0 @% H' [1 ?, @1 E
12. {
    5 b0 q5 t# C: u- e" i/ |
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    1 \' u' x7 t; z" Z
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
    
21.     {
    
22.         return;
    
23.     }
    
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    * t/ E" Z& R, r, ~
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    
30.     {
    
31.         return;
    4 K3 J* U# z* R/ q- P, y
32.     }
    
33.      
    1 j' D: h9 A! a! p) a
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    2 r# e/ q# `9 a* r  ~
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    6 U2 b# _% K9 I9 ^2 p  {8 ~
37. 
    , [+ s* E2 a( L2 F
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    
41. 
    , o6 F" N' i$ K
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    5 i! o# n  u2 k& O9 e7 a  _
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    $ D1 a0 h$ o8 J& c; [7 h; E9 G
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    7 W! |4 `# X- P$ U) I$ Q* t- G
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    & @; h9 E# e7 Q- |, s: }, s  X- d
50.          listen(socSrv, 5);
    
51.          
    4 b3 ]( o; x  i3 m" m
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
      N5 m0 e5 Q% Z& P
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    
56.          //循环等待接受客户端发送请求
    
57. 
    3 w  T  b5 P+ ]2 v2 v' a; N$ \
58.          while (1)
      z- b7 O+ v  a; Z7 x
59.          {
    ) `9 b% q% P' F9 h7 f  a
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    # \* @. h. f6 q: R: L
61. 
    5 P& k3 a  ~/ x' p5 U( ^
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    3 }! p) y3 t" [7 _$ S/ N
63.                    //此时程序在此发生阻塞
    
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    8 P1 L1 ~2 ?1 G& i
66. 
    5 n- j/ O; K( q1 ~6 K# ^
67.                    char sendBuf[100];
      R5 }/ m% d0 x* p' \; X
68. 
    ( P. L( ]4 m% ]
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    9 a; y/ r6 Z: f7 K, q, |
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    4 H9 z: b7 d* @8 t
72. 
    0 K8 }/ ^" v6 s* _  n3 B( J0 w
73.                    //用返回的套接字和客户端进行通信
    
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    % `' D9 P2 j' q- g4 e9 s' F' G
76. 
    9 G% r' Z. s# P' v
77.                    //接收数据
    * e5 z( `4 k) B& j, z. D
78. 
    
79.                    char recvBuf[100];
    & P& D! p. ?& d% \7 h
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    , E# h+ L" {2 {) I$ B' v6 R& ~
82. 
    
83.                    printf("%s\n", recvBuf);
    % N: t1 U. v; j- e! b  A4 Z: P( x
84.                    closesocket(sockConn);
    
85. 
    
86.          }
    
87. }
    
88. 
    
89. 
    
90. Client：
    
91. 
    
92. #include <winsock2.H>
    ) g1 F* ~* O% N5 ~% }  [  |3 \
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    2 }8 ]: E- X+ k+ N
95. #include <string.h>
    
96. 
    / G: W$ g# i, K" z4 |% g2 Q
97. void main()
    # m/ b; s- W% X9 D
98. {   
    
99.     WORD wVersionRequested;
    5 B7 B) P3 H' r; {4 n3 `- G
100.     WSADATA wsaData;
     
101.     int err;
     % U3 r2 v! f- N9 Z( q
102.      
     * u9 H1 d  ]+ A& w& x  Z7 B1 V+ V
103.     wVersionRequested = MAKEWORD( 2, 2 );
     ; L; O& s5 R" Z) L' W: T& ]% W
104.      
     ( |; I- |$ e! z0 W; K$ T
105.     err = WSAStartup( wVersionRequested, &wsaData );
     2 d, e# a5 P# c% y* e+ J
106.     if ( err != 0 ) {
     
107.          
     
108.         return;
     % U6 O! k9 [6 w' T9 k* v
109.     }
     
110.      
     
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     1 J6 }6 K0 Y# K3 y
114.     {
     
115.          
     
116.         WSACleanup( );
     & q; w7 D2 ~- P6 ?" Q
117.         return;
     
118.     }
     ' J, |4 h( ?- k% c! X. m+ I+ H
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);
     & `  f, O) K- Z8 v; P  e3 h5 z) ^
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";
     ' Q8 Y% `$ k) Y- i
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     , a- ^/ Y. \) h2 |) k5 H3 p; ?! m
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     - i. _  e1 y3 `$ v
132.     WSACleanup();
     ' a5 y1 `8 ?9 t, P- J1 `
133.      
     3 `" L$ l8 H. ]0 X
134. }

复制代码

- A. G( F+ g( ~" Y' g6 o' B! K$ j