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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
+ |# k2 X( H& L  g7 N' m( C& H客户端程序：client.cpp
) p. E6 H2 t: a* _* z

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   ! t  d2 N9 _$ e* [
5. #define DEFAULT_PORT       5150
   0 S! a9 r  L/ [7 n; I
6. #define DEFAULT_BUFFER     2048
   ' h2 q* x) A. e% d: O- B
7. 
   
8. char  szServer[128],
   $ k, H# s/ V4 `% C7 _& N/ z% m
9.      szMessage[1024];
   . n0 D9 P# k: r
10. int  iPort    = DEFAULT_PORT;
    
11. 
    . M* g) c7 e3 [" }& v* ]8 Y
12. int main()
    
13. {
    
14.    WSADATA      wsd;
    0 j: q6 L$ I6 I  _3 ]( c8 {1 e) M4 Q
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    1 r! U# f  a: ^4 D
18.     struct sockaddr_in server;
    # A; Y0 V2 _- S7 u9 n
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    1 L' S  f' S& c7 o
21.     {
    & k1 x! `$ y) W
22.        printf("Failed to load Winsock library!\n");
    * Y- N$ D6 U/ d. p6 ~  Q
23.        return 1;
    
24.     }
    
25.    printf("Enter a string to send to server:\n");
    
26.    gets(szMessage);
    
27.     // Create the socket, and attempt to connect to the server
    6 o6 W' j3 t: L* D( a. ~$ Y9 e- J6 S
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    5 |- H" C& `; a/ u. D
29.     if (sClient == INVALID_SOCKET)
    
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    
33.     }
    + `: Q; E) P: U7 _9 q) L" f; J6 A
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    ) a3 i# }" c5 p* i, e3 w
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    * {1 g* {) q2 {. }! C
38.     if (connect(sClient, (struct sockaddr *)&server,
    # F' c  C9 c& T/ |* U4 K; Q
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    / u4 Y% p* J$ z# C  `  C
41.        printf("connect() failed: %d\n", WSAGetLastError());
    & ?- v8 K% Q( j! z
42.        return 1;
    
43.     }
    
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    5 X8 e% u1 a1 l5 e0 h9 n% [
46.     if (ret == SOCKET_ERROR)
    
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    ! V1 p: X2 g& W$ t6 b4 p# S# ], p
49.     }
    5 R( h7 [) N0 m# F3 T' |
50.     else{
    ) @# W3 g6 R; m) i9 Z
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    . ?: I: i2 l1 q+ S& T' G$ `
56.        else{
    6 x; I; ~. D+ E' w- Y' ^$ M; m  G
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    5 E4 J* N8 v" n: R% W% c5 W
59.        }
    9 U# V6 }  n- N, c1 \
60.     }
    
61.    closesocket(sClient);
    
62. 
    7 Q2 X! w6 V7 \( v8 ?) C
63.    WSACleanup();
    
64.     return 0;
    # |  `+ ^* e. i6 W! V+ f) \
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   * T/ p- h# n# R! O4 f
2. #include <stdio.h>
   % A& {" o! B( h* Y
3. #include <stdlib.h>
   
4. 
   & i8 x, q! l% F. N9 `
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     4096
   
7. 
   , a8 p( X+ }, l1 D6 \1 }: `
8. int   iPort     = DEFAULT_PORT;
   - u6 Y4 e. \' T; ^4 L  B
9. char   szAddress[128];
   
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    8 t. d6 \$ h. b) p( M* h+ H
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    2 U" d' H# h/ r& a6 R# G
15.    int          ret;
    ; r; X) l% r0 J8 O* A' A" L# J& F. E8 P
16. 
    $ h0 k2 v$ D& ~9 _  X) X+ J
17.    while(1)
    3 J3 n: K/ f5 R
18.     {
    
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    5 ~7 h  C* B8 g
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    
23.        {
    5 X* Z& L  p% {4 ?7 k) ?& o8 F
24.            printf("recv() failed: %d\n", WSAGetLastError());
    # g- D; r. c7 D% V6 e& s# {
25.            break;
    
26.        }
    . e% u! \) u" {: T! r" Z
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    ! a' x. h& u  v$ o5 U
29.       if(strcmp(szBuff,"abc")==0){
    
30.          memcpy(szBuff,"Send the correct string!",25);
    , c# i# Z6 S, H1 q9 g
31.        }
    3 s4 H1 h" D! K3 o! T* b) x
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    % f7 y& c8 z% o
34.        }
    . q3 J. \. \" `& Y
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    9 [4 L4 M& U0 z( f7 z' {
39.     }
    4 I; c* d% s% i5 T, y
40.     return 0;
    
41. }
    3 Q4 W' p, L# w0 C5 k$ I
42. 
    $ x+ L& m- C$ ~& x' X- |
43. int main()
    * X9 b6 V# t0 E
44. {
    , o# j- I" P( H% F
45.    WSADATA      wsd;
    0 g% u) e5 u3 r1 Y9 P
46.    SOCKET       sListen,
    ) Y# M8 q8 s( P3 E3 D/ s
47.                  sClient;
    & T0 F! ]1 T/ a9 |
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    2 ]" R. @0 A( X0 b7 A
51.     struct sockaddr_in local,
    ( @7 A& i! D, h, g% f. @
52.                       client;
    
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    % @# y0 h9 e' n
56.        printf("Failed to load Winsock!\n");
    1 v2 K; M" j% Q% e* V+ g
57.        return 1;
    9 G/ j: e2 E1 A3 Z- P. Z+ }
58.     }
    - p. j& `3 j- y' ]6 X
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    & V+ B# `' i5 \7 T8 Z" s  `
62.     {
    & s0 b+ s% x& q+ c% W9 r4 J
63.        printf("socket() failed: %d\n", WSAGetLastError());
    ! S" e2 b$ v8 z+ H, g' W" m
64.        return 1;
    6 u# Z) j  K8 \7 I6 f+ I# B
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    & k+ D" G* x9 N5 i) L. z5 o# J  F
68.    local.sin_port = htons(iPort);
    
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    , Q# [4 o8 b& ]3 s/ r0 }; l
72.     {
    ' ?% Y& i+ b7 L
73.        printf("bind() failed: %d\n", WSAGetLastError());
    ; o& B8 q' N4 d8 q: T! v
74.        return 1;
    
75.     }
    
76.    listen(sListen, 8);
    
77.     // In a continous loop, wait for incoming clients. Once one
    ( i6 N. q; z' }! o
78.     // is detected, create a thread and pass the handle off to it.
    / U- S% a8 I4 m. N& }  t; Y6 i# J& R
79.     while (1)
    " L8 E) O2 F+ D% R. A# Z& s7 M- e
80.     {
    
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    0 T0 P, d& ]( n' |
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    $ w" Z1 V0 m- m9 i3 b% I
97.            break;
    2 g- H: W/ P' W; j3 j6 _7 f
98.        }
    # N3 ~' u3 k6 [9 [) I
99.        CloseHandle(hThread);
    
100.     }
     
101.    closesocket(sListen);
     " d" k) @3 e* @% r9 v# H9 o
102.    
     
103.    WSACleanup();
     + S5 g3 V" I9 L8 y3 v
104.     return 0;
     
105. }

复制代码

9 m* c- d+ Z' W" }5 v) ?
& o3 P2 n: H: M5 F

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   . c) k$ A  L, z
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   . c" F" {6 L4 Z2 Y2 M
6. Server：
   % v) o( ~: k2 ~5 @  k
7. #include <winsock2.h>
   
8. #pragma comment(lib, "WS2_32.lib")
   - M* c# b# P% P& a. U+ A6 {9 G- D
9. 
   
10. #include <stdio.h>
    
11. void main()
    + i: }4 O( \1 P
12. {
    8 p9 i( m5 \  X: g
13.     WORD wVersionRequested;//版本号
    4 `* A3 A6 v. n2 O
14.     WSADATA wsaData;
    . W# K' K  R# K% j/ i, I
15.     int err;
    : ], m- I" R% n5 I: \% m, G# ~
16. 
    $ E0 ?" s0 |4 t; ^% E+ F
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
    ) H3 c! Y2 S7 M! E3 l, q9 R
21.     {
    
22.         return;
    - ^& G6 d2 H& y# W/ l3 o( R6 S
23.     }
    
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    5 h) [! n5 x: k% Y: O& @% t* t/ n
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    $ ]' a7 E9 n- ~
29.          
    
30.     {
    - |0 ~3 h7 V: ?0 K2 r+ `5 m1 p
31.         return;
    
32.     }
    
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    * M6 V$ t" B9 K- q* p
35. 
    9 G# B" C5 O; i
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    * l' H3 S1 Z% z+ w
37. 
    & h+ ]0 @* z: }8 Q4 A
38.          //Socket地址结构体的创建
    + X7 w+ }* ^' J; l6 E" `
39. 
    ; H7 J6 }! v4 X, j: s* c
40.          SOCKADDR_IN addrSrv;
    ! [  {6 q$ x1 I4 J3 P
41. 
    
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);
    3 r! S8 B* O0 d/ F) m9 ~
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    % C+ f# y$ l/ a2 c8 R: P, r9 K
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    
50.          listen(socSrv, 5);
    
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    8 H+ a0 ~! \1 @1 @$ }
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    9 q% r$ ?7 H% u* }$ R7 H/ M
55. 
    8 P- k* @+ _0 N9 R* X+ W+ Z
56.          //循环等待接受客户端发送请求
    
57. 
    
58.          while (1)
    + P/ E1 [% }; g/ E& u9 d
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    . `+ p9 B7 r' U3 h, M; ?+ {  G
63.                    //此时程序在此发生阻塞
    
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    4 ~6 B$ P! A( A) r1 W% b
67.                    char sendBuf[100];
    7 G" U" F! V( }( x( _" g
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    9 V, \9 l9 G# i, d
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    ; {/ s% |: L5 v7 v
72. 
    
73.                    //用返回的套接字和客户端进行通信
    / c% o1 I6 F2 Y# U  O
74. 
    ) w; a/ f5 a7 T/ N8 k6 z6 T) `1 z
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    2 o% k6 k$ V7 r# L
77.                    //接收数据
    
78. 
    
79.                    char recvBuf[100];
    
80. 
    & n& J1 a7 P# |! U( N
81.                    recv(sockConn, recvBuf, 100, 0);
    8 m7 c% c$ ^4 j
82. 
    2 l* Z' }" f5 c
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    , i; m! V3 v! v$ N  A. D" `
85. 
    
86.          }
    
87. }
    , `7 I# h+ ~- I
88. 
    9 V" Z# `8 M+ L1 |" d# R9 C
89. 
    
90. Client：
    
91. 
    
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    " t& {+ l: ?' K. t6 ]
94. #include <stdio.h>
    
95. #include <string.h>
    3 K" S! u; ?2 d2 d& B# r* i- t
96. 
    & D, U7 S8 e1 V. e0 Y# h0 e# \
97. void main()
    5 t4 H; u6 R9 p- j: U! t
98. {   
    1 F; |7 ?* J8 {, |7 h+ R" \
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
       |7 c# R7 k( D6 _) }( {
101.     int err;
     / V% D6 N; v6 M+ ]4 ]
102.      
     7 d" e& C6 P% ~& |+ _. ~  r( S
103.     wVersionRequested = MAKEWORD( 2, 2 );
     1 ]: [$ m0 I3 S& d" O( _8 f
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     " ]. e. C3 X0 W; g2 J5 m4 d8 q# U
107.          
     7 ^) i$ ^# ]% \0 @- i  w/ ^9 H" b  ?
108.         return;
     
109.     }
     : l. e* p' w, y
110.      
     # c3 U* s6 ^; E% W5 W0 Q# x( o, U- v
111.      
     : ]6 s: D/ S. I  u
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     & g' \! K1 i8 z' L: }4 E
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     
115.          
     
116.         WSACleanup( );
     
117.         return;
     
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     ) Y) C' v, Y/ q: o6 |7 n
121.     addrSrv.sin_family = AF_INET;
     
122.     addrSrv.sin_port = htons(6000);
     # I+ u; x' }% v3 s1 N) c+ o3 v
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     ) t2 n8 ~1 c+ E8 o! g
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     " S/ g  b7 [4 t
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     7 q, c! K: u- [) R6 C8 I% E
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     
132.     WSACleanup();
     " D; a7 ~" e) [
133.      
     / y* |0 h# C4 W. d
134. }

复制代码

' r/ r+ c# D. |