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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
6 }' K6 ~: d5 w# I/ Q+ b& e, v客户端程序：client.cpp

1. #include <winsock2.h>
   
2. #include <stdio.h>
   4 N. R; J& n- `) s) z: n9 e4 o
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   . [3 k6 L6 l; w; E) C0 U5 [
7. 
   
8. char  szServer[128],
   
9.      szMessage[1024];
   + L% t& `9 C, ~3 I1 D
10. int  iPort    = DEFAULT_PORT;
    , Y1 m3 ^) y0 @# ^: r
11. 
    . J$ V8 e  o# e1 g, S' T
12. int main()
    
13. {
    # e% b3 g% o9 a5 ]
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    ; g; e3 y" w7 ?" }  J
22.        printf("Failed to load Winsock library!\n");
    / N) Z1 Z, l, E2 b6 _/ `
23.        return 1;
    
24.     }
    
25.    printf("Enter a string to send to server:\n");
    ' s0 H, M; c" T: z' C' i9 E
26.    gets(szMessage);
    
27.     // Create the socket, and attempt to connect to the server
    
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    5 `; Y' |) G- N6 ^/ Y! t
29.     if (sClient == INVALID_SOCKET)
    
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    
33.     }
    
34.    server.sin_family = AF_INET;
    / _/ J+ |4 c- q3 |: l
35.    server.sin_port = htons(iPort);
    * M. o3 W+ I/ j3 {8 p
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    : _( R* C6 Z) h( @
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    : y" u+ `9 F2 {
39.        sizeof(server)) == SOCKET_ERROR)
    # |5 e4 x3 Y" H6 o7 M" D
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    
43.     }
    9 c1 E( ?+ u; f0 n1 [3 j
44.     // Send and receive data
    " k: j- Q6 B) b9 k
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    3 j0 ^( U9 R) q1 r$ ~
46.     if (ret == SOCKET_ERROR)
    4 ?  r6 V4 k$ h6 D
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    # \- m) B# M: G- G' n1 D; K
49.     }
    
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    / c) L6 `  l6 N- ^( O. J
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    ( x+ D* {% z! T- c  l5 b
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    , a+ S" r0 c4 y2 B. _
55.        }
    % U- G+ n1 `+ i( s% R8 ~6 W& a2 o
56.        else{
    
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    8 t) J9 X- [$ B$ }+ K5 D
60.     }
    0 t) f5 k! g) ^5 V3 x
61.    closesocket(sClient);
    
62. 
    1 `- M  U7 K  P6 k. U1 c" \1 F' O
63.    WSACleanup();
    1 B; y, o+ l# p% G! G
64.     return 0;
    
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   
2. #include <stdio.h>
   : ?0 X, f1 `: A
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     4096
   . K) }% F. W: \" {. [" t* d; x
7. 
   
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   ( F5 y! U) t: N8 D3 g
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    * D8 I3 E9 R0 p1 `9 j! n
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    1 u" u# z# [3 S
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    6 I! C4 s+ d, b. J% u, ]
16. 
    
17.    while(1)
    
18.     {
    $ G2 E; Q) U$ K7 _
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    ; ]/ p3 M- w  e  i7 a
21.            break;
    1 ?3 e' y- N* ^
22.        else if (ret == SOCKET_ERROR)
    
23.        {
    + C  K9 q) L8 {2 U( H, b
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    & Z1 x5 ]% y( k; Z: E
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);
    , S& {0 z9 m$ G1 ~, `$ I
31.        }
    6 i% k- c' g4 S
32.        else{
    $ c/ |1 ^, X  N- d1 M7 L
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    + C2 v1 P' H  W9 D
39.     }
    
40.     return 0;
      X! y4 D  {' D( D" D& m* \) ]
41. }
    
42. 
    % b# ~& k) a% f$ K
43. int main()
    
44. {
    " `$ e+ n! z8 \; t
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    7 B  x; M, x3 O( W" r& e5 E  F
48.    int          iAddrSize;
    + H) }. _- @3 Y7 f
49.    HANDLE       hThread;
    ' ]: H0 [% g3 T
50.    DWORD        dwThreadId;
    + _+ T! {- ]7 o8 M/ M* `
51.     struct sockaddr_in local,
    # p- J& M& C6 H& W
52.                       client;
    1 P5 [  V* R* @5 S  ^. d4 a- m
53. 
    ) {' e( N+ d* o! f" H
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    0 {2 }, N3 U" H0 n% @2 L9 s
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    
58.     }
    ; v$ r5 S% @1 A
59.     // Create our listening socket
    5 M  e9 F! L" Z2 A. e- S. ?. J& n
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    * y7 p* S* g3 m0 ?( v; w
62.     {
    ! d. \+ C3 p) T
63.        printf("socket() failed: %d\n", WSAGetLastError());
    " ]4 b: O. H( t( |
64.        return 1;
    
65.     }
    2 c( f4 l6 F. I5 P% ^5 K* ~6 e
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    ; ?" r. D! N; a% Y9 R- F
67.    local.sin_family = AF_INET;
    + b0 y! F) G& D6 {# x
68.    local.sin_port = htons(iPort);
    
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    6 P6 k* D2 P( D& }
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    ; U# _5 ?3 Y- H+ N) u& T# G
75.     }
    2 i; D/ H5 ?  W2 ~, i8 v2 U8 B# q
76.    listen(sListen, 8);
    
77.     // In a continous loop, wait for incoming clients. Once one
    8 @' d: \4 ?! \- A9 g
78.     // is detected, create a thread and pass the handle off to it.
    . [  L2 U9 ?) n- A( O- L
79.     while (1)
    
80.     {
    
81.        iAddrSize = sizeof(client);
    3 [$ S5 K4 Q8 u! H: n* K
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    : @1 a; \/ u. o! X
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    * m* {- ~( I0 w
87.            break;
    
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    : K& U5 X4 m" R; F' A/ N& n9 z
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    2 N0 a% S- f# Q6 M  l. D; w+ ?
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    # [* n1 q) ]9 p! i- g' w# ?% J
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    6 l7 Y  z% k& O: j4 O  J2 U( \
98.        }
    
99.        CloseHandle(hThread);
    
100.     }
     + y0 N/ C+ r  H, K- w& s
101.    closesocket(sListen);
     
102.    
     ; k$ k9 D5 c1 @+ |! x# r0 V  Q
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

; B6 `  }. }* O9 d4 b2 e* ^3 B

1 h* w* @) g$ g
% w1 k9 E, V* f8 U. ?! S, P8 N" j. A: ?

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   - z! H( `. ~& e! X7 x  e) N
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   
6. Server：
   1 W- l# A- u. v7 f8 d5 }
7. #include <winsock2.h>
   2 Q( b. m$ @$ `" |9 u0 k
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   $ O! {- W: u9 R6 m/ C. [$ @# R
10. #include <stdio.h>
    / X& p7 C) a) b2 @7 U# X$ J5 m2 p4 w
11. void main()
    ) n/ o3 k$ z1 S: q( g4 ?) C& {! L
12. {
    
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    
15.     int err;
    1 ?! _' u- m2 X4 s2 x" h  @
16. 
    ! G; @2 C* u3 y+ a
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    & O6 R- C" Y" X+ z$ ~0 C% \9 _
18.     //加载套接字库,如果失败返回
    9 v9 ?4 y+ ^; Z' |$ W
19.     err = WSAStartup(wVersionRequested, &wsaData);
    : L- ^$ Q# h, r4 p4 [( z
20.     if (err != 0)
    1 `3 J% _& }3 x3 g" v: X
21.     {
    
22.         return;
    
23.     }
    
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    & {- U7 e: W, K) A1 R4 N
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    ' u2 g7 B* m4 O3 _* I
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    7 G% ]4 m: |0 ~# Q/ J( i1 V! W
29.          
    . r; y8 [4 P# m) w- F
30.     {
    
31.         return;
    
32.     }
    . r% X/ p# r/ m, O" O0 H; @2 S
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    6 u- O" [8 w! {1 h
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    6 a7 x! B! X" H5 B* s# F4 e7 W
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    , D) G1 ?3 t1 E' E  C
44.          addrSrv.sin_port = htons(6000);
    5 j1 e5 @5 T4 Q# O
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    
50.          listen(socSrv, 5);
    
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    . \8 }  @, e% N% H' ~$ r+ k4 b
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    8 Y* o/ y/ W% E2 L1 o
55. 
    
56.          //循环等待接受客户端发送请求
    9 b$ t8 X5 G) T
57. 
    8 U5 N  ?9 c6 j% `6 K. c
58.          while (1)
    
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    ( Z1 V4 _1 s* |- c& Q7 e+ i, [- G
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    , s1 K4 T& e- ^' z8 D5 b; t, `
66. 
    
67.                    char sendBuf[100];
    6 V" s! ^$ }0 Q0 V% D: B" t
68. 
    5 P  G' Y2 U" g+ q
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
      e' i" i  d* i) T* `) E. v% j
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    
73.                    //用返回的套接字和客户端进行通信
    
74. 
    8 X# C7 ^9 K; _. g8 a
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    # K% p: h8 G# D. \/ V1 R/ E* N. O
76. 
    8 ]; c0 p) T6 u+ {% i9 {
77.                    //接收数据
    
78. 
    
79.                    char recvBuf[100];
    ) h! _5 r$ W. \  k# A
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    & R; j% J" u  z7 ]/ P7 p
82. 
    ! [+ Z; R/ f% L1 q  j, P7 R
83.                    printf("%s\n", recvBuf);
    4 N$ K4 [3 e9 p
84.                    closesocket(sockConn);
    7 X' `' v1 X% }* Q9 I
85. 
    
86.          }
    
87. }
    
88. 
    
89. 
    5 f$ }8 i  s" y/ B
90. Client：
    + `% c  o6 ]5 _/ y% c
91. 
    
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    % @  N! y! ^* e
95. #include <string.h>
    
96. 
    
97. void main()
    9 j2 [+ u# w' t9 p7 \1 T
98. {   
    4 }; {5 ]; O2 u/ a6 e8 y8 r* ~
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
     $ i) e* P9 p  K  M
101.     int err;
     0 K# x0 v) M! S9 h6 D: C4 L, N* Q) F
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
       }0 p, i8 Z9 \4 L/ g+ i
105.     err = WSAStartup( wVersionRequested, &wsaData );
     % ~# A& _- ?( M5 X, s0 n& l
106.     if ( err != 0 ) {
     
107.          
     
108.         return;
     " b& M: f9 X- `9 U, v1 `; c: e- L% Q
109.     }
     " I' t( e8 ]: a0 y" G! G
110.      
     
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     3 R0 t6 r: g# f) U6 g- B
114.     {
     
115.          
     ' ?7 R0 N) Y. u
116.         WSACleanup( );
     
117.         return;
     
118.     }
     $ ?' Z$ F7 E7 n  n
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     0 I% c, G0 l2 l/ a' L, g
120.     SOCKADDR_IN addrSrv;
     + g/ _0 g2 Q- @/ T% {
121.     addrSrv.sin_family = AF_INET;
     & }/ U4 e6 M+ g2 J
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));
     ) [# i# z  y$ u7 M9 m: S* w0 A; L% p
126.     char recvBuf[256];
     ( K9 j$ x! o3 m  R5 l( l3 j
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);
     
131.     closesocket(socketClient);
     # \2 l1 T9 F# z% c
132.     WSACleanup();
     
133.      
     - Q7 Q, r  S4 \& B+ {
134. }

复制代码

! Y- |1 b2 \6 R& c' ~& w& [