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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
% a. \% ^6 P" l( V1 w) m客户端程序：client.cpp
6 r  j( U8 G) g: @& R6 l+ _

1. #include <winsock2.h>
   
2. #include <stdio.h>
   3 g# q& Z& I- e& l1 g
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   : D) b2 d& h* B! `2 f- y8 Q5 W
7. 
   ) q$ Z: A# V4 s- n& R7 G' t* G
8. char  szServer[128],
   
9.      szMessage[1024];
   # o- d) k; M! c9 Q& Y
10. int  iPort    = DEFAULT_PORT;
    
11. 
    
12. int main()
    . m2 F0 [7 O6 [9 {* H
13. {
    
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    $ H! i' c. p# N( z2 M
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    1 w) e7 y+ i9 ~& Q- t) q" w$ |. n) w
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    / u$ ^: }: ^" X" u0 d5 G% v- v: I  ?
23.        return 1;
      |& m' a8 m& G& R+ Q: d
24.     }
    % {! w& R. F8 \9 x' j. L+ `
25.    printf("Enter a string to send to server:\n");
    
26.    gets(szMessage);
    % |* H5 q3 y) X9 k
27.     // Create the socket, and attempt to connect to the server
    - B  a% v: ?' H5 z
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
29.     if (sClient == INVALID_SOCKET)
    0 @; ]+ ^3 M- |0 |/ O
30.     {
    * A; r5 x3 P, v, ^: g, j- C/ r7 l
31.        printf("socket() failed: %d\n", WSAGetLastError());
    % c& z$ b/ F( S5 h9 J) z
32.        return 1;
    
33.     }
    
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    7 U: w+ j9 L# Z' ^6 i# f
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    7 a. R, A) o7 z* u3 U8 n5 v4 J5 a
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    ! H- u1 v) g: M  B; c% `* B  ~
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    
43.     }
    
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    2 D/ U) J0 _6 M1 X$ A, h4 r
46.     if (ret == SOCKET_ERROR)
    
47.     {
    3 V) z3 r  c, e( c' i; R' ^/ q
48.        printf("send() failed: %d\n", WSAGetLastError());
    & N  x) c: e5 [* E
49.     }
    : Q9 Y8 ]' v% \- ?0 y
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    2 c9 O8 O4 ^/ N+ Z. k; c  A: B6 ]
53.        if (ret == SOCKET_ERROR){
    8 V& r3 [( G* H$ {# w( p
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    
56.        else{
    % }) D; P. K4 q& m! v
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    
60.     }
    ; x7 }/ [2 T0 Z* W) [
61.    closesocket(sClient);
    6 A# R9 `& u3 d; F9 w1 \' v
62. 
    
63.    WSACleanup();
    - K$ L4 X$ k7 u* y; w
64.     return 0;
    
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   + b0 F( v8 @" i0 g9 F' r
2. #include <stdio.h>
   
3. #include <stdlib.h>
   ) L4 u9 m% Q2 X# K. D- B) b' u
4. 
   / t# C  D7 Q! r1 L9 }) R$ J
5. #define DEFAULT_PORT       5150
     p* f5 j/ a/ T+ V. A% y2 e
6. #define DEFAULT_BUFFER     4096
   
7. 
   # _* `# ?7 m' n7 X( m
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   2 L, t3 z) s# a& t
10. 
    6 v( E2 m; z6 G( g# `# r5 g' c! d
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    7 c# w# k. b4 |9 Q! M$ @
12. {
    8 Y  a2 w9 K) P
13.    SOCKET       sock=(SOCKET)lpParam;
    7 U' s9 b& f/ [' ^0 _# L* y( k
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    ( R2 v/ I! K; b1 Y
16. 
    
17.    while(1)
    
18.     {
      }! ^% x+ r3 Z3 ~
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    6 e" t) ^, B0 O9 ~7 g  l; y
20.        if (ret == 0)
    
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    
23.        {
    4 r7 v3 Y; N8 ~& U8 b9 K
24.            printf("recv() failed: %d\n", WSAGetLastError());
    0 `& T) V6 g5 D( z7 c& h
25.            break;
    ) q6 h) u' f, \1 V
26.        }
    
27.        szBuff[ret] = '\0';
    + F: L5 y  }0 z$ W. K8 F
28.        printf("RECV: '%s'\n", szBuff);
    ! k( e" @/ E" d. L+ d* D
29.       if(strcmp(szBuff,"abc")==0){
    9 I4 J3 P) g. O
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    ' H" D: A) O$ M6 U* H, R$ y
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    9 G7 F0 K, F; H; A9 m
34.        }
    2 ?% a. e$ e( l
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    2 v8 s) W  U4 u( c2 x
38.        }
    
39.     }
    
40.     return 0;
    
41. }
    
42. 
    
43. int main()
    
44. {
    . V! A4 }7 _4 _3 {% P* ?# F
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    
48.    int          iAddrSize;
    / c4 s' N9 ^7 J
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
      K8 z) w5 }5 r
51.     struct sockaddr_in local,
    + U5 I; a6 R6 n2 p% H
52.                       client;
    ) u% V- K6 P6 D2 u
53. 
    9 N% y  J% ~* j
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    - D2 R+ y: p& g/ q% W6 v3 L4 {5 r
55.     {
    4 W! y$ F8 n& U, O3 {/ z% E
56.        printf("Failed to load Winsock!\n");
    5 n2 K; z: C+ e- \$ x+ t
57.        return 1;
    
58.     }
    # W4 M% g5 u4 ~  C
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    * A- D- @0 O* I- s3 d8 R! Y0 P0 g
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    / f3 i" ^" x5 \' k
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    ! ~' D6 ]) i) N, e4 D
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    . t! p9 b; n9 E5 v
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    * }0 X; y( R' u& A
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    : B2 d6 ?; K$ W- y+ ]4 D
74.        return 1;
    
75.     }
    
76.    listen(sListen, 8);
    " u7 j1 y6 K3 P: p7 k, y
77.     // In a continous loop, wait for incoming clients. Once one
    ' h" _; P6 @* |2 ?
78.     // is detected, create a thread and pass the handle off to it.
    
79.     while (1)
    3 Q+ J7 [7 Q! X: J7 ~: U) ^5 Q
80.     {
    
81.        iAddrSize = sizeof(client);
    3 c( D" y; H. Y0 n5 X2 T
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    7 E5 Z  U3 u) S" G) X- M, x1 s
84.        if (sClient == INVALID_SOCKET)
    % V. {/ x4 g  j2 e7 X
85.        {      
    1 x+ q! y) M- |1 H" z) H
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    2 r) _' p, j, k4 N
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    ! B5 Y1 Y2 P1 y
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    6 w1 t3 s3 g' X/ d! ^2 }
91. 
    % B4 c* k6 O' y
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    1 L! Z' {. J5 M3 C  G, N1 \$ ]/ s: F
95.        {
    ) q+ X' V7 U' k8 `, @. e
96.            printf("CreateThread() failed: %d\n", GetLastError());
    ( l) \  ~: S( t$ Z% X" e3 t7 e
97.            break;
    + J. [' F" s/ w
98.        }
    
99.        CloseHandle(hThread);
    
100.     }
     
101.    closesocket(sListen);
     ! F3 v- p, `! Q. `/ p+ j5 T
102.    
     ! r, x6 p  m4 u: l7 e) h# H
103.    WSACleanup();
     8 n0 O9 T0 ^! {
104.     return 0;
     
105. }

复制代码

& U* Y* n6 @# k; p
* o; o5 m" E; ~# r9 v
+ O8 p0 q3 n( ^8 v/ K* b/ [' ~8 Q7 ~
  @5 }2 f* A( c! N& I/ x
; v7 ^6 U6 A' r7 b$ A

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
     I1 i/ Y( ?& _3 i1 p
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   # p! c: k2 v/ h# ~% }
5. 
   $ z6 x1 Y1 a4 k2 B9 P
6. Server：
   
7. #include <winsock2.h>
   ; f- H; q% n3 R0 @
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   
10. #include <stdio.h>
    * y0 H0 k; t' k' S( V$ G
11. void main()
    
12. {
    
13.     WORD wVersionRequested;//版本号
    ' n+ A  G2 @$ F+ f
14.     WSADATA wsaData;
    , a: ?% [# o- e6 x. }. F; Z
15.     int err;
    
16. 
    " i& C7 n; `6 b- p; _9 q7 f. o
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
      j1 @' `9 X4 ^' M4 X0 V
21.     {
      @& K9 A8 X9 N' p
22.         return;
    
23.     }
    
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    7 M7 m  H1 J) r) b0 S
29.          
    
30.     {
    6 `0 s9 t6 d' Y: ?# y, i/ D* B
31.         return;
    
32.     }
    
33.      
    % o0 R/ [* A& y, q- h
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    ) h: S) T: \+ k6 k' b* P  E
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    $ T( V- Y0 J  j' x
37. 
    
38.          //Socket地址结构体的创建
    & N/ }' ~# ]. K
39. 
    , ^4 ]3 N4 d2 N3 F% m
40.          SOCKADDR_IN addrSrv;
    
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    / x0 O% @6 K0 h. u& ?* D* N
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    1 k" y: l  ?: m3 [' m9 N5 |
44.          addrSrv.sin_port = htons(6000);
    % ]6 ^+ z: [3 p
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    ; f& ~' D* |" ^' y2 W6 o
46. 
    ) u, `9 {$ V. p/ Z  T: J5 v* ^
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    # u: u3 A' Q) I7 Q7 M
49. 
    7 c4 u1 u1 ?2 q& A6 V3 w; F* v" R
50.          listen(socSrv, 5);
    - i: `& O+ R7 R' f
51.          
    ) N6 B) a, s. O
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    " r/ s+ a  D0 @% F1 ?) t% v! w
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    " }/ S  L. |& \! P( n; a
56.          //循环等待接受客户端发送请求
    
57. 
    : O( d$ ~! Y1 C" I# F3 t
58.          while (1)
    
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    $ x2 F! t% {3 X+ Z5 F
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    + E' z5 d; k( I' x+ i: I2 O/ m
63.                    //此时程序在此发生阻塞
    
64. 
    7 T' }2 i4 V) K5 y9 m
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    
67.                    char sendBuf[100];
    + f+ O, i) h1 S- [0 z
68. 
    3 x4 S. S7 m% X% c& w) H+ N
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    $ g, \2 Q4 s0 n9 u8 o
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    ; Q( ]+ R5 l, F; o. [) T
72. 
    6 w# L8 R6 W3 i0 U2 E  G6 U
73.                    //用返回的套接字和客户端进行通信
    * j5 ]/ ^% ~% K# k" z1 G
74. 
    0 ?8 t! ]% A$ Q+ c* A3 D
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    " V3 @8 i# [) j# p7 s4 O6 A
77.                    //接收数据
    
78. 
    # W+ V" n" T: b2 c
79.                    char recvBuf[100];
    
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    ) Y0 }+ S: O, _' J* @
82. 
    
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    9 R4 X% y) _2 J' l" |  W
85. 
    " U; D6 C+ X! `! w- S
86.          }
    # L- [$ A8 z5 W/ t" F
87. }
    " C8 o4 N: {& a; f
88. 
    + B# H5 A& ^$ Y6 f9 m" V
89. 
    
90. Client：
    + U& ]& J( Z, I! ]
91. 
    
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    # |  D8 t& R  B3 Y2 Z6 q$ l9 V
95. #include <string.h>
    + E  n% W, n. t/ O3 Y2 @7 `
96. 
    
97. void main()
    6 [: z" C- j" |1 o
98. {   
    
99.     WORD wVersionRequested;
    0 G- I: g# J# Q  a  E
100.     WSADATA wsaData;
     1 ^; Z* X6 Z9 ^
101.     int err;
     
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     3 `  @$ b2 W: z: u' c3 s
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     
107.          
     
108.         return;
     
109.     }
     
110.      
     % I4 r5 ~1 N) ?, g- ]" j" M
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     ! h# W! @3 n, n" C( w3 l/ f
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     
115.          
     
116.         WSACleanup( );
     
117.         return;
     . |" \7 m2 ~5 t3 [; u; V5 o+ d# C- q. J
118.     }
     5 `6 e+ O4 ]# f$ Y7 j# w! F
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     ) ]0 z2 s3 ?. w+ S
122.     addrSrv.sin_port = htons(6000);
     : i- [# v7 ?- }, \# ~
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     ' J1 o( O, X/ v: b( k$ Y6 ?" C
129.     printf("%s\n", recvBuf);
     7 ?3 n2 k8 [; k+ ^2 l5 u
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     3 s7 [% R5 B! a# m$ m
131.     closesocket(socketClient);
     
132.     WSACleanup();
     3 H9 K3 v5 y7 K# I4 N  C
133.      
     
134. }

复制代码

1 M. D3 H5 Y# ~& @