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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
4 n# }7 m1 p5 h, c0 }% ?客户端程序：client.cpp
6 t3 _' V/ ~- O5 s6 H8 i

1. #include <winsock2.h>
   9 @9 T5 _4 {! W) ~& I( b% ]
2. #include <stdio.h>
   ' a4 r% n9 o* ^
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   
7. 
   
8. char  szServer[128],
   
9.      szMessage[1024];
   / f/ }4 L# G% l# M' L! F
10. int  iPort    = DEFAULT_PORT;
    2 Y  f* K. U9 o2 V, k& z
11. 
    
12. int main()
    
13. {
    + N1 t. n5 y2 A
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    ! K! Q* }# D# }5 G/ y* j; K
18.     struct sockaddr_in server;
    ! O: C' F: ?4 a! y" I  S. x
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
      D. K1 N7 A, W
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    
24.     }
    
25.    printf("Enter a string to send to server:\n");
    9 I8 N+ m' m5 W4 A
26.    gets(szMessage);
    : k3 [% c* ?4 L/ Q  D/ B& u7 @. r
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)
    6 b. X5 {& r+ M5 i/ _0 Q
30.     {
    ' _) I# T% D8 b/ B* d9 F1 M& \
31.        printf("socket() failed: %d\n", WSAGetLastError());
    ( N) s  V; ?" w- l' H& G( B
32.        return 1;
    8 r" k$ Y1 u; I, ^
33.     }
    
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    , C8 Q4 k3 [( `2 @8 Y6 ^
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    / a  I$ f& S; v$ d# F5 C: h
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    ) T7 u8 z3 x+ t; l4 I1 j
42.        return 1;
    5 m: A% b% C) s0 y2 k
43.     }
    9 @4 Q6 z  n9 H- |
44.     // Send and receive data
    ! w: X2 o2 Y5 O: J
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    . [5 ?. r" y- }
46.     if (ret == SOCKET_ERROR)
    % z1 A' E/ c6 J6 F
47.     {
    1 f8 U$ Q7 n: L& R) R4 N
48.        printf("send() failed: %d\n", WSAGetLastError());
    ; D% Z  m# J' [  @" u1 d+ P% Y) \
49.     }
    , L' G# E* Y( `! y
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    4 m( z6 [) F, b' o$ S1 }6 r1 _) B
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    / P0 t3 y, M/ E5 X7 f
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    
56.        else{
    % E: C, O& C; V# ]' _- K" o
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    - p% ^* G8 A( J' C( ?+ f3 U% D
59.        }
    + b$ y& Q! J7 @6 N- X
60.     }
    + _, n% u1 u4 Z! a8 K
61.    closesocket(sClient);
    
62. 
    1 ]. i; y- |/ q8 U1 M1 l. [9 Z- O
63.    WSACleanup();
    4 Y% J) I% r* g
64.     return 0;
    7 Y. |- ?! W& z  }3 }7 ^
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   2 j& W! R" K* S2 }+ W, q3 W) F+ C
2. #include <stdio.h>
     k& a9 ~9 x' s/ w; \
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   * `4 F  K0 g  K5 U5 o0 i& v
6. #define DEFAULT_BUFFER     4096
   
7. 
   
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    : x" Y) }# O# D3 p/ X- F
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    . H3 ]0 K( E4 {' H
15.    int          ret;
    6 Y- F" @; p. F/ m. ]6 z
16. 
    
17.    while(1)
    
18.     {
    
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    
21.            break;
    - P4 Z- N+ c/ p7 W4 K8 N# s
22.        else if (ret == SOCKET_ERROR)
    2 e; b) _+ C- @4 v' ^% I
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    
26.        }
    
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
      _' i1 ]* K2 ^* z
29.       if(strcmp(szBuff,"abc")==0){
    8 T- e9 B. D1 B+ t9 l4 M  q
30.          memcpy(szBuff,"Send the correct string!",25);
    % p( h. \0 S! ]) j/ e
31.        }
    & W( K* Q  ^4 y% w5 V+ F
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    ) [9 y, N. B  m0 y3 ^5 Q
34.        }
    , S' d- k9 `! `
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    / ~, K6 ^0 \5 k' A+ o
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    1 d8 z( }' K0 }2 U* ]) ~
39.     }
    
40.     return 0;
    
41. }
    . K( h! V% ?" g( T6 q
42. 
    
43. int main()
    ( j$ {* k: u1 T# T
44. {
    , M8 A& t; F# Z* `& N3 K2 p
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    9 ]0 G9 P  R- U
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    ! V; K; g7 [: N, `7 X1 p
51.     struct sockaddr_in local,
      N: J" |  f) C2 a( }0 O' _" d
52.                       client;
    & c9 q+ l1 X% U3 |
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    " O& S6 F) r. t
55.     {
    # N) T. {  D" y* _5 F& Z
56.        printf("Failed to load Winsock!\n");
    6 N1 e1 Q* M6 }" v% U
57.        return 1;
    * }7 w# b  z. U2 y% ^$ B
58.     }
    
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    2 c& _. Q. ?4 @5 c/ ?0 O
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    : p  d% J6 K; [3 [8 @
64.        return 1;
    & Y  f2 E. k" I6 J% H$ E
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    ; n: N1 _3 r) K9 e' s$ c
67.    local.sin_family = AF_INET;
    1 ~1 u) T3 ~( K" @
68.    local.sin_port = htons(iPort);
    
69. 
    8 F, [( p: w4 E) q% Z  U
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    " g" @  t! S( p* S9 z
72.     {
    7 \3 p' p; o( I/ n( Q0 [# P) W/ i
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    ( ]! T$ _4 L: N" O, [
75.     }
    
76.    listen(sListen, 8);
    1 H: r9 a) ~, R# A
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)
    / V! C, I5 S" W  G* Y  J
80.     {
    
81.        iAddrSize = sizeof(client);
    1 q8 J$ p$ @0 Z
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    6 v% a7 m, E. X) ?, e1 _
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
      X4 \) d7 ~2 d% s
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    5 Y' I+ [  `' Q0 v  j. V
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    # W: ?3 N& b9 G& F. N8 g
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    * E" l  y5 w" M4 a; C+ B
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    5 H; B3 A: v4 @" X1 c3 A# b
97.            break;
    : F- h, N: ~  p" G4 j9 p
98.        }
    
99.        CloseHandle(hThread);
    4 f: k$ p3 `; ~; D7 W+ b
100.     }
     # C- I6 f  B8 Z' x& X* _. t
101.    closesocket(sListen);
     + g5 {' @1 K* u' B0 i0 Z
102.    
     6 e) ]$ U7 w0 d# h3 X3 Y* [
103.    WSACleanup();
     ) |4 t1 I; m$ Y! N" `
104.     return 0;
     6 M1 A& e2 o' i: R7 h
105. }

复制代码

: n9 U% e7 n/ n
9 V! _/ l8 a7 e# [+ f

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   5 m! X6 }8 a- g" b, N: @) G
5. 
   
6. Server：
   
7. #include <winsock2.h>
   4 s9 j9 @4 L' L; B2 a
8. #pragma comment(lib, "WS2_32.lib")
   9 D! G7 ?! H7 H4 D1 b1 j" x" E1 u1 m
9. 
   ! H" i# D1 S" {. T1 U9 l  ~0 V, X
10. #include <stdio.h>
    . _/ ~/ Z1 [1 D, g# n% h
11. void main()
    % d1 Q+ M8 X6 X0 |5 d8 E! y/ e; s
12. {
    
13.     WORD wVersionRequested;//版本号
    + N& h; i2 m5 E
14.     WSADATA wsaData;
    
15.     int err;
    " d  c& f$ s$ J
16. 
    * [. b$ i, Z) _) x' o
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    ( n" n$ ~; _7 m: F4 B* A. t6 i, u
19.     err = WSAStartup(wVersionRequested, &wsaData);
    * q. [# X* ?, e/ K8 B$ h
20.     if (err != 0)
    
21.     {
    6 A% \* F4 o7 I; ^4 H  }
22.         return;
    ! x; G. d. u9 S+ Q
23.     }
    ) |! P6 u2 Z  Z: l: h; C4 l; d
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    & d; r, p) G7 V5 N7 H& u. ^7 X8 T
27.          
    ; s0 X. ?: O7 d8 I: I$ E# b- C& r3 K
28.         HIBYTE(wsaData.wVersion) != 2)
    0 u" O- {! v, o9 Y0 k0 @3 N: S
29.          
    9 B1 ~+ V& c7 V9 Z/ m* ?& K+ F# b
30.     {
    5 Y/ ]( R& @9 f8 i! X3 f
31.         return;
    
32.     }
    ) r  `) m  k, [$ J; Y  s, x
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    1 F3 j" m/ S' a3 b6 R$ P
38.          //Socket地址结构体的创建
    4 X% e& _2 S$ a5 I+ d3 f
39. 
    5 J& K3 ?' F  u; v4 w- O7 i
40.          SOCKADDR_IN addrSrv;
    - W, ?* T; S& _
41. 
      v+ I$ u# t/ b8 @# H$ x; @
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    % w+ e- X' d# u1 |( A  d
44.          addrSrv.sin_port = htons(6000);
    : P/ a1 C( M7 r2 ?0 R
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    2 @) h- c0 Y8 y+ y" O
49. 
    5 K1 `1 I* o0 ^. F% p5 a
50.          listen(socSrv, 5);
    4 x3 g. o  Y0 m( \8 N8 X: y2 j- r
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    3 m, }/ ^$ ?2 L% f6 r+ C, H3 P
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    
56.          //循环等待接受客户端发送请求
    ; }/ X0 _/ B* r6 [0 t  G7 c% @
57. 
    * P, x) {8 }2 V' P2 n, g
58.          while (1)
    
59.          {
    + G$ j+ L. \1 l: |* h* I
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    2 W) \2 I+ l1 _) [: C( e
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    + d1 u& q4 X0 G/ M/ g. d  Z
63.                    //此时程序在此发生阻塞
    
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    
67.                    char sendBuf[100];
    
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    + y0 s/ g" `1 `
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    ; r' f' ?4 l6 g
73.                    //用返回的套接字和客户端进行通信
    : d: E/ o  D3 h" o
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    
77.                    //接收数据
    4 t7 T; t# Z7 v8 J
78. 
    
79.                    char recvBuf[100];
    
80. 
    8 b3 t8 ]( M4 a- C
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    / e- E- ?' u2 }; }0 R; r
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    
85. 
    
86.          }
    
87. }
    
88. 
    
89. 
    
90. Client：
    
91. 
    * F# `4 D5 I8 H7 N
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    % o% }/ N* e4 d3 C( ^9 \5 g
95. #include <string.h>
    3 R# d) r+ ~6 g: Q  u* m' X
96. 
    
97. void main()
    
98. {   
    
99.     WORD wVersionRequested;
    4 I1 j$ \# ]$ g+ m$ w% E
100.     WSADATA wsaData;
     
101.     int err;
     9 N; [, c5 k% A( T+ A' G
102.      
     / P- ~" D  g$ f  s% w
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     7 R  B! L! @/ G( g
106.     if ( err != 0 ) {
     : O  @; M4 ~! t& v$ g
107.          
     
108.         return;
     
109.     }
     - Q" L( z: a( C) p) M
110.      
     1 n% w$ F9 l5 X) |0 e
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     7 L7 j* q3 x: n& A# ?! M  S% Z  O
113.         HIBYTE( wsaData.wVersion ) != 2 )
     0 u! I7 J' Y& r
114.     {
     
115.          
     
116.         WSACleanup( );
     & {- h+ X/ D8 d* j
117.         return;
     * N5 t( s! C+ k; }4 _
118.     }
     ( ?" n7 J  t& S! a1 Q
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     9 C  ^" H9 d  B' B
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     6 `( s- Y% K$ H! s( t8 q, S+ ?- Q
122.     addrSrv.sin_port = htons(6000);
     : i3 H1 V, \5 Z& h, E2 K
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     ( Q8 I  `( C0 u4 T- j& y: [
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     & J: O% O6 y2 O% \- T
126.     char recvBuf[256];
     ; q* g6 T. k( p
127.     char sendBuf[] = "This is Joychou";
     1 u) z$ g$ B. e* c2 r2 Q8 m
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     ) m% f7 D& R% M: k* d( A* }
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     # S: |9 X) q; D5 v( D' T% [, b/ e3 L4 F/ e
131.     closesocket(socketClient);
     
132.     WSACleanup();
     
133.      
     ( O# H/ W! u! c+ p# A' M2 \
134. }

复制代码

7 y0 c6 v* u6 W4 \" j  m