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

admin

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

1. #include <winsock2.h>
   # |1 k' I# _# H6 P
2. #include <stdio.h>
   * l/ t  q& r, Q( C8 ]
3. #include <stdlib.h>
   1 p8 ?$ P$ x0 f8 a8 {9 Z
4. 
   1 y) M5 a. O5 {1 a0 f
5. #define DEFAULT_PORT       5150
   - o* E. u- `+ S9 T: f/ k% Z9 ]# G; X
6. #define DEFAULT_BUFFER     2048
   
7. 
   9 H5 I! b  M( L5 o( J2 o' B% y
8. char  szServer[128],
   
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    : L* Z' y/ U, x/ d, e
11. 
    9 e3 C/ u& z6 ?+ y, @, |% f
12. int main()
    
13. {
    
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
      S1 x+ s: M; y/ P- I0 z
16.    char         szBuffer[DEFAULT_BUFFER];
    8 O, Y; `3 l, ]8 r, E+ S; v
17.    int          ret;
    2 a2 l! J; w/ f' ], Z
18.     struct sockaddr_in server;
    & a+ e" C7 {* V3 a& Y2 y
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    8 x! W1 g& i* D4 e4 x
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    , w3 L0 x3 ?( @! Y) ^" e
23.        return 1;
    
24.     }
    
25.    printf("Enter a string to send to server:\n");
    . W2 E" \# Z/ d5 ?+ `
26.    gets(szMessage);
    8 \2 x' F2 A$ Q7 }! {: k! M
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)
    ! |/ e; r& g5 r3 P
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    
33.     }
    & N) `8 p* \, u' ^3 k
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    : A$ S5 A, G9 \7 O! u
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    5 K% }+ `# c" m5 f# q5 }, u
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    * g6 j: p  P2 R2 q% z
43.     }
    . I9 L- O( D: j/ J8 m
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    : j0 X: S' t  M9 \; P+ z, |
47.     {
    ! Q. d; `3 O* y# \
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    % \# r6 w! U" J
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
      u( w8 q9 b3 C' v3 `
54.          printf("recv() failed: %d\n", WSAGetLastError());
    9 s- D, b, G6 w5 }1 r  O. u2 Z
55.        }
    
56.        else{
    
57.          szBuffer[ret] = '\0';
    * P  f/ i" k* r) p: D: S
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    8 m+ I, t7 Z9 L# c- a
60.     }
      ~" M( o+ R4 D& I. l2 j
61.    closesocket(sClient);
    + d2 y; `4 A: v, g
62. 
    
63.    WSACleanup();
    
64.     return 0;
    + g: x6 l3 ?# x9 V
65. }

复制代码

服务器程序:server.cpp
7 p- _2 D  ?, @: A' ^

1. #include <winsock2.h>
   + }. b# N5 X0 v3 Z; _# l
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   % ?6 c: ^1 u- ?8 \+ G/ M
5. #define DEFAULT_PORT       5150
   . c4 H; s& _% E: e2 S3 `
6. #define DEFAULT_BUFFER     4096
   
7. 
   
8. int   iPort     = DEFAULT_PORT;
   $ i6 s, k8 r( z% V9 o$ r1 o9 \
9. char   szAddress[128];
   
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    % V/ p# K' e  x" ^) F' A4 l
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    - h8 H$ P2 F# v% a; V5 Q, l; X. C
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    
16. 
    * ~% u6 R; D$ i) x
17.    while(1)
    7 Q) x7 w) T8 }' }& C
18.     {
    7 G6 u# L) _/ z/ O6 H' i
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    / z9 F: R( X3 `8 ]7 y" u- f
23.        {
    : Z3 o5 U1 R2 ?" m
24.            printf("recv() failed: %d\n", WSAGetLastError());
    " Q- K. A; Y2 }; _
25.            break;
    
26.        }
    
27.        szBuff[ret] = '\0';
    ! ^$ n1 T, s( s2 g* b$ H5 @! R
28.        printf("RECV: '%s'\n", szBuff);
    # F1 B- @% n7 F) s( `
29.       if(strcmp(szBuff,"abc")==0){
    
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    4 Z; q. d: O4 f( l
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    6 V  M. C$ h9 i% L% ^9 K, J
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    * K" @; V. Z8 d5 T/ E
37.          printf("send() failed: %d\n", WSAGetLastError());
    # U9 w' z$ }0 Y+ c( v7 |
38.        }
    6 K; X5 z, p; l+ v- [
39.     }
    
40.     return 0;
    
41. }
    ( Y9 |  A( F9 A; M0 B* e
42. 
    
43. int main()
    
44. {
    
45.    WSADATA      wsd;
    # I2 _2 D  [! a9 Q( X
46.    SOCKET       sListen,
    0 z+ n& }, w* P: U# |, v
47.                  sClient;
    
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    1 K  V8 x5 m3 {" Y+ [5 h4 T
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    ) p* K- ^+ I$ Z1 t1 _- y
52.                       client;
    4 \* C" a- }! {0 E- r8 `
53. 
    . u+ E0 O% I0 Z
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    ' q" I) `8 d3 i8 F* l# R8 v
55.     {
    # ?8 y4 _, r0 E& u/ \
56.        printf("Failed to load Winsock!\n");
    $ R7 O% n9 O6 z/ B# Y, M
57.        return 1;
    ) D( t7 L. [; d
58.     }
    
59.     // Create our listening socket
    0 b* t6 M9 R3 Y: K* D! C4 X; L
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    - M- k: G/ W, R
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    ' Q# `' N4 E3 W5 N2 `
64.        return 1;
    
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    
75.     }
    
76.    listen(sListen, 8);
    
77.     // In a continous loop, wait for incoming clients. Once one
    6 r. g8 \0 s* d) e3 P# N: V
78.     // is detected, create a thread and pass the handle off to it.
    & f/ e& i- l# z$ b1 z9 O  w
79.     while (1)
    9 {) F$ M, N7 ~2 l; @7 d
80.     {
    2 ^7 x5 F: @6 T, @) D
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    $ W+ i) i4 Y/ u) k1 f6 Q. T
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    ( l6 o! V  z8 D$ X, _- [
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    
88.        }
    * {, Q! _7 {$ s# i. B
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    + d& D* W* i6 E0 P7 r
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    - |* m$ `6 x8 n' t
97.            break;
    
98.        }
    
99.        CloseHandle(hThread);
    
100.     }
     * P4 n) W1 s8 A: [9 M* U7 `
101.    closesocket(sListen);
     
102.    
     
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

. m; D! @1 G: J# c

5 N1 @# s" s+ x% e& {, S
6 J! R% ^% y& Z7 _" @
+ A2 b; u2 W8 J5 |

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   * h0 @3 [2 {! |% x4 Q4 \
2. 
   ' Z7 Y# k6 V7 N1 c9 \( I$ u5 t* P
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
     G% D8 |' Y5 R+ @2 o2 Y
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   $ F5 e! m$ N* p8 Y$ L1 C7 e2 k5 I0 Q
5. 
   
6. Server：
   # c! @6 r7 U" U% ^; \, Z1 E7 v% H- ^& t
7. #include <winsock2.h>
   8 H" `% l+ |5 ~) h, V* s
8. #pragma comment(lib, "WS2_32.lib")
   7 }+ V% D% `; `7 d: b, J
9. 
   
10. #include <stdio.h>
    
11. void main()
    0 s! n: v( Z2 P& [
12. {
    0 d0 _2 u5 v" a3 e
13.     WORD wVersionRequested;//版本号
    + K( m. z5 I  L4 s6 X
14.     WSADATA wsaData;
    
15.     int err;
    4 R+ Z" a/ z- d& `  P5 @- V
16. 
    # Y; r0 B: n2 ~  e% K& L
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    ' W0 {6 {) L  r4 D8 Q. J
19.     err = WSAStartup(wVersionRequested, &wsaData);
    + @* l$ ^' _4 s( O% t/ U
20.     if (err != 0)
    
21.     {
    & J: x) _; C6 B7 I3 ?, Z
22.         return;
    
23.     }
    ) J# P3 ~' c9 u
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    ; G( W  N; [; W* {8 [) N" Z( F
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    ' ]& C0 Z# T; t
28.         HIBYTE(wsaData.wVersion) != 2)
    ! l0 G- h, r  b# h
29.          
    - R3 E7 h, B: l7 `4 @9 O
30.     {
    8 Y3 @4 M4 u  p6 B: [' c4 i
31.         return;
    7 A4 ~' Z- \  X. K. j
32.     }
    
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    7 k+ M; E* F+ d" C: [$ D4 E
35. 
      V9 T0 i" \9 M
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    - v$ O1 O1 D6 B
41. 
    7 X. a0 s4 o4 Y! l
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    5 b- s% e8 Z: Z1 |# x6 c% {# {
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    * n% @5 H, S6 L7 F3 |/ M2 ?
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    + H$ v0 v5 Q5 G, ?2 Z$ |
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    4 ]) U5 o+ {' p; A6 q, O) T- ^
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    $ G7 R0 C" _7 j+ m
49. 
    % o: i6 C: t( E/ V: T6 q7 C: v
50.          listen(socSrv, 5);
    - K% I6 g0 ^" C7 X; h1 X2 {$ H5 L
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    / w# m0 n, C. s* L  r3 I
56.          //循环等待接受客户端发送请求
    ( ~  o# j1 k* b6 `4 w; W# o! }# W
57. 
    
58.          while (1)
    ! [2 s; r: a, `
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    4 u! @" A, n# f5 Z
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    ! S5 B; E! Q. h9 l8 i
63.                    //此时程序在此发生阻塞
    
64. 
    * {7 Y" J, f9 b. a
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    5 P9 D* r$ }3 O& f0 ?- z1 c
66. 
    / G0 C6 p0 t9 x
67.                    char sendBuf[100];
    9 ]% M: l( n3 Q0 P& |4 F6 |) |: h
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    * y; ~' V$ E  O- Q5 j
70. 
    , m2 P  z- \! f* |; x' ]
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    
73.                    //用返回的套接字和客户端进行通信
    ) d- i. A  w9 h) I! ~" t: i
74. 
    7 U. z% H3 v% f- w* x4 W4 H7 Z! a
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    , e5 e/ S+ i" @/ r
76. 
    ( e6 T* M8 r4 y* s5 s  A
77.                    //接收数据
    5 t9 y1 Y0 v: K; E2 w& F3 ]
78. 
    
79.                    char recvBuf[100];
    - d$ U2 V: A% }* ]3 e
80. 
    # F5 T7 u( x3 C
81.                    recv(sockConn, recvBuf, 100, 0);
    / D. L$ g* ~( l$ V! S
82. 
    * h! V. Q! c; L. T3 g( M/ P: U* `2 s
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    
85. 
    ( E1 y, H8 e. a! f7 l
86.          }
      P7 ~$ z) V1 q0 U7 C2 B2 s6 y
87. }
    ' L+ Y& k7 ^1 H1 J; l
88. 
    
89. 
    : L5 Q6 s! H0 ~' }* l" G; \
90. Client：
    2 w  r2 o+ e) x
91. 
    / M. G7 L) M' T2 m. x  v
92. #include <winsock2.H>
    $ k" T7 L7 ]3 y" [9 r  e
93. #pragma comment(lib, "Ws2_32.lib")
    7 u* p7 j$ v9 O- s! a* o; w
94. #include <stdio.h>
    
95. #include <string.h>
    
96. 
    
97. void main()
    5 ~* _8 p$ x- s
98. {   
    
99.     WORD wVersionRequested;
    6 T9 F: E( i3 d& R  D7 @, d! Y
100.     WSADATA wsaData;
     6 ^* x) z/ D( ]' J, x/ i
101.     int err;
     , t" ]. Q; p: [' P2 G3 A# J7 \
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
       {+ s) S+ }1 i# D; T
104.      
     ! }3 E  T( K0 J3 m3 G+ N
105.     err = WSAStartup( wVersionRequested, &wsaData );
     - M, C; d8 h5 s: T' k. z
106.     if ( err != 0 ) {
     ) ^1 q' v9 W- ]  e# ^3 ~8 r
107.          
     
108.         return;
     
109.     }
     
110.      
     6 T% U5 @5 I$ C
111.      
       I1 f7 q0 k" @
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     & e6 K! a9 v$ w$ f, g
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     
115.          
     
116.         WSACleanup( );
     & t( G1 k$ B# R( G- a# {2 T
117.         return;
     
118.     }
     + B) z- ?; Y9 D% U9 n! K
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
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.      
     / M) o& }3 Z' m* c" [
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     8 c& T+ n1 e& V, r+ n& ]4 f
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     6 `, @6 n) v$ ?" y
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     / b6 ~. B- t& S, s/ z1 o
131.     closesocket(socketClient);
     
132.     WSACleanup();
     
133.      
     
134. }

复制代码

8 W; n; X, b. D