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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
客户端程序：client.cpp
+ _7 G. O5 \2 K

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   8 _9 u; O/ v' I; h2 E
4. 
   
5. #define DEFAULT_PORT       5150
   / K% u6 v3 _4 [. l% o2 S6 \& p
6. #define DEFAULT_BUFFER     2048
   * Y# n  j: b5 d! p, |
7. 
   
8. char  szServer[128],
   
9.      szMessage[1024];
     Y1 w' v2 z! i0 {2 j
10. int  iPort    = DEFAULT_PORT;
    
11. 
    2 W4 D$ A/ E" b; l  o; I
12. int main()
      h& A4 f7 w0 f0 _" E! l+ H
13. {
    ! {0 Q1 Q4 Q4 {& s- Z
14.    WSADATA      wsd;
    ) v/ T0 {  ^# ^. R  y
15.    SOCKET       sClient;
    ( I* Q( K) Y3 O
16.    char         szBuffer[DEFAULT_BUFFER];
    6 X, H6 C8 u; c7 x2 _
17.    int          ret;
    % z" j5 ?7 z8 y. Q# X/ n: y
18.     struct sockaddr_in server;
    , \$ x; Y# w3 A! X6 a
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    ! b* L, ^; V$ Y8 t, P
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    
24.     }
    $ m/ B4 I" Z1 y, u7 p
25.    printf("Enter a string to send to server:\n");
    
26.    gets(szMessage);
    0 y1 U- V" x! ~4 O4 w9 f7 }
27.     // Create the socket, and attempt to connect to the server
    2 V$ f/ O) w4 N9 Y
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    ! _+ o0 p9 R6 W3 [- Q5 x+ ?# p
29.     if (sClient == INVALID_SOCKET)
    
30.     {
      W! k$ S: m0 c" R* w5 `
31.        printf("socket() failed: %d\n", WSAGetLastError());
    , X9 ]; U( I$ s& k; M6 S
32.        return 1;
    
33.     }
    + q3 W& F8 K- i+ H0 j0 W. ]
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    + \' e1 w& ?, F; t4 P* Q# n
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    + U& x8 @; z9 J
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    - ~- C( e$ [4 z
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    2 A! Y3 F. ~; K" J2 Z  t9 y
41.        printf("connect() failed: %d\n", WSAGetLastError());
    9 c* s& Z0 u/ b! [4 x; {
42.        return 1;
    / j. T# M- ?( B2 i7 M' O7 P- o: D' V
43.     }
    8 B9 O* _+ {* j- L6 I- v5 d
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    2 f" _6 U1 Y. d/ y! d  @2 h
46.     if (ret == SOCKET_ERROR)
      e9 e* R, a  ^: B
47.     {
    0 Q* ^! a" D4 ^
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    : e. m8 ?3 V) e
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    3 b, I0 \% f6 |6 a$ F) y3 G
53.        if (ret == SOCKET_ERROR){
    ) o8 c8 O. H: c7 s! t9 y/ |! r
54.          printf("recv() failed: %d\n", WSAGetLastError());
    # p* r% F; S& w' O" r
55.        }
    
56.        else{
    % R# g. w3 ^/ J
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
      K# \6 M0 T, p6 X
60.     }
    ) Y" i# m8 y5 p! p! R9 B" c
61.    closesocket(sClient);
    6 A+ X/ `1 O2 _# ]6 B
62. 
    
63.    WSACleanup();
    
64.     return 0;
    : K) y: p. N; L
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   ( \2 F, C: Q1 p. U4 A2 t
2. #include <stdio.h>
   ! f" j1 V  P/ H3 s
3. #include <stdlib.h>
   
4. 
   $ @! T6 ~- [; K  N9 d
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     4096
   6 ^  Y/ l$ j) g9 t. t- H( p  L
7. 
   $ B+ W# U( \, i0 z% b3 ~, r* V" @- i
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   % J+ w& T1 E' g: C1 N6 t+ O
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    ! [# ~( J- R2 U3 I
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    
16. 
    
17.    while(1)
    
18.     {
    4 `! W! X* y& M9 l; r1 s: N
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    8 I/ g  |* U  _6 ?, h5 f8 u
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    7 R; X7 s' v  j4 S. o4 _& S
23.        {
    1 \; f$ h/ G4 X: F
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    4 V  F9 P7 `$ ~6 V& H
26.        }
    
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    8 U/ F: Q" e0 Z3 {( l( x7 e
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    
32.        else{
    & j$ h& g  Z, q, a5 y' e
33.          memcpy(szBuff,"Send the wrong string!",23);
    # a. c0 ]9 ?; w* I3 p
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    & w( K$ {- u0 A/ p
38.        }
    : E/ A. d( _0 s$ U! X, W4 M
39.     }
    
40.     return 0;
    
41. }
    ; @* x5 r1 q; N0 q2 N
42. 
    
43. int main()
    
44. {
    ' G0 o6 A2 L2 E% }8 k, u
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    
52.                       client;
    
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    
56.        printf("Failed to load Winsock!\n");
    % t% w3 y2 \2 \4 A& Y: K# g
57.        return 1;
    
58.     }
    
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    . o" H, X5 E" \
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    2 B5 `/ b  r& P  o4 A
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    
65.     }
    6 R0 ?, h/ z4 q4 W
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    
69. 
    : C3 W1 u) y( C+ w, I" ~4 f8 l
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    5 q# D  @% \$ l
72.     {
    - E. h& G8 T5 _0 t6 Q
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    + }6 Q2 E/ a) u: S8 n  I3 `+ X' t* X
75.     }
    8 ]6 @2 m* b. Q& H) o5 Q" R
76.    listen(sListen, 8);
    0 \5 s, j* Q4 s( H" Q5 g  \0 c
77.     // In a continous loop, wait for incoming clients. Once one
    4 E# V( ^+ r# d. M$ D1 m1 h
78.     // is detected, create a thread and pass the handle off to it.
    
79.     while (1)
    ( a) s  H' ]7 |& [+ ~- t8 n
80.     {
    
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    - L3 y1 i: @5 ^
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    
88.        }
    ( _7 a! M; Q2 G; g3 Y
89.        printf("Accepted client: %s:%d\n",
    - Z1 K( k* u& N1 L8 y3 S4 V
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    & }6 s; h# {: P8 Z- {( D9 M, M
92.        hThread = CreateThread(NULL, 0, ClientThread,
    ' E0 U# D! z' ?$ D
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    ) Q* L( L- |+ S: |5 S: i) s
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    3 l4 E6 S2 q! o0 A# |
98.        }
    ; B$ c" v& l2 n2 d$ E* }
99.        CloseHandle(hThread);
    6 k$ @* ]+ i8 k  }
100.     }
     2 {# J5 ^& s6 b. @" x
101.    closesocket(sListen);
     
102.    
     
103.    WSACleanup();
     
104.     return 0;
     5 v) T; Q0 d# B" f2 R; p  F# C) Z
105. }

复制代码

* j$ [* B5 i* \. v; H3 Y

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   ! N. o$ O! {: a. c5 U0 C
6. Server：
   
7. #include <winsock2.h>
   ; D* p; l6 @% ^2 S# T, m- Q
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   
10. #include <stdio.h>
    % E% `8 k7 ~2 d8 `0 _
11. void main()
    ' ]  C! j8 D6 f8 O" w
12. {
    ! O. V- F, x& g  \  s9 n; b
13.     WORD wVersionRequested;//版本号
    ! p  m/ ~9 c; R9 m1 P+ B: S8 I
14.     WSADATA wsaData;
    0 N) q: C0 Y/ Y
15.     int err;
    
16. 
    ( L" Z6 _- s, i. _: Q# y2 i
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    4 ~9 V2 m1 v6 P( z2 E0 ^5 Z2 M
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    + @3 v0 |- h; {
20.     if (err != 0)
    $ \# s6 ?1 s+ u% a" n5 D2 a; t' p
21.     {
    . p- l- B1 W4 v
22.         return;
    
23.     }
    5 F) z! q' U% X5 S* G5 G5 G& m
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    - G) W. D* B. a- d3 M
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    ; w, {3 m* \0 z  X- N, o4 M1 t
27.          
    & a1 E. w( D% W6 I
28.         HIBYTE(wsaData.wVersion) != 2)
    9 j) Y3 b( ~! L9 `' J6 n
29.          
    0 F0 ?/ V  N8 B
30.     {
    
31.         return;
    * Q  Z+ `# T% x3 H; E
32.     }
    
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    
41. 
    : U8 Q2 p# v+ c
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    $ B( U2 {# L4 @6 C
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    1 C% k: i$ i9 K3 k
44.          addrSrv.sin_port = htons(6000);
    1 b3 l! e% v7 X
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    + r; m2 E- F7 v, S$ q
46. 
    , d. |* ^7 ?+ Z/ M+ l3 m- l* N
47.          //将套接字绑定到一个端口号和本地地址上
    3 |" P; W6 M3 J% x9 I5 \, B
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    + ^% n. j% {  d
49. 
    
50.          listen(socSrv, 5);
    / v: A+ F+ ^/ L' U8 c
51.          
    / X( x0 g+ x! [) w( T% Z7 d  L& G
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    8 }: a) \- u0 C7 Y4 Z: x
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    ! |2 z2 m- {3 y  H( r; D: O* N
55. 
    
56.          //循环等待接受客户端发送请求
    9 [: V8 m: P0 \7 m) h1 r+ R
57. 
    9 F1 w5 t! x1 w  v
58.          while (1)
    & v  w* Z/ Y4 p8 T) m. C6 S" f
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    ( k) c2 J% `; D7 P8 Z
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    # I1 q- a$ `, \1 ~; I4 p
66. 
    $ R- S( m" V8 j7 u
67.                    char sendBuf[100];
    / R+ b3 u# f+ G! o9 N! y; y
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    : K5 S% y; f9 I0 y, F6 {* q  q
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    ) v9 j( J2 s9 M/ h* M( h
72. 
    / X( j) q, ], c( n7 I+ C* B/ t
73.                    //用返回的套接字和客户端进行通信
    - }& Z' i, g8 P* v8 n% D. ]8 Y
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    # @3 o+ [2 ^$ z8 Y$ p
76. 
    
77.                    //接收数据
    
78. 
    
79.                    char recvBuf[100];
    " n5 n7 v9 [2 }
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    * \/ S0 ]" o( Y' u
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    5 \) g  @- I; p0 U8 j
85. 
    ! A/ o; A. @" N# R9 R  Q; Y! ]1 i( Z
86.          }
    
87. }
    
88. 
    
89. 
    : v. D' h; W% @7 r2 t
90. Client：
    
91. 
    ! w/ n8 o, h* Z  B2 D" G
92. #include <winsock2.H>
    / W" F% n; g+ n0 J# ~: I
93. #pragma comment(lib, "Ws2_32.lib")
    + Q, y) _" K9 t" q' k% v
94. #include <stdio.h>
    # `; M6 q: [" z  f1 M
95. #include <string.h>
      T2 M, d0 `$ [2 ~" y9 x4 S
96. 
    6 }$ d7 Y% U0 L
97. void main()
    5 k# R; G0 _7 {# }  P, K
98. {   
    
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
     
101.     int err;
     
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     , p; e2 M( g0 \- Y9 i# o
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     * G+ t" v/ B5 ?
106.     if ( err != 0 ) {
     1 D, W- D6 J/ i/ g! n4 W: C
107.          
     5 j6 e7 s$ y; ~+ w# }# A
108.         return;
     3 H# }) @% B% J" n# G# V
109.     }
     6 t  X$ R4 L* v6 ]% I) m$ @
110.      
     
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     " [! u0 }4 m8 n  T* U" u) c
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     ( @* W5 K% }9 B
115.          
     / R1 u3 h" A* X+ ?& o# o4 h
116.         WSACleanup( );
     
117.         return;
     
118.     }
     3 p  _# m' v' T* V% y1 I
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     ' y" }) p+ ~& \9 O' A( F4 }
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地址
     ' m. ?( ?4 K( g3 z( u+ I
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     3 d. Y* G+ w0 d4 u" i1 C
126.     char recvBuf[256];
     , E7 ^/ u) f, O+ p
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     / r; B) K+ _6 U$ k! C: n: F
129.     printf("%s\n", recvBuf);
     & e* R+ }2 P- e0 M% ^4 N
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     % S& ~, m& {0 s! j: R1 B
131.     closesocket(socketClient);
     
132.     WSACleanup();
     
133.      
     
134. }

复制代码

& S3 h! _; [' j7 H
! C) s; d5 {0 H