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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
( j. C6 F  M. T9 c& r" e# V客户端程序：client.cpp
- N$ {  B) e) E0 i+ P, U7 l4 U

1. #include <winsock2.h>
   
2. #include <stdio.h>
   & p4 ~- t! |4 h0 n
3. #include <stdlib.h>
   / X( ~  d2 i/ z4 }' y
4. 
   : `2 p; ~' v2 J' w+ @: a8 ]% Z
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   + S; f/ W/ Y4 C* m5 Y
7. 
   
8. char  szServer[128],
   
9.      szMessage[1024];
   ( b8 k5 u2 _+ v/ Z+ R
10. int  iPort    = DEFAULT_PORT;
    ! B! {( N" z- j
11. 
    % ~+ H5 E/ z- b( Z& G( f. Y" w
12. int main()
    
13. {
    
14.    WSADATA      wsd;
    3 K7 s6 n' r' M( o2 f
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    7 p5 U5 Q/ B% i2 L! v& V- g! o) c/ L
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  j7 _6 w2 e: ~) m/ b4 Z+ k
23.        return 1;
    1 p1 O5 J& @: D5 S
24.     }
    : B0 G+ Y' b* z2 z2 o- w
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);
    ; o# B( a% H% U" _9 D7 R
29.     if (sClient == INVALID_SOCKET)
    
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    , R0 s2 D" s% p* Q* K
33.     }
    ' m+ n: d3 h- G$ I
34.    server.sin_family = AF_INET;
    + b. m' P, `. L& ?
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,
    + |' D* l; q8 H6 \
39.        sizeof(server)) == SOCKET_ERROR)
    1 W" X  U2 h- n4 r
40.     {
    * i+ L/ W# ^2 {! e8 s8 a
41.        printf("connect() failed: %d\n", WSAGetLastError());
    : S" v& b, J0 H' S, l
42.        return 1;
    $ h) Y& j- {4 Y9 l
43.     }
    ( K4 j9 b5 l0 f' z2 S
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    6 u  }2 Z8 t  w+ E6 V1 x
46.     if (ret == SOCKET_ERROR)
    
47.     {
    % F( Z- ^- p: A
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    , a+ Y3 F  q) B
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    
56.        else{
    
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    
60.     }
    2 _7 v- I5 J# d' g: R% K
61.    closesocket(sClient);
    
62. 
    
63.    WSACleanup();
    6 N1 P" r& m$ B% v3 F
64.     return 0;
    
65. }

复制代码

服务器程序:server.cpp
' C# g  K) J5 L& F9 h. |  A

1. #include <winsock2.h>
   ; G9 q! k+ S/ g+ ~
2. #include <stdio.h>
   1 |4 w. z2 v* d4 Y; Y$ b* i
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   8 u. o5 V0 U* W8 `+ D
6. #define DEFAULT_BUFFER     4096
   4 ?6 M9 d! |& M, a5 y
7. 
   % C+ b6 v, I8 Z6 i7 d
8. int   iPort     = DEFAULT_PORT;
   - }+ J9 D  R) z1 g+ H2 t  X
9. char   szAddress[128];
   
10. 
    6 G' C. O8 n6 ]5 K$ W
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    ; s/ I5 H2 b6 l$ b# L
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    + k: p3 N6 U3 U3 G- ?
14.    char         szBuff[DEFAULT_BUFFER];
    , \. [" O0 u7 q" X9 d2 F# u& g
15.    int          ret;
    9 ~3 F: K" b6 D6 x0 q1 f
16. 
    6 b. i( [- h0 q- N2 o
17.    while(1)
    2 U: @0 ?& Z0 \% c; ]2 e4 B% h
18.     {
      b5 f  L2 x: l/ c
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    $ T! U2 b& Y: \% p
20.        if (ret == 0)
    
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    % n! s2 W9 t9 |5 Y. A
23.        {
    ) T# U6 g0 D! }( h
24.            printf("recv() failed: %d\n", WSAGetLastError());
    ' V( O) u/ J) [9 ]9 E3 R% b
25.            break;
    4 b4 n6 b* W* I/ {
26.        }
    
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    
30.          memcpy(szBuff,"Send the correct string!",25);
    2 w6 B/ I+ w6 ]; T6 P3 c' M4 |
31.        }
    
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    : \7 i4 N9 A- w( s$ k7 x
34.        }
    1 i4 B9 g) p1 o. q
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    + {( K; W! S) U9 Q3 C+ }
38.        }
      d! z7 {7 L  l7 s
39.     }
    ! C) T8 {4 n/ e' w1 |4 _8 X' f
40.     return 0;
    
41. }
    & \& }/ ?8 X- ?! e3 q5 Y
42. 
    
43. int main()
    ( \. H7 N3 N0 _1 m
44. {
    : p# I" N! c# p" N! R0 w: ~
45.    WSADATA      wsd;
    / X# P  B2 B7 A& n7 o
46.    SOCKET       sListen,
    
47.                  sClient;
    " l: g: D8 `: x0 j5 r' S, r# d
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    # Y. Z: r0 p7 o8 E* m8 k
50.    DWORD        dwThreadId;
    ) S# q1 g  K. T  T# N; l: {5 n
51.     struct sockaddr_in local,
    $ s* M9 ^  `- w0 ~  I$ A
52.                       client;
    ) m- ^0 N1 K+ j/ c* E* g3 x4 o3 m
53. 
    , f2 `9 d. k4 A! M
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    " d& Q# y% X' v; R( C4 Z. ~
56.        printf("Failed to load Winsock!\n");
    4 t: K  k, Z: l9 s
57.        return 1;
    
58.     }
    
59.     // Create our listening socket
    ! G2 q! X5 p5 h9 p
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    % \7 Y8 Q) l) R: S
64.        return 1;
    8 n7 `. J& o* K+ \; p! k
65.     }
    % u% u  U- ~( H6 W, y6 K$ Z
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    ) L6 P% K; c: M4 k8 O8 L
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    
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
    4 D0 m& ^2 @! V
78.     // is detected, create a thread and pass the handle off to it.
    
79.     while (1)
    
80.     {
    1 z" |) \) e" |( a
81.        iAddrSize = sizeof(client);
    6 D6 s; [- _' t
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    8 v! C+ q  ~! W  ], r
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    ) B! W0 P9 u# Q7 K4 m/ z+ d' x5 x
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    " I+ a. D- _3 g0 Z
87.            break;
      c9 _* A; _8 A- {6 J5 k
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    - y( t6 m% w8 M! G& L
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    7 ~' x: c7 i% l3 @7 R% b5 |3 ~
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    / m: N# A! L: U0 q8 g4 t) d6 J
97.            break;
    
98.        }
    
99.        CloseHandle(hThread);
    
100.     }
     : z3 e" S( R" r- Y# w  R
101.    closesocket(sListen);
     
102.    
     - l9 t+ O, Z7 x4 A5 q( Z6 T
103.    WSACleanup();
     5 r. N4 H  I/ V, l( I
104.     return 0;
     1 {. t. s/ P9 T1 Z& A- p1 s
105. }

复制代码

) `$ e' l5 K, ]5 c. d
$ q4 p8 h- a1 c, ^! o
% l) b) C# q$ u& R/ c; Y
, h* Z; }' ?" j* T3 m

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   . l2 a7 z+ C- u  R3 i
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   " W2 P  t9 W3 K
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   * \0 c' J+ t8 S: b( b
5. 
   
6. Server：
   : G; O- j* m* `  P, ?6 e
7. #include <winsock2.h>
   
8. #pragma comment(lib, "WS2_32.lib")
   " w1 r1 _! P+ p6 ~, M
9. 
   0 H+ [, @6 v6 X* i2 I
10. #include <stdio.h>
    
11. void main()
    
12. {
    + {) v2 C: R/ _. @" m; @& K, F
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    , {- l1 o$ X; u: P+ \1 K
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    # _0 Z( k  x- b$ \! }, h- n
19.     err = WSAStartup(wVersionRequested, &wsaData);
    4 k8 y) c, e8 i& K/ {, O
20.     if (err != 0)
    * P, \  k1 g% H2 P  L
21.     {
    . d; G/ |. _: P, u& t8 N  X( j8 I$ J
22.         return;
    / E- G  E1 D$ G, f2 }) f
23.     }
    ( a9 M0 }" i6 g: E, l9 v+ ?( ^! i
24. 
    3 {8 C0 F, Y* H; E
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    ! a  m6 ]1 j7 z
29.          
    * }3 W! s- W; D! m% l- d7 ?3 U
30.     {
    & M# X8 |! w$ }4 c9 U3 l; {
31.         return;
    / v. s: @  R/ P2 o4 c
32.     }
    " \+ H& C! @0 s. s: j% }8 @
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    * O9 J& Q) o2 v6 L
37. 
    
38.          //Socket地址结构体的创建
    + Y+ H! X8 F& @% [
39. 
    
40.          SOCKADDR_IN addrSrv;
    
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    % h( Z6 K5 I+ g0 T6 S
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    , `  ^! m- z* J
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    ' C' R" R' H8 X7 Q0 R9 b9 k
50.          listen(socSrv, 5);
    
51.          
    8 Y) Q, I5 Y: L" n: d
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    " I4 a' O3 D; ?9 @* q8 j# J
55. 
    
56.          //循环等待接受客户端发送请求
    6 x/ B* V( |. v  J1 i8 U! Q" M
57. 
    
58.          while (1)
    : Q+ w/ b- p2 {6 `  n2 ^
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    5 w: A2 c( A3 v
61. 
    ! \0 A/ ?+ ?' R) N
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    " W) V9 ^; P, C0 j+ X; l
63.                    //此时程序在此发生阻塞
    7 o' N! a( q9 p6 @+ l
64. 
    4 E' ~6 B$ B9 P8 |& V5 b; f8 r
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    ( M" {9 w5 _) o& I- M( z6 T$ V
67.                    char sendBuf[100];
    $ H/ \% K, k) B9 c( S' T# s. e
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    
73.                    //用返回的套接字和客户端进行通信
    
74. 
    4 F9 D4 k* u$ ], Q/ ]
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    # I* e7 m( M  f! ^2 e
76. 
    ) g4 Q- v) y9 @( M
77.                    //接收数据
    
78. 
    
79.                    char recvBuf[100];
    
80. 
    ' I. L% `) m8 E- f) h$ G! G
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    % L7 v& @* n  H& W8 n- h9 b
83.                    printf("%s\n", recvBuf);
    & v& t) Z+ a% A* i
84.                    closesocket(sockConn);
    
85. 
    $ ^/ ]7 C0 a# r. w1 ?0 R1 J
86.          }
    2 I# C' F- y9 V$ x
87. }
    
88. 
    
89. 
    - c: ~1 c2 S1 D: M% S
90. Client：
    ( ]1 c' U, s) w6 c# U  g( H2 V
91. 
    + D. ^% [. J0 k4 y- S0 u
92. #include <winsock2.H>
    . v5 l' A& T+ X4 M/ n
93. #pragma comment(lib, "Ws2_32.lib")
    6 j3 {9 x! D4 A+ L. _
94. #include <stdio.h>
    
95. #include <string.h>
    
96. 
    
97. void main()
    
98. {   
    / ^" T$ ]: E, y7 V" ]- L) w
99.     WORD wVersionRequested;
    2 X5 Y% C& G& {: Q7 q' Y
100.     WSADATA wsaData;
     8 p& G- U2 g" R4 @1 T% r$ A2 D7 Q
101.     int err;
     5 F6 @: u3 M7 V* U& m
102.      
     . C7 I8 W" y: s* ^
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     ; u+ k. ^. K: \/ R% z" ^' ]& j
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     
107.          
     % ?, ~* J3 @- C% l3 k
108.         return;
     * M# P2 V0 i  J& D6 p
109.     }
     
110.      
     
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     6 y, n* B5 R8 ^; N2 h$ }4 Z8 u3 C
113.         HIBYTE( wsaData.wVersion ) != 2 )
       q+ ^. l+ k2 i% h$ r
114.     {
     " Q1 C3 C2 h9 s! Z( w
115.          
     + M  [/ S: G: V
116.         WSACleanup( );
     7 k. N5 @* K! Z
117.         return;
     
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     5 P# b  ~9 \" G2 X! Z
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     
122.     addrSrv.sin_port = htons(6000);
     ; m9 C$ X$ t( \; @9 b3 ?* c
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     ) [; V1 I- t  J9 F# F  r
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     7 k0 @; h! _1 A$ h2 a0 P
126.     char recvBuf[256];
     6 B- b$ O5 `  e$ ]% q' m, k
127.     char sendBuf[] = "This is Joychou";
     . N; T7 q" _- T8 W
128.     recv(socketClient, recvBuf, 256, 0);
     ( c3 O) d6 G/ \
129.     printf("%s\n", recvBuf);
       P: @, b& @) I9 W
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     ; W  L& {2 b& ?  T0 Y( F$ G! t
132.     WSACleanup();
     
133.      
     
134. }

复制代码