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

admin

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

1. #include <winsock2.h>
   ! O$ T' {. k1 u( g% W: a
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   & i+ d- P, _. @( M; p/ y
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   : G; V$ M8 Z0 z8 i- c# D* g$ J! u
7. 
   
8. char  szServer[128],
   , W- H2 D! g+ H: g4 g6 c# _
9.      szMessage[1024];
     ^3 }  w/ ]% T* v
10. int  iPort    = DEFAULT_PORT;
    
11. 
    
12. int main()
    
13. {
    
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    7 o; _& I$ f$ W, R4 y1 b( m
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    - [) o( I: P% t
18.     struct sockaddr_in server;
    : M) M. Q* u8 t) }# P! V! \
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    # v2 h/ c0 O; z5 b5 j! X
23.        return 1;
    " b+ ?. v/ G# }& T7 n
24.     }
    
25.    printf("Enter a string to send to server:\n");
    ' `4 p# `$ K. p) h: A
26.    gets(szMessage);
    
27.     // Create the socket, and attempt to connect to the server
    
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    ! d1 ]* Y. |% ~+ i% F4 @
29.     if (sClient == INVALID_SOCKET)
    
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    - k% t2 q0 E8 N
32.        return 1;
    
33.     }
    $ t! D! |* U4 l% W; A9 I
34.    server.sin_family = AF_INET;
    + M: D. ]2 A$ f" i3 i0 t
35.    server.sin_port = htons(iPort);
      e' O% N$ H0 U4 p- s
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    3 E# O6 m2 ]/ A4 O% U5 I: l/ Q
38.     if (connect(sClient, (struct sockaddr *)&server,
    $ \; \! H. K0 P. k
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    * L; X  U: E3 E" K3 n# x; o9 a. E
42.        return 1;
    * y: X8 Y) c4 |- D
43.     }
    
44.     // Send and receive data
    ) j+ M& R, n) L
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    " M/ {! L8 Q: o/ T" ]
46.     if (ret == SOCKET_ERROR)
    
47.     {
    ! n" H9 F' r, @  s9 X. [" ]$ {
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    8 V) G/ |1 U7 r; @) c1 X) v
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    1 c4 U7 X1 Y" I9 \% u
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    8 @3 L5 ~5 R; H6 ]2 x
55.        }
    
56.        else{
    & d8 t- ^, k1 ~( J8 C; ~- ^
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    % {4 f* n7 v: j. O, |  \! E7 i) q8 Q
60.     }
    - J7 A, X5 K( A" A; o& }8 f
61.    closesocket(sClient);
    
62. 
    7 o0 o5 `7 k5 H9 [. S3 l! a) `- i: \
63.    WSACleanup();
    
64.     return 0;
    " a" a: V* ~, V" O' n8 i3 o
65. }

复制代码

服务器程序:server.cpp
% h1 n( }8 S: v( l# M3 g

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     4096
   
7. 
   
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   
10. 
    : s# q+ B9 Y, X2 _- ]2 ~+ s( `& _
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    / o& T1 O- V0 ^0 Q" a: r5 W" x
12. {
    - m: U- ?0 Z- |' k" ?, e
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    ' V! Z" I# |9 n- _& Y
16. 
    
17.    while(1)
    : l2 S' L3 [- ~! {- U. V
18.     {
    ; y) Q: v* W5 Z: p2 ]+ W1 m
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    2 o7 s# ^  K5 X, h/ N4 @  V, I! n
20.        if (ret == 0)
    7 r# L6 l# e$ R9 r
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    
23.        {
      i1 M% `. v% J2 L7 }  r. ^
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    
26.        }
    4 j% @5 D2 J! P! l
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    ( v3 J; h5 h- D  f
30.          memcpy(szBuff,"Send the correct string!",25);
    ' H3 x' j  c- \& u! j* S$ w
31.        }
    
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    # u5 C: s$ Q8 U$ I$ C
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    % {; A$ E7 Y: O9 n. s
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    & l3 e& e/ |) {/ J: n7 o
38.        }
    
39.     }
    
40.     return 0;
    $ o/ i3 S$ a0 ^$ X9 V1 G
41. }
    
42. 
    
43. int main()
    
44. {
    6 Z! F0 P% L& s# G, x% K; H- A
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    5 k; |3 d9 M5 Z2 |$ o7 W
47.                  sClient;
    0 u$ E. ^* G1 @5 R+ {6 U
48.    int          iAddrSize;
    8 x; \3 U' M- l& b- k$ S
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    / b- N- P4 X0 |* M- K
51.     struct sockaddr_in local,
    
52.                       client;
    / m" V7 A2 M8 r' Y5 K/ L+ S7 w
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    3 @) p7 h3 x* J' Z- U. F
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    
58.     }
    8 U" |( d* l+ }4 k
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    ' _$ ^& w9 l$ A: l3 l0 A$ M
61.     if (sListen == SOCKET_ERROR)
    9 f. R" a& J. c
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    5 S. y4 X% s! [
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    5 F% t% [- T5 [  R; E
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    
69. 
    5 m- n: k3 y  O, u5 X4 y
70.     if (bind(sListen, (struct sockaddr *)&local,
    6 }) v6 u6 M2 I+ U
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    6 _- D; v1 A8 Y" B6 ], s) z
75.     }
    
76.    listen(sListen, 8);
    
77.     // In a continous loop, wait for incoming clients. Once one
    : V1 R- T9 l6 n8 m. a( e
78.     // is detected, create a thread and pass the handle off to it.
    
79.     while (1)
    6 e# `8 D- ]9 R: s% T# j! Z6 O; {
80.     {
    
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    ( }! A8 g7 o- s
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    
88.        }
    5 B; a. I2 Z( H7 S$ a
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    9 _  H# ^; I. i' E5 `  v. e
91. 
    7 R+ e, c/ l: u) a" `3 }
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    1 C# l, y: }3 L) D% |
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    
98.        }
    $ o7 J* L& Q' |  I
99.        CloseHandle(hThread);
    2 k+ }* ]; E/ m* K( _0 [* m
100.     }
     $ z* }+ O$ P8 F! Q
101.    closesocket(sListen);
     ) T% H  Y3 {- X" Q
102.    
     2 q) }& ^/ H$ q# w# b- @5 {& V% D
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

8 p2 M3 T4 n0 t
( ]7 `2 s# P  y) E3 x; O6 j' ]
, U7 o* P: |- y4 t% J1 r/ Z

2 \0 H1 Y4 l2 U) N# O

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   $ S( x- Y: K! _8 {1 `# ]6 ^
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   
6. Server：
   
7. #include <winsock2.h>
   0 p& P6 l8 ?/ S
8. #pragma comment(lib, "WS2_32.lib")
   % O, S0 a* e# S4 W+ \& M: [
9. 
   " N3 j' Z% X! b; Z6 p' h
10. #include <stdio.h>
    
11. void main()
    ! L5 j/ A* i2 S; M" Z; f  Z1 @
12. {
    ' A3 z, j* n' Q8 n$ i
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    
15.     int err;
    
16. 
    ' P' X1 g+ C& [* C* ^: x
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    $ Y0 }2 r5 Z  q' s8 H* L+ [
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    * N' j) X5 [4 i% @, t2 l+ K( e) z
20.     if (err != 0)
    - }& d# g' z1 x4 N
21.     {
    ; R& E  L: ?3 |7 B; e5 I% E; M- T
22.         return;
    
23.     }
    - z, |$ Q% o/ O
24. 
    2 c- e' z' h6 `% D5 t" C% R
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    0 G6 x' y, ]- J  n
29.          
    
30.     {
    
31.         return;
    
32.     }
    ! n% v. s$ ?. q' o5 s# M" P# x6 N
33.      
    8 P% y7 @0 z$ a  p
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    % z3 v+ E; L. i
37. 
    : X9 L" I! F9 I  M, g3 f+ u
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    
41. 
    6 J7 M9 q% @; M) E
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    + B3 b" G& p( I: A, m& c# b
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    9 S" y1 M% P1 \
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    , f) ^( N- s7 n
49. 
    
50.          listen(socSrv, 5);
    
51.          
    3 L3 V$ q* V" T7 y) X
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    - ]* @% H5 V; I# c
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    & k8 s9 e8 b. i3 @9 Z/ ^* Q5 b
55. 
    : Z* f8 }- `& R% I
56.          //循环等待接受客户端发送请求
    
57. 
    
58.          while (1)
    
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
      j- }3 F- ?* K% y- y5 B3 ]. a) r
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    3 z+ w) j7 s# r: M2 \  X  J1 G+ Q
63.                    //此时程序在此发生阻塞
    ' ~7 j8 ^: P: y, J! c; ~4 I
64. 
    ( J( z9 @1 x1 y9 ^
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    0 @* j1 X% C* D: h" J
66. 
    # |6 C, {- F. X
67.                    char sendBuf[100];
    
68. 
    7 ]) c7 N1 [4 w4 x6 i( _
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    1 \+ \9 B1 n. {4 D$ f! n7 B9 A
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    + X/ ]( T4 c# O( e, E$ M
72. 
    
73.                    //用返回的套接字和客户端进行通信
    & M' b) }+ S% j% I
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    # s/ z6 n7 v7 Y* ?& d$ u
76. 
    " q5 ?0 {# X, i+ F. |
77.                    //接收数据
    
78. 
    
79.                    char recvBuf[100];
    
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    4 h" Q; G0 D- G, _% g
82. 
    6 i% s  n# J) g0 c* I
83.                    printf("%s\n", recvBuf);
    ) G9 e9 J) ]/ i% p
84.                    closesocket(sockConn);
    / B7 @; n2 W' i. {
85. 
    0 l" }5 J0 K% h5 y
86.          }
    
87. }
    
88. 
    + n7 O3 v9 ?5 r
89. 
    
90. Client：
    
91. 
    
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    4 ^1 u5 H, @1 p
94. #include <stdio.h>
    , X! s' Y3 H: d- B
95. #include <string.h>
    
96. 
    
97. void main()
    
98. {   
    
99.     WORD wVersionRequested;
    7 e0 q4 v- j2 x1 l0 l- X9 @  F
100.     WSADATA wsaData;
     . K0 z$ J6 ~3 a" K; F6 Y4 b
101.     int err;
     # s9 J' [4 {. V& j; f, T! j
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     ) W6 j/ i/ O0 X4 m
105.     err = WSAStartup( wVersionRequested, &wsaData );
     3 ]: p7 J3 }  B, m+ J1 K9 z4 C
106.     if ( err != 0 ) {
     3 k5 n* O+ Z2 r4 `; U
107.          
     ( f5 r' q$ R$ d' }+ o  g" ~; ?
108.         return;
     
109.     }
     
110.      
     
111.      
     * d9 w, m  r2 `% }' B# r
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     
115.          
     
116.         WSACleanup( );
     & P- b1 A/ a7 v: Y: i: {0 y
117.         return;
     ; \  x5 P. V: H$ d; H
118.     }
     9 A  r7 R3 k! d! E0 T
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     7 b9 U/ k3 \" X
120.     SOCKADDR_IN addrSrv;
     ' r, q+ h4 O* j# V+ l8 P
121.     addrSrv.sin_family = AF_INET;
     
122.     addrSrv.sin_port = htons(6000);
     2 ?4 w( X& _& Z0 `8 B
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     1 C! _0 ^) b! \  X# y
124.      
     / m* ~; K) ~) M: h! F; [8 e
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     9 L8 m4 q7 B& ?- o; ?* m# [
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     $ Y$ J4 r7 P( f
131.     closesocket(socketClient);
     , [+ K2 ^- G, J# X* w
132.     WSACleanup();
     
133.      
     0 \0 O$ W' c; I1 W7 p0 ^, }7 `5 x2 i
134. }

复制代码

8 l9 |8 t, E4 R+ ]