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

admin

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

1. #include <winsock2.h>
   , b% h! ~+ T. u  }2 B" R& j7 j; k
2. #include <stdio.h>
   9 Q8 o- r6 T! p& Z. v* \5 m' K
3. #include <stdlib.h>
   ) ]9 u  ^0 A" E) S
4. 
   
5. #define DEFAULT_PORT       5150
   . n+ s! i4 m# o% U' n* a6 b
6. #define DEFAULT_BUFFER     2048
   
7. 
     f6 n) }) s: \# [; c& ^7 ^( D
8. char  szServer[128],
   . L3 p7 ^5 L8 N$ C  `# m7 l
9.      szMessage[1024];
   8 {4 q& u  T$ H& g+ j7 R' K: m
10. int  iPort    = DEFAULT_PORT;
    % Y- X8 h- i6 `. c) {7 |1 b2 O/ ^" d
11. 
    5 U5 U- g0 G) H; l- J! C1 K
12. int main()
    
13. {
    % o  d; k3 g, p2 O5 r! R* f; l, r
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    + f9 k  y0 W6 V, }% {3 K5 c
16.    char         szBuffer[DEFAULT_BUFFER];
      G  D$ }) v  O* a
17.    int          ret;
    0 x4 o7 x* t4 B- [/ S- s
18.     struct sockaddr_in server;
    # E: m/ j) Z! D2 _" L; i/ s
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    - \6 v; ~- r3 g8 i$ u& s
23.        return 1;
    
24.     }
    
25.    printf("Enter a string to send to server:\n");
    8 R; Z, ^+ t. [( R1 G
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)
    - @% i4 h( x7 {& C' K9 G7 p
30.     {
    5 r: |3 q  q1 h, I$ J
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    ' @# L& n. l& E" m# s
33.     }
    + g3 `$ U3 F% z$ K# b
34.    server.sin_family = AF_INET;
    1 s- K. m" a6 N7 A" c
35.    server.sin_port = htons(iPort);
    7 E& v/ V; j, `* w- W1 q9 k
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    3 ~3 P0 |/ z/ t. i
37. 
    # E: U4 m2 A) {' t/ t
38.     if (connect(sClient, (struct sockaddr *)&server,
    " _: a) b" c" ~& @! g" E
39.        sizeof(server)) == SOCKET_ERROR)
    / Y7 S* Z, p* w9 _/ A5 @
40.     {
    # u1 c8 f( P: k  I6 c( O; g
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    0 Y* n4 `3 u% r+ x" a
43.     }
    
44.     // Send and receive data
    ' z% p3 h; \) |; o
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
      p6 B. w& g- x+ S* ~8 ]
46.     if (ret == SOCKET_ERROR)
    
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
      H, ^9 F1 @* L2 _! L0 J3 I7 o
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    7 c) w3 Y6 y& m. d7 Q" s
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
    / R5 G: Q; [, S0 m
54.          printf("recv() failed: %d\n", WSAGetLastError());
    7 @" D% d: i1 _* ~
55.        }
    & t0 h5 h6 L2 ?  v* ~; p* c, \
56.        else{
    6 a+ _) b% I# d) ^
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    2 D2 r1 K/ u: }5 s" r: U9 S
60.     }
    
61.    closesocket(sClient);
    # M6 I0 ?' {  C
62. 
    
63.    WSACleanup();
    - \5 O- I: A' }
64.     return 0;
    8 I5 E* Z' {5 Q# ]
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   0 G+ r/ T& L! l% r$ g) |3 x
2. #include <stdio.h>
   
3. #include <stdlib.h>
   ( x  U4 F( K7 l' e8 [- o- x
4. 
   3 L6 }& s+ A6 n1 V' Y* E
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     4096
   
7. 
   
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   
10. 
    7 b2 y) }3 L9 l. _" k7 m& |
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    ) M+ }4 T# m' S/ I" F& Q" d/ R: N
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    ' Y: S, V$ d! J
15.    int          ret;
    
16. 
    + R% h2 e1 Z' K) d) i
17.    while(1)
    
18.     {
    - g% t% q: P4 [
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    
21.            break;
    + Q# L8 i2 e. u2 N8 x
22.        else if (ret == SOCKET_ERROR)
    
23.        {
    3 p6 k& h, O7 f# Q+ M
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    
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);
    
31.        }
    " U& L; J" R$ m4 i7 t. W3 Q
32.        else{
    
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());
    ; H1 L# U! p* o) B
38.        }
    
39.     }
    . n1 G$ u8 q  L5 \
40.     return 0;
    - M! D2 I6 P4 T/ v
41. }
    " w' @- }0 }2 \* S
42. 
    
43. int main()
    
44. {
    
45.    WSADATA      wsd;
    ' c: X$ V2 [. `5 ^5 J4 I
46.    SOCKET       sListen,
    + K4 C" K9 m0 X$ H- ?, ^/ w1 ]
47.                  sClient;
    
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    ' F$ a3 d& i" V+ F$ R* q$ }: V
51.     struct sockaddr_in local,
    % ?" }% |3 \/ z" r: r+ F; b
52.                       client;
    1 Q  L2 M/ i6 i: I6 U, _7 ^' l& v
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    ; I- U. I* l3 p' L& E+ ]  W
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    
58.     }
    
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    7 F* n0 R1 r, ]3 U
61.     if (sListen == SOCKET_ERROR)
    2 H# P6 K. k* ]- y2 ^( J# p" k
62.     {
    2 {! a. G1 u! i! S
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    3 \" M- D1 T" h: h
65.     }
    / \* d5 K! c; a$ i( b! [" Z' v  y
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    + M3 E5 y9 C3 J# q
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    % @5 c: R: y/ Q/ {& s! z; t) X% Z
69. 
    ; P6 B& X4 G) L, r
70.     if (bind(sListen, (struct sockaddr *)&local,
    ! F) i' R3 L% E; w
71.            sizeof(local)) == SOCKET_ERROR)
    : N9 C, N2 n) u# _
72.     {
    9 Z, p4 A5 \, I
73.        printf("bind() failed: %d\n", WSAGetLastError());
    % |. x' Y6 e2 X0 Q
74.        return 1;
    
75.     }
    
76.    listen(sListen, 8);
    2 M" {0 ]3 `( ]0 R  C: ?, E+ J; O9 G$ c
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)
    
80.     {
    
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    / n+ k. a' h% k9 h4 k. W
83.                        &iAddrSize);      
    5 i  G7 m+ J" T. q+ l
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    ; }$ H) c3 w$ S0 @
86.            printf("accept() failed: %d\n", WSAGetLastError());
    7 h# a: B7 u# F, j6 L
87.            break;
    5 b; e  P& e0 \+ D# K
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    9 U( X  }) M3 h) O" n
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    # A3 X4 X1 }* I! a, k. M
93.                    (LPVOID)sClient, 0, &dwThreadId);
    ! g( f. L2 b" {; x, B; O; ^
94.        if (hThread == NULL)
    7 i5 L2 V9 h4 }, l0 s  I, u
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    0 ?% ]) C; t+ ?
97.            break;
    
98.        }
    - h7 B! d* V5 A- Q
99.        CloseHandle(hThread);
    
100.     }
     $ y' c# `0 k5 V! Z: {0 j
101.    closesocket(sListen);
     
102.    
     
103.    WSACleanup();
     . M; R/ |7 ^" J, R" y# L2 Z
104.     return 0;
     8 R" M) x5 Z( ]% C
105. }

复制代码

- _: r5 k, t( |: w. T: O

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   . A1 _9 e2 O; {$ ], B% s
6. Server：
   : ~0 g- j& e$ H" y
7. #include <winsock2.h>
   
8. #pragma comment(lib, "WS2_32.lib")
   8 H8 i# U# B' ]7 [, ^6 t  R
9. 
   
10. #include <stdio.h>
    * K6 g9 X0 m4 Z5 U+ z
11. void main()
    6 n1 Y, p) d, W4 J/ w
12. {
    
13.     WORD wVersionRequested;//版本号
    0 p' i% ~# G& X& {$ b+ R. I) w9 `. p
14.     WSADATA wsaData;
    - ]0 U. }: s" \
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    5 u- Z/ H- |0 A
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    : n4 g: M! a$ ?$ J
20.     if (err != 0)
    
21.     {
    0 @1 B+ v: |6 u0 R. c3 x; l
22.         return;
    
23.     }
    
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    8 u& j; t) T# `# v* `/ j# l2 y$ w1 e: y% V
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    
30.     {
    
31.         return;
    ! a1 I2 @5 X# f3 b# q% `  F
32.     }
      J  c6 o( ~+ w0 ?. S6 x  V
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    5 n8 t9 U! Y$ m, _
37. 
    1 n! f4 g0 o  j- s0 {* c$ B' ?
38.          //Socket地址结构体的创建
    
39. 
    + Q' H  [; G/ E
40.          SOCKADDR_IN addrSrv;
    1 i* [0 J& K( u$ b8 ]. ^
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);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    3 F2 S" v/ d! w/ j$ o) v0 C5 A( l8 V
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    # A8 s$ q3 c( U1 P
50.          listen(socSrv, 5);
    6 Z6 }( K' h! F/ p4 y) |
51.          
    , s- v  ?7 `+ x& K/ e( K) P
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    ; Z" P1 B" q  g# r6 z; C' J
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    
56.          //循环等待接受客户端发送请求
    6 y4 a# H' T8 i3 E2 p6 ?1 e  t
57. 
    # s& b  @5 M& n  ^
58.          while (1)
    0 p: ]8 O8 ]; G9 q. I1 o" ]8 G% y
59.          {
    . b: `, T5 ~, N' k" \
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    5 \* d) D/ @- n
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    
67.                    char sendBuf[100];
    
68. 
    2 H, ~9 k* o5 J6 Z; M( t: H: {
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    " C, G# A, _4 {7 p( f9 \3 ]
70. 
    * Z! c9 ?. i# P! a; n$ y# Z; @
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    . ^; P( {8 o& O4 v6 Z
73.                    //用返回的套接字和客户端进行通信
    
74. 
    3 B6 r2 U! L* Y8 ^+ {
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    $ G7 ~. K: p% f+ B- t
77.                    //接收数据
    / T/ [) I) N0 f0 z- l
78. 
    ! O0 X. J. p, H. K. `4 b% u
79.                    char recvBuf[100];
    : A  {/ l/ G8 Y5 o: p1 _- @9 f+ E
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    + L2 j; j1 C6 v+ ]* v
82. 
    - j  R( L; Y# d
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    
85. 
    
86.          }
    0 o7 G+ p$ W4 |/ p7 i8 h
87. }
    
88. 
    
89. 
    4 l% D: a( c3 A5 _2 R% v2 [+ x( Q5 i
90. Client：
    
91. 
    
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    2 ~7 U; `' j  N) I
94. #include <stdio.h>
    ( q2 G; |% l5 i% b9 f
95. #include <string.h>
    
96. 
    
97. void main()
    
98. {   
    6 `1 h& T9 Y  O/ i2 T3 I
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
     
101.     int err;
     
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     7 S& Y' u# N& U
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     
107.          
     
108.         return;
     3 r2 Z6 y% w. F
109.     }
     ) I& C8 P1 e8 s8 Z4 N2 v
110.      
     & a& f/ B7 `; F6 M) z; I2 M; E. T
111.      
     0 L! _/ |1 a8 d% ~* @
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
       e. [* n, f& `; K
113.         HIBYTE( wsaData.wVersion ) != 2 )
     ; |6 N" l0 U3 N% z9 }- z
114.     {
     
115.          
     
116.         WSACleanup( );
     ! ?- u" z. f+ n: j; v3 l
117.         return;
     
118.     }
       ]$ P' ]/ w* w5 c
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     + v2 w4 K2 s' |9 `# R' l  o1 Q3 m
122.     addrSrv.sin_port = htons(6000);
     / d' j6 b5 _+ m7 K4 b
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     + o2 m/ z1 L2 O0 I3 b
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     7 g$ ?# c1 J& b7 V* A2 _/ U) x
126.     char recvBuf[256];
     : L1 N1 T) ~0 t: M. m
127.     char sendBuf[] = "This is Joychou";
     & {2 f2 a" J. t* W9 k% n
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     $ t# D: z3 D6 q$ b
131.     closesocket(socketClient);
       B7 X0 \2 j- e+ Q$ e
132.     WSACleanup();
     
133.      
     ' F1 ^3 M$ r/ {* o* @
134. }

复制代码

# D( y8 u% G, @. w# z