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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
7 M3 u: j3 l4 G8 f" u3 y4 W客户端程序：client.cpp
& T, J: T$ s+ J

1. #include <winsock2.h>
   % j$ m4 W% P5 T7 [& p# Q( D
2. #include <stdio.h>
   ' U- |# I- A$ X" I  t  h
3. #include <stdlib.h>
   - o5 l( c' i0 ~1 ?
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   
7. 
   
8. char  szServer[128],
   
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    % O( g" ?% G. M6 @; m4 i6 B
11. 
    
12. int main()
    ! _5 C, ]8 t  f; R
13. {
    
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    
18.     struct sockaddr_in server;
    * h. ~* D8 U( \; M. S. F
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    ! Q& i  _. r( u8 _% y& n( y0 N
21.     {
    $ ]2 q: ^+ [! O, r% x; k$ F/ P
22.        printf("Failed to load Winsock library!\n");
    - E9 {4 W# i# \' f
23.        return 1;
    # n7 U7 \7 b6 n0 z8 E. W
24.     }
    + O6 p7 j1 M$ y2 ]$ Y
25.    printf("Enter a string to send to server:\n");
    2 ?7 W; S5 |  D$ g( }" [
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)
    % x% [/ Q+ S; n! U* S0 m2 S
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    0 R$ s+ P4 I3 V6 _
32.        return 1;
    
33.     }
    ! X+ u9 Q. ]) b& ?
34.    server.sin_family = AF_INET;
    & N( q& Z+ W% B+ B8 J  ~
35.    server.sin_port = htons(iPort);
    5 _, y' @. h( h3 x
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    4 X' s& C. n5 c4 \, P6 N
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    / y' G" i( t% \0 _  ~- e3 L2 b5 {4 U
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
      p1 ]9 W. U0 _8 O. |2 e# B
42.        return 1;
    0 B7 v: Z2 f  z3 W# |" u* }2 }0 _
43.     }
    
44.     // Send and receive data
      x$ N7 \; X, j
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    4 ?% U. \+ C8 M: K# X
46.     if (ret == SOCKET_ERROR)
    % r( P5 _' Y! R: z4 L- X, s( L- r
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    " ]! y. o) ?! Y. T& C+ K/ B) ?- }( j5 V
49.     }
    
50.     else{
    5 y/ \9 Z4 f3 c- C: i
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    + b& @: ?* B9 s, G' |# w
53.        if (ret == SOCKET_ERROR){
    ) k) R) B2 ?9 w+ O4 \
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    
56.        else{
    : E& O3 [; C/ v( \7 n
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    & _" X& T; [0 y. b# z( D% L; _
60.     }
    
61.    closesocket(sClient);
    
62. 
    
63.    WSACleanup();
    
64.     return 0;
    ; R( N; i: J! ?& M, G
65. }

复制代码

服务器程序:server.cpp
( h7 k( R. P0 ?0 k& r* g3 C' H

1. #include <winsock2.h>
   2 u% j) d/ V& T* y9 b7 Z! y
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   + N1 u3 j, O4 {  C$ F; l* r% a
6. #define DEFAULT_BUFFER     4096
   6 c" Q1 j  I" K, S1 H' z$ A. j
7. 
     i4 u5 F9 T2 F- k1 h
8. int   iPort     = DEFAULT_PORT;
   ' T& z. T7 n( z3 Z( b+ Z
9. char   szAddress[128];
   + c1 z& C0 ]3 U+ e
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    # l8 P6 J7 R; G1 H5 g- D+ E
12. {
    3 D8 b* N/ x. J* V
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    $ f# W: ~* {6 r9 a& o" E8 h
16. 
    9 X' ^/ ]; ]; ~* l5 _
17.    while(1)
    
18.     {
    
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    5 A; X: k% P, v8 M* M) l6 W& g
20.        if (ret == 0)
    
21.            break;
    2 N8 ~2 H; N6 f, G" }6 ^) @
22.        else if (ret == SOCKET_ERROR)
    
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    # o! r1 v# t9 t; o6 L- X
25.            break;
    
26.        }
    
27.        szBuff[ret] = '\0';
    % b1 ?( R" b" x" `. N
28.        printf("RECV: '%s'\n", szBuff);
    $ B. j, p% k! {1 z" c
29.       if(strcmp(szBuff,"abc")==0){
    2 \' P3 u; R5 ^& m+ @
30.          memcpy(szBuff,"Send the correct string!",25);
    $ s) r/ k# q) O; ~4 Z
31.        }
    * h  ~. R6 W1 G( {) S* U
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    $ k! U6 ?8 M& W  R  ]$ {9 w
34.        }
    4 ~* s8 V9 z& \3 X8 c
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    ' i$ M0 t- q/ U- H4 u8 n6 o. B- ~7 \9 T
36.        if (ret == SOCKET_ERROR){
    1 u: I4 q" C+ C! L
37.          printf("send() failed: %d\n", WSAGetLastError());
    0 |' J* ~6 i' r% a- B
38.        }
    3 L9 L: l8 K# u6 F  o
39.     }
    # v- Z: U2 n: L
40.     return 0;
    
41. }
    
42. 
    
43. int main()
    
44. {
      f8 o  `) ?( \$ w
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    4 c4 j+ U9 O1 m% Z! c  @2 U
52.                       client;
    
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    4 O$ `1 M' l7 h/ _
55.     {
    - ]. I* u- Y: O  V; w
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    
58.     }
    ( h2 r; |7 m& C5 S. \
59.     // Create our listening socket
    6 K+ C1 i# Y; x, r$ h# x* T$ ?1 ~
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    " y- s9 C' r8 z  z# v% u2 k
67.    local.sin_family = AF_INET;
    ; |2 {$ b% ]1 n3 _, h9 F  Y
68.    local.sin_port = htons(iPort);
    ! K$ p8 T9 d8 I8 F/ W( l" I
69. 
    1 ]6 E* H. O4 ?/ e9 l; T) z' O
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    & J4 t, H" o4 c4 }! ]2 a0 w6 o- J+ Y, {
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    
75.     }
    
76.    listen(sListen, 8);
    & F9 N5 i* s/ U! F4 T& |/ d
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)
    
80.     {
    5 U1 p0 P# \" n" z& L# W
81.        iAddrSize = sizeof(client);
    " e  z( |7 H" d/ y! J- W% u1 p, s4 a
82.        sClient = accept(sListen, (struct sockaddr *)&client,
      O3 @9 P* O6 H9 \3 R# q" T' T0 l
83.                        &iAddrSize);      
    ; L% Q* D% Q, _- t9 m1 ^1 [
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    3 |9 m- [4 \( d8 {6 t1 {0 U& `( }
87.            break;
    
88.        }
    , B. d+ L2 K4 G9 A  C
89.        printf("Accepted client: %s:%d\n",
    $ m0 j- f* \7 e! Y
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    , O$ b' X9 S5 n, s
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    # z0 R' g9 a2 u9 [2 R! S
94.        if (hThread == NULL)
    , M0 n) Q1 p: T1 Q8 ]
95.        {
    / l/ _, W2 |# t, q
96.            printf("CreateThread() failed: %d\n", GetLastError());
    ; X0 j/ m+ j! P6 y! v& d3 u
97.            break;
    # y8 H9 n9 _1 u" L! r* t
98.        }
    
99.        CloseHandle(hThread);
    0 A! X0 g: a" {& @; @% n5 R3 B9 m! e
100.     }
     
101.    closesocket(sListen);
     
102.    
       m: A8 I, Q* q9 I" f2 z; _
103.    WSACleanup();
     
104.     return 0;
     2 n% _# A3 D8 @
105. }

复制代码

, I9 h4 F& Z2 }& ?7 u
+ m) C# P  l9 w' r& q
% n) s# q9 X4 U* C

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   7 G7 ]; }* T# }6 m
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   # l6 f/ u, I5 u, D' v# x5 f
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   / K5 B: a5 _3 J% W' g* ?
5. 
     C% F  J' u) w  [' C$ a
6. Server：
   
7. #include <winsock2.h>
   / l6 O; Z5 N4 A
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   ) ?& D3 B! o/ f% P* g" J+ s
10. #include <stdio.h>
    
11. void main()
    3 O; w4 u- g6 G: C% [+ |/ q
12. {
    0 y% T$ b' Q* h' u% ~5 s
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    & s+ S) r! t# Z, E9 F5 c
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
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" f+ p7 o5 n% Z
28.         HIBYTE(wsaData.wVersion) != 2)
      b" s3 w& P' A. Y8 b* ^. z
29.          
    1 ~  ]) n5 D6 ~3 ~! D& j
30.     {
    
31.         return;
    . V, T' Y/ f- x& D$ I& n3 T: E
32.     }
    6 [) ^; d. w7 A0 t4 J7 F
33.      
    ' {1 x* F: S3 p! X
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    . [1 C  `0 x3 R' i. ^
35. 
    ; v$ b4 J$ g0 k; ~2 v
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    
38.          //Socket地址结构体的创建
    4 w3 z& [- Y* G/ b5 a
39. 
    + T3 T/ y* v* _* ^0 J
40.          SOCKADDR_IN addrSrv;
    
41. 
    $ F& ]- B8 Q5 j& S
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    
44.          addrSrv.sin_port = htons(6000);
    , V4 j; b0 |# k8 W% O  g" P
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    / i/ \1 x0 ~0 b7 N- ~% ~
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    # `% U& [; p% n) Q; [* r7 Y
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    / L5 \- w7 V! I
50.          listen(socSrv, 5);
    . u5 `" Z) t; p
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
      v9 l9 Z+ P7 b* g# a7 n
53. 
    3 t7 M3 m' U, N# O
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    , E( M/ d" p/ ]
55. 
    : a4 N* ^  Q( `; W! ^; X
56.          //循环等待接受客户端发送请求
    
57. 
    
58.          while (1)
    ; J$ j# q& e5 C
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    ) {) W: V6 w- h& e8 ?, k
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    
64. 
    7 ]; a. ^0 V3 `& Z. g0 k- _
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    
67.                    char sendBuf[100];
    
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    3 H: C# _0 E3 C  h1 j$ c9 B
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    ( |0 _+ R* a2 Y; q/ I1 y4 A& i( h
72. 
    * X, n: _& X) ~( e" S
73.                    //用返回的套接字和客户端进行通信
    
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    ) [, n# c: _; a8 ~0 [
76. 
    7 W. Y( ^  B8 E7 V
77.                    //接收数据
    
78. 
    / M5 W! M* T3 C. h) x$ X
79.                    char recvBuf[100];
    
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    + Z, [  E6 t% ^3 z7 i/ q6 e
82. 
    1 g6 y( l3 \& [/ O/ |
83.                    printf("%s\n", recvBuf);
    - C4 s( T; s. l' `/ {
84.                    closesocket(sockConn);
    % f" }3 Z1 d% N3 k* S: }3 Y
85. 
    
86.          }
    
87. }
    
88. 
    
89. 
    
90. Client：
    
91. 
    3 ^; K' l8 H! I
92. #include <winsock2.H>
    7 l9 V: `7 o5 _# l
93. #pragma comment(lib, "Ws2_32.lib")
    " N' c: o6 H( v) Q
94. #include <stdio.h>
    
95. #include <string.h>
    * Q# o, I3 }8 O! O6 X
96. 
    * x! D# T  c" B: M
97. void main()
    
98. {   
    
99.     WORD wVersionRequested;
    $ N! d! V) D! M# S
100.     WSADATA wsaData;
     # u# Q. y2 k1 A$ ?) M! R, q
101.     int err;
     
102.      
     # L9 m1 J/ V+ q  z
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     & {" J% ?8 n+ c! R9 m' O: c" R
106.     if ( err != 0 ) {
     0 N& D8 b$ e+ m" Q
107.          
     
108.         return;
     # f( A* U; `+ G+ c; x; a9 v
109.     }
     
110.      
     ! E3 t+ N. f+ g6 l& ?3 }+ @
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     5 [! k$ f) a! s* Y
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     
115.          
     4 G+ k+ s+ g9 a. S4 T) e0 d
116.         WSACleanup( );
     0 d0 g/ u, Q4 |; M
117.         return;
     ) a6 g  ~& J7 N2 Y- W/ b" c
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     $ @3 E* R3 f2 v- ^) h8 z# }
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     
122.     addrSrv.sin_port = htons(6000);
     
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";
     
128.     recv(socketClient, recvBuf, 256, 0);
     - A8 y( [4 {7 y7 C- B
129.     printf("%s\n", recvBuf);
     ; y8 c4 [( R" x* x; R2 h! R* @
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     ; b' \0 i5 J# C% f" M0 z
131.     closesocket(socketClient);
     
132.     WSACleanup();
     
133.      
     + y2 V  R, Z9 X% \0 a4 ?: C
134. }

复制代码

' w" y0 b5 G# w& o4 S; g