cncml手绘网

标题: 一个简单的C语言的socket服务器和客户端程序 [打印本页]

---

作者: admin    时间: 2020-5-9 02:14
标题: 一个简单的C语言的socket服务器和客户端程序
程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
* [! t. t% l3 {7 V8 Z客户端程序：client.cpp
$ ?4 q6 {3 ]% M) M6 T. I- P

1. #include <winsock2.h>
   
2. #include <stdio.h>
   ! }8 x; }" c3 T# _$ a. [
3. #include <stdlib.h>
   
4. 
   ( _4 b. Q0 {5 P$ l3 y/ a- C. l
5. #define DEFAULT_PORT       5150
   ( _- C, g* {' P1 |$ C* d0 C3 {
6. #define DEFAULT_BUFFER     2048
   
7. 
   * Y$ p5 w- h% i) R9 v
8. char  szServer[128],
   
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    
11. 
    
12. int main()
    " t  Y  h% u% g4 c9 P3 h
13. {
    5 n( U$ a# B* T
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    # l5 c" F& C* v% z3 @. l
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    9 q2 s' R  t1 r
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    # m1 L6 S3 ~8 r4 l/ y
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    ! D* H3 O7 s8 Z0 ^) [) z/ {
23.        return 1;
    
24.     }
    
25.    printf("Enter a string to send to server:\n");
    
26.    gets(szMessage);
    - V3 ~$ l/ y) E. B# {0 j, w+ w* O
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)
    
30.     {
    * `, d  y. z& M: }* `) [* t
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    5 A" L, v( Q+ e. I( o
33.     }
    
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    ) Z( c, k$ ]8 Y2 a
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    8 Z% I4 |8 V  b0 T- L, B
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    1 g8 f5 U0 B7 w2 O. q; }, w' f
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    7 u, w* X; X4 {; F0 N6 y0 ^
42.        return 1;
    2 R" j4 Q& o8 j% e) B- C+ ~! Y. q
43.     }
    
44.     // Send and receive data
    ) H$ F7 ]$ z; Q2 r' ^5 Y% X/ y
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    . g# g, K( a. b6 x4 t6 ^3 O
46.     if (ret == SOCKET_ERROR)
    1 P' A8 x9 y4 X- D) L. ^) R2 C* Z- W
47.     {
    ! _$ U1 G. y" `4 \
48.        printf("send() failed: %d\n", WSAGetLastError());
    , g! q2 {1 x) n' `4 H. N$ H! O/ N0 p
49.     }
    $ P! H* ^. [9 t+ m3 k
50.     else{
    5 L" e/ ^* ?8 C0 }* E
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
    + \5 y) s- [- W/ \" {' ]2 p/ `
54.          printf("recv() failed: %d\n", WSAGetLastError());
    . q# @2 a" B( q: I! d) [
55.        }
    0 d  ]) ?4 z6 A. ]4 e1 b
56.        else{
    
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    . j9 r3 r7 D+ F! c) C! c! X
59.        }
    
60.     }
    
61.    closesocket(sClient);
    
62. 
    * ]  A% t" x& k4 L
63.    WSACleanup();
    * B6 a4 G8 G9 ?8 [/ y$ P$ S" W9 o
64.     return 0;
    1 D0 ?% h; e1 s: C& a1 u4 ?! [
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   3 p: R. [& @6 V, q
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   4 T0 W. }5 O( U
6. #define DEFAULT_BUFFER     4096
   " ?/ e& V3 m4 Y! l* Q
7. 
   : ~8 F$ I& n5 Y- e
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   / f6 X# J8 D' q- d
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    + Z' F) c$ R; c! N7 G7 n
12. {
    ( i. U( |$ J4 i; [8 _4 {% l
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    # [6 X) ]" [1 X9 w# A
15.    int          ret;
    
16. 
    
17.    while(1)
    4 |. e, j4 c2 _- j# T. t
18.     {
    
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    3 {; v% s) P4 ]0 F' |" Z: e  N" A
20.        if (ret == 0)
    
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    0 N+ e) P6 u5 u1 O4 i3 _
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    6 a) J; x4 l8 K. I, i
25.            break;
    
26.        }
    
27.        szBuff[ret] = '\0';
    " a: I* D& H5 }; S. v
28.        printf("RECV: '%s'\n", szBuff);
    6 S* }1 t( ]6 T# G9 U6 B
29.       if(strcmp(szBuff,"abc")==0){
    3 D8 I: l% z2 ?. r, j" |# z
30.          memcpy(szBuff,"Send the correct string!",25);
    - t; d# T' m: D' w/ O
31.        }
    
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    ! o6 U4 w% S0 [# P- j2 M/ x
34.        }
    , t( p0 t6 i* L! @& z9 m
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    
39.     }
    
40.     return 0;
    ) v8 B# j2 L+ z- T) {
41. }
    ) ~7 ?4 o' E) ?6 H! A
42. 
    + Q' O. Z8 Y0 z( r5 L. Z8 d5 e
43. int main()
    ' \* |6 g" }. R% i$ M1 P5 x
44. {
    $ z; E, R5 L9 y) V2 g0 R( U" ^
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    8 t3 a- D9 D2 c* [+ A" v
48.    int          iAddrSize;
    $ m* M6 z( G' K1 Q6 W$ f! b# C
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    9 ]8 k. Z* D+ r: Q
51.     struct sockaddr_in local,
    ' z+ e% [8 c  L& ]) ^
52.                       client;
    % N8 |1 m) a' C4 c! ]' @( U, ^, `
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    9 l2 H6 t! D; }& c
58.     }
    
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    ( k) U7 ?- c2 Y& V
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    
65.     }
    ; T) S3 X0 y0 o8 o
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    8 ^3 C5 R1 N: j; x- T
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    % v6 ~% ]" b  v2 G  _" \6 N
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    3 P7 K3 b$ }* P' W
71.            sizeof(local)) == SOCKET_ERROR)
    " q2 ~1 J- K% j
72.     {
    ; C6 @) u' I6 h* B
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    ' `& h, Q+ ^  H/ l0 z+ V
75.     }
    
76.    listen(sListen, 8);
    
77.     // In a continous loop, wait for incoming clients. Once one
    & Y, A  h. z; f% z1 f' \1 B
78.     // is detected, create a thread and pass the handle off to it.
    . {. `0 t8 H! @2 h+ {9 {( ~
79.     while (1)
    
80.     {
    
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    ' Y" D3 W( }7 T
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    / ]/ p6 E9 x$ g( R, E
87.            break;
    ; z) m/ Q- h. {. G6 |+ h7 h8 X
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
      u( F. v. G# ~2 v! R/ s% _
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    
98.        }
    7 p; @( y' P9 _6 p& p: x. J; `
99.        CloseHandle(hThread);
    0 K- }$ E: }) `5 H# `3 p1 B7 ]/ ~
100.     }
     0 Z0 T7 _3 R) m/ s" s
101.    closesocket(sListen);
     
102.    
     
103.    WSACleanup();
     0 Q3 k3 K- Y4 [" X1 ?0 \- [* A9 m
104.     return 0;
     
105. }

复制代码

0 C8 n9 U: z4 s3 {! C; a" U
# |/ F( ^3 U* m% n- J

  G$ \; c' t& G* @8 x8 B

---

作者: admin    时间: 2020-5-9 02:16

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   ! [6 v  ^7 `$ ?
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   
6. Server：
   9 G# ?+ u& b6 g3 n
7. #include <winsock2.h>
   * ?7 y3 m: y6 _! A2 E0 [" D! d
8. #pragma comment(lib, "WS2_32.lib")
   2 {4 F+ c  c' d$ X# {
9. 
   # c+ A; ^6 s: j1 V6 ]
10. #include <stdio.h>
    # L- I5 z8 J" m  \+ L. H/ M) s
11. void main()
    
12. {
    
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    
15.     int err;
    
16. 
    - _, |+ S" v( ?1 u5 Z( Q# J# I
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    7 ^' T+ f+ s6 ?% ~# b7 Q
18.     //加载套接字库,如果失败返回
    6 B0 @( O- @4 a- A& @: h
19.     err = WSAStartup(wVersionRequested, &wsaData);
    ) K( Q  P4 c6 `- x" o  e; g" ~
20.     if (err != 0)
    * Y' y' M% D* J* q. Z
21.     {
    
22.         return;
    
23.     }
    
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    / k. E* L; y) {) O! o: J4 J
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
      y! |, H9 p  e) R. C+ m5 T
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    
30.     {
    ! B6 B: E4 Y" R: Q" a
31.         return;
    
32.     }
    ! b/ K  E. `+ h3 K
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    ' p$ n3 Y) n1 o. A1 s/ c! y! O5 k
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    
38.          //Socket地址结构体的创建
    
39. 
    5 D) q: a$ b* H/ ]" ]
40.          SOCKADDR_IN addrSrv;
    / l; t  p5 h2 S, e! j
41. 
    % r. x+ |3 I! D+ d
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    / [1 h3 w/ ~1 ~# b3 I
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    2 t6 @& i' ]2 {+ h" R5 {
49. 
    
50.          listen(socSrv, 5);
      Y2 R& H5 @  {/ T7 s% ^& F8 p9 J& z
51.          
    , q5 p0 R( \/ c9 g( f. K6 Z8 S
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    / W2 e% p5 M/ ^. P* O; v5 A. k2 v
53. 
    7 K3 g' U* G5 M; |# i
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    9 |  z4 ^/ o& e0 z2 D
56.          //循环等待接受客户端发送请求
    1 f% ~! }4 e- V4 P- C& X% K# `
57. 
    $ ~( n- K* K/ u6 c. \
58.          while (1)
    
59.          {
    7 g" Q/ M; E' Q2 W7 V& ^* m
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    ' ]" c. `& u& c6 F
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    ) ?7 a( q  c# ^. T% N5 a
63.                    //此时程序在此发生阻塞
    
64. 
    : N9 y1 W9 c- }% J
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    " O6 n- N  y+ H, i5 J, ?' Z, K
66. 
    7 m9 I% w, Q$ I, z
67.                    char sendBuf[100];
    ' e' Z# Z, r2 ^: p" ?
68. 
    , i/ Z4 i, G/ d$ Y
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    - Z# I  r  ~' |- i" g8 H8 M0 `
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    ( e- d# ?6 V8 @; Z' Y9 W% K
72. 
    
73.                    //用返回的套接字和客户端进行通信
    5 T! P0 j( M( F+ j! F# F/ `
74. 
    . d# `% c6 K2 M3 y  e
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    
77.                    //接收数据
    
78. 
    
79.                    char recvBuf[100];
    7 o0 y- n, g! A; B1 e$ }
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    ' S9 ~' s/ R3 U/ {6 j
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    
85. 
    
86.          }
    8 G5 R5 h( q2 r5 h5 ~, A- E
87. }
    : U  N3 H2 c  H+ [7 V' F+ |1 T
88. 
    
89. 
    ( D  e: G: d7 T' R
90. Client：
    
91. 
    
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    ( L* o$ y4 ~/ n1 q% j" J& r3 H
95. #include <string.h>
    
96. 
    ) t0 \( z  F  R& ~5 U- T' |
97. void main()
    ! _6 D! E7 I( n7 F5 {
98. {   
    
99.     WORD wVersionRequested;
    0 O  r8 K- x# ?* A7 k! Y
100.     WSADATA wsaData;
     ; L! w, d. _2 X: D2 m* A! P5 v2 F7 _
101.     int err;
     , x2 \" h$ d; t7 O0 W! a
102.      
     / g% z* O! s; Z! ?9 q& Q# A3 b) N3 ]
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     ; k: R" |3 I6 T+ G) m' n0 N
106.     if ( err != 0 ) {
     " v0 P$ f% Z( F1 ]1 }! z
107.          
     ) K' v# U" M. d) G9 W  B* l, j
108.         return;
     
109.     }
     ) s) j, c; s( R% Z+ N3 R
110.      
     
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     " r- }& E6 p( D' o# B3 S  [
115.          
     . f& s* |* a7 z7 p! K. R* ^2 X( V* [
116.         WSACleanup( );
     
117.         return;
     
118.     }
     - F5 }: a6 D+ b. p' J
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     % s$ F; d, \9 k0 R5 y
121.     addrSrv.sin_family = AF_INET;
     1 V( w; e) u5 ^" c. x  g# }
122.     addrSrv.sin_port = htons(6000);
     
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     4 e" V1 }( B  e2 ?# v& ]3 y( H
124.      
     ( Y2 w1 T' q! j/ k  G
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     / c+ w# A1 L2 n1 E5 S
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     # r3 e: Z) }( n. d; _- B& `
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     ! A# L" G4 o: k1 a9 c3 U+ g
132.     WSACleanup();
     2 x  `) m! M5 ^) g/ {9 l6 e
133.      
     & S4 v* S* ~/ ^4 X$ \5 x
134. }

复制代码

9 Y; }( ?$ C& \, u9 ~, {$ ~
$ a) y7 K1 P& Z$ ]# f5 f) Y2 W

---

欢迎光临 cncml手绘网 (http://bbs.cncml.com/)

Powered by Discuz! X3.2