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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
) r$ g1 x; Y$ C4 k0 x4 U6 z  Y客户端程序：client.cpp

1. #include <winsock2.h>
   % X5 A. A+ \' i: W* J  v
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   , J6 h4 l: \6 J8 E7 T* G" p
7. 
   ! D3 T  Q& r1 W* z
8. char  szServer[128],
   
9.      szMessage[1024];
   3 J  [% p- q; J4 ]0 i
10. int  iPort    = DEFAULT_PORT;
    
11. 
    8 h3 E9 C1 o/ r5 d6 f& h
12. int main()
    
13. {
    
14.    WSADATA      wsd;
    2 T; |, O0 E6 A
15.    SOCKET       sClient;
    4 a6 d- K" V1 u6 L+ l3 g3 [9 G
16.    char         szBuffer[DEFAULT_BUFFER];
    , N- |- i% g2 N
17.    int          ret;
    
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    6 [- C; x; ^8 T! P: a
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    . ]* v/ M8 h9 H) F! f  I( |/ D
24.     }
    . Q/ x  `6 ~% E- P: }+ K
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)
    % i  U3 H; J' K) z' x- |
30.     {
    : ]$ A5 K- k0 J  Z, F; l, I
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    
33.     }
    
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    : W0 @7 Y9 M" e4 \1 t, D. p% c
37. 
    ( j; b& H+ l8 ?8 k
38.     if (connect(sClient, (struct sockaddr *)&server,
    4 v/ P$ u/ x( t* d
39.        sizeof(server)) == SOCKET_ERROR)
    : V5 v7 w5 u+ Q- g. X# g  R( E
40.     {
    2 ~0 t8 ~. u0 V! i. Q- m
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    3 S$ E( K; r6 I0 [, r6 T% H+ t2 ^
43.     }
    0 ]4 B" o5 M% m. x  v
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    ; D& s2 `/ |4 t& J' O8 w
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    7 w* T2 K& k4 ]: ^  N1 |6 N9 [
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    4 _  }7 ?1 ^$ ]; t! ~# A' {! u
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    
56.        else{
    ! ^8 \, h' T6 @
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    . d% }  s; K# b$ q& N* [7 T
60.     }
    
61.    closesocket(sClient);
    
62. 
    
63.    WSACleanup();
    
64.     return 0;
    ; t# H( f8 n- A4 r& d& A0 ]
65. }

复制代码

服务器程序:server.cpp
- z6 N# r  A. ]/ f$ w5 G! S

1. #include <winsock2.h>
   . x6 ^$ P5 S% u9 Y. r: f
2. #include <stdio.h>
   5 R, _! x4 x; s$ O( B# Q
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   5 G# t) c. V1 B6 O, P8 L$ C
6. #define DEFAULT_BUFFER     4096
   ; T% G7 W$ r, _9 K7 c
7. 
   
8. int   iPort     = DEFAULT_PORT;
   , x4 h9 u& h6 \; u/ S, p
9. char   szAddress[128];
   ! E) h1 ?4 r+ [1 u" G  R/ e
10. 
    5 J; O4 f6 O* X: x/ ]3 G
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    & A. q4 r! j. f) {: p
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    - a2 w' F9 e( C- i, B$ }
16. 
    
17.    while(1)
    
18.     {
    3 L2 D5 f7 K) ?% Z" N
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    " W% i5 J; c& n! {/ w+ ^
20.        if (ret == 0)
    / p$ i( }) Q6 v# L
21.            break;
    , L; y% @0 N" r+ v8 d% b4 t
22.        else if (ret == SOCKET_ERROR)
    - ^4 R% I/ D5 H, J
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    9 B: ]% V9 f" ?8 h! @. ?
25.            break;
    
26.        }
    5 V; |- |# |' ^: q7 L) B
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    6 s  D0 H, W6 t
29.       if(strcmp(szBuff,"abc")==0){
    / ~3 Q! R7 }' a! s
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    ; E* a2 I4 x! C' u8 }# ?% ^, q) O
34.        }
    ) P% O% A9 }3 k1 }
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    " p: q1 Z3 ]9 J  A- u/ \- j
38.        }
    
39.     }
    ! n5 f) F! Y+ P, O( P2 G( \
40.     return 0;
    
41. }
    
42. 
    
43. int main()
    
44. {
    
45.    WSADATA      wsd;
    $ T3 Y1 W# o+ Q' t% W" M  e
46.    SOCKET       sListen,
    
47.                  sClient;
    8 B7 G. @3 i6 g# W6 x3 n4 \8 N
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    $ B  e6 L: t: E% x+ b3 V  ^
50.    DWORD        dwThreadId;
    . b" D2 \3 Z) k
51.     struct sockaddr_in local,
    
52.                       client;
    $ h1 n2 G6 P" t* R( v1 `
53. 
    9 R& G+ v  N; z, I1 v% C
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    ( E6 K# h! @& ]% z, p3 y% L
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    , h3 R/ @- X: z7 `' \
58.     }
    
59.     // Create our listening socket
    5 ~* h9 I9 h; _( Z3 b  P. b; D
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    1 e" F5 G4 v% e) b. i7 r2 L+ ?1 d
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    3 f! X# |0 @3 N2 K! F. z3 B
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    4 ~9 u# v  Y  q) I5 X. _: U; `: \# G
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    ! c, e$ m( |2 H) ?+ ?0 W
71.            sizeof(local)) == SOCKET_ERROR)
    # B' @6 \0 C, J5 W" @& q! }  {; h
72.     {
    , v2 s9 @$ |, \+ O& @! n
73.        printf("bind() failed: %d\n", WSAGetLastError());
    % |8 @5 w/ k6 y# F$ ?
74.        return 1;
    7 E) e9 |( n) U3 S' N/ o
75.     }
    
76.    listen(sListen, 8);
    
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)
    $ p) x- ^. T: k: N
80.     {
    
81.        iAddrSize = sizeof(client);
    0 c; ]. S' c3 F% ^$ y) J) Q$ I
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    ( C; Q) ]' C$ z
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    - z( O9 r" i" S; ]( U) V
87.            break;
    
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    , l; f+ v. C; W. k. S" D1 ?
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    6 o8 c1 `  u- d5 g( g% \  M4 Z# u
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    * T1 O! T% c8 d
94.        if (hThread == NULL)
    
95.        {
    : r. y4 @8 P- D5 J
96.            printf("CreateThread() failed: %d\n", GetLastError());
    / `8 w' i; v' F4 `0 d) |
97.            break;
    
98.        }
    
99.        CloseHandle(hThread);
    
100.     }
     
101.    closesocket(sListen);
     3 h; n3 i* S/ Z# Y
102.    
     
103.    WSACleanup();
     9 _# E5 L7 d3 r- q3 h8 n
104.     return 0;
     
105. }

复制代码

5 I) p4 f* K. A% _% n. i+ l
7 R0 l+ r( h- M6 q- c

" Y0 f* m, w$ c$ |! T
; }9 V+ g& M$ T! j/ C4 y

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
     U: R- t. P! v8 u9 z
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   
6. Server：
   
7. #include <winsock2.h>
   
8. #pragma comment(lib, "WS2_32.lib")
   % Z, k8 X$ P$ U7 V
9. 
   
10. #include <stdio.h>
    
11. void main()
    ; U) {/ [1 Z- }
12. {
      @1 _' U5 L/ O3 ]: g
13.     WORD wVersionRequested;//版本号
    ( w0 w7 M7 }) U$ u/ b  V  K& _* K
14.     WSADATA wsaData;
    1 V0 |3 Q! R0 W" I
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    & U; G. y3 |5 L0 S9 c5 y
20.     if (err != 0)
    
21.     {
    3 D7 ?: n9 }$ O. M( \/ G& q
22.         return;
    ! w# [6 a0 N( @+ D
23.     }
    
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    ; |7 X* [: U( V. _( l
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    + X5 Z" F" a- ?5 r$ M) X9 k0 r$ W. B
29.          
    
30.     {
    2 V* n9 w. U! L# r3 n6 d/ M- t
31.         return;
    
32.     }
    5 x' S/ q4 n- x! O" S
33.      
    3 v' Z  h& K* l4 p% R- t8 S
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    ' C# Q& J: ]& R& j* m
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    2 E2 X% O# n  {
37. 
    
38.          //Socket地址结构体的创建
      d" M' W. E& e  S
39. 
    ) C, [, x# U9 K& s- h, D4 E
40.          SOCKADDR_IN addrSrv;
    # {/ V4 e, K, |# h
41. 
    & @6 p! i# y, S. x  O! r) N
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    ) v* B# w8 z2 w! u4 T+ X
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    1 j, ]( I( ?3 ~1 {
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    6 i5 d/ {. l! j5 X" m- g& o
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    " e1 E: @! n# N, g2 q0 w3 E
49. 
    
50.          listen(socSrv, 5);
    
51.          
    " |- `) o& S/ d
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    - q0 i. n) }3 x, m# T8 d
55. 
    ) E$ f7 S7 t% |8 s( Z5 V+ `. Z
56.          //循环等待接受客户端发送请求
    1 U) a( J8 O0 a0 {8 D( t
57. 
    & l" P/ g& n3 H, o2 R; w9 g" l9 l- |
58.          while (1)
    # K. @; ~' B+ S/ E+ S" G7 {
59.          {
    6 l+ w& m, A: T
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    & E5 ?" m, I9 h% y/ a, E
61. 
    " Y' o2 Y2 q  f" j6 ?
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    3 k' y* w( u: H. k% ?. [# e
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
      D6 N) \, p& K9 z" X* b, f
66. 
    : g% F. J' b4 v
67.                    char sendBuf[100];
    
68. 
    & [! J" [: s, `6 |
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    - R. x- H1 k  n7 c% F9 l
73.                    //用返回的套接字和客户端进行通信
    
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    ; Q6 f) n" v! C0 V0 H
76. 
    % a$ e- ~  a# x- M1 s
77.                    //接收数据
    
78. 
    
79.                    char recvBuf[100];
    ; B& f; z+ P2 |, l
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    - K) ^  s- H5 \/ ~4 g3 A9 Y
83.                    printf("%s\n", recvBuf);
    0 j- ^& `* X" I% i
84.                    closesocket(sockConn);
    % {& I/ Y9 Q) J& y: H# g
85. 
    
86.          }
    & _  M0 W0 a- w! X
87. }
    0 Q5 \" C* P; p, J- S, H; u  Y
88. 
    . e& r- O$ C" K8 X* e
89. 
    
90. Client：
    1 |9 v0 ^4 G0 ~/ \4 m
91. 
    # G+ s) a# V% R- C! _! T& t/ M% S
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    / h5 |) ^9 R0 v  v( [' m
94. #include <stdio.h>
    ' W' H8 g0 I4 `  c
95. #include <string.h>
    
96. 
    
97. void main()
    & r/ O3 `% d2 l( @) ^
98. {   
    
99.     WORD wVersionRequested;
    $ r0 k% P1 a9 Y/ I# b" a
100.     WSADATA wsaData;
     
101.     int err;
     
102.      
     2 D! Z5 [( F$ ?- q" \  g) U
103.     wVersionRequested = MAKEWORD( 2, 2 );
     3 f2 o8 G; M4 e( D
104.      
     ( H3 ~5 p+ X' g) c9 I
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     1 H. H0 u  P, Q- Z1 o+ A" I& }2 {
107.          
     
108.         return;
     
109.     }
     " Z# B4 X) M1 j3 f) m
110.      
     
111.      
     3 S$ Y9 N* y" v; B& ]' Q0 n& p; e
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     ! T6 O+ p0 k* o- ^3 c! U
114.     {
     0 @2 u$ n4 i" x) L
115.          
     
116.         WSACleanup( );
     ( ]7 W5 f  x- k5 e  \/ T
117.         return;
     
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     $ I& k5 |  ^' b1 m+ R  {% |# Q* h. {
122.     addrSrv.sin_port = htons(6000);
     
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     $ v1 B/ I, ~7 }8 ?0 |# r  W6 F. t# V0 s
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     4 C. f1 ?+ X+ d. j* r; ~
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     ) Q. B  @1 ?! g# I1 U+ h, `8 W
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     ) ^+ P& m; J# E, v  P( [
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     % b, a  M; Z  u
131.     closesocket(socketClient);
     - n6 A4 u/ n1 b6 Y2 L# {
132.     WSACleanup();
     
133.      
     
134. }

复制代码

$ ?: t! Q; D! R( U$ j8 _+ r0 e* ~
% v, }$ a% z  G$ P! D9 J8 M" r