cncml手绘网

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

---

作者: admin    时间: 2020-5-9 02:14
标题: 一个简单的C语言的socket服务器和客户端程序
程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
/ n2 r0 v6 y. D+ R客户端程序：client.cpp
7 v. b) Z3 j. ^7 r# r0 M; J

1. #include <winsock2.h>
   
2. #include <stdio.h>
   " n. e! A, I+ r) J  p
3. #include <stdlib.h>
   
4. 
   / T9 \3 u% m9 N! z
5. #define DEFAULT_PORT       5150
   ; z( `- K- R3 q1 o7 }" V
6. #define DEFAULT_BUFFER     2048
   
7. 
   
8. char  szServer[128],
   
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    
11. 
    
12. int main()
    ( C( C5 D2 n0 Y3 G. G
13. {
    ) w1 f( X% Y. i' J! }! s
14.    WSADATA      wsd;
    & x" ]8 C% W  J9 }8 y! s) {
15.    SOCKET       sClient;
    , `; {0 |; k. h5 Q) d! |" T
16.    char         szBuffer[DEFAULT_BUFFER];
    0 ~# h# u6 O2 T6 D! _
17.    int          ret;
    
18.     struct sockaddr_in server;
    + G; ^/ Y! j! _; b: D
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    + U+ i% H* a0 c4 A
21.     {
    6 t5 h  _2 e/ [
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    
24.     }
    
25.    printf("Enter a string to send to server:\n");
    
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)
    4 [) `. c$ Y% a  H& }
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    0 `5 [- X7 ]9 e5 h
33.     }
    ) G$ a/ L4 H+ ?9 i* i: }0 T
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    & i3 p! h7 U+ S# ^6 I* V
37. 
    3 L/ ^! e! B0 O
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    ) N9 o/ P* R' h% z$ t
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    ! O5 v1 z  ?. R- s) O1 E
43.     }
    * {; H# c$ V' |' S- _
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    1 V/ k7 a; W9 _  _/ {; a. m
46.     if (ret == SOCKET_ERROR)
    , E* S2 M( ~2 \. r
47.     {
    4 n7 W7 F& S3 w: k% L0 I; _
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    
50.     else{
    0 ?9 ]2 `1 Z9 T  a! A
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    ( e3 Z7 J+ P7 V4 G8 _( N5 ~2 Y; i
56.        else{
    
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    9 R0 c, |  Y! n, F8 w
59.        }
    
60.     }
    
61.    closesocket(sClient);
    7 B6 v8 ~) Z* F) P* J
62. 
    9 K( t( d% z+ U9 i1 M
63.    WSACleanup();
    0 }1 k+ O* O- p5 m1 J
64.     return 0;
    
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     4096
   $ O/ F. _$ w% J6 |
7. 
   5 A3 |/ E) v, D
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   " ?9 i. u* n  }# r. r6 R! t& h
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    ! G0 {  s) U" G, g1 ~$ c: l
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    8 k  n) {" Y; a% w! Q  {3 T$ w2 x
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    & T: ], I  f' O
16. 
    
17.    while(1)
    
18.     {
    ! ~/ n  H9 s1 K5 L) r# @6 x
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    ) E! V+ ]' o; O
20.        if (ret == 0)
    
21.            break;
    " l6 W# Z1 K" o) S
22.        else if (ret == SOCKET_ERROR)
    $ }4 l! ?: L0 [, i; ]) N( U& L: ?
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    
26.        }
    
27.        szBuff[ret] = '\0';
    5 S: N3 j4 S4 p6 ~/ \* L
28.        printf("RECV: '%s'\n", szBuff);
    : m( ^$ g$ {$ E  d0 l/ G
29.       if(strcmp(szBuff,"abc")==0){
    
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    6 T) c$ }* B7 h6 v0 o- G. d
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    ' Y2 j& ]* A% j& B* H$ W' d5 `
37.          printf("send() failed: %d\n", WSAGetLastError());
    ! w- P2 u" ^+ e, D, C4 p, D0 G$ P
38.        }
    
39.     }
    
40.     return 0;
    
41. }
    6 k9 i- a# Z2 j8 D* K7 [7 Y
42. 
    
43. int main()
    
44. {
    
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    5 k+ O4 t( n/ o' S# ~
47.                  sClient;
    1 a2 o- B2 E) j, l+ v
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    / r/ J4 x# Q* d
50.    DWORD        dwThreadId;
    " _* j( ^6 l/ N; l  B0 ^
51.     struct sockaddr_in local,
      V7 F4 L/ \8 ~( K% k+ ?4 `
52.                       client;
    * d3 \: `$ Y6 S3 d' J
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    + a4 n! Z5 v$ l% V3 y
55.     {
    
56.        printf("Failed to load Winsock!\n");
      p% d1 i# s) t' Z
57.        return 1;
    : f5 r8 |; C+ ?
58.     }
    - \; [1 F- f* }% [  q
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    0 T! T7 `% O' Q3 E. `' X
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    . P0 o5 X% X; o) ^7 K, _( A. l3 ~
63.        printf("socket() failed: %d\n", WSAGetLastError());
    6 T0 ]# c$ d2 u( W
64.        return 1;
    
65.     }
    0 a1 }1 L6 ?* A3 u1 Q
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    : `8 U2 f/ a9 k  `; ~1 |0 ]; |
71.            sizeof(local)) == SOCKET_ERROR)
    9 H. r7 M' L! o: J! U( b
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    7 n$ j/ @1 m/ @6 ^2 w8 {' l8 h
74.        return 1;
    
75.     }
    
76.    listen(sListen, 8);
    4 e3 U, H( r3 K! i+ p
77.     // In a continous loop, wait for incoming clients. Once one
    ' ^4 I" w$ L' n: b: v) M8 g
78.     // is detected, create a thread and pass the handle off to it.
    
79.     while (1)
    7 q% W. h/ V3 E: D: ?7 V9 g
80.     {
    
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    + ?9 D. ]  I* r4 k; F! G
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    " o; i! m; H& F: B7 k7 g7 D2 b
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    % _( m2 p3 o& z
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    & }" N" E$ J$ p5 x& Y
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    ( W! X: m6 k5 y: {" \% _
97.            break;
    
98.        }
      k3 X( C$ W2 l; M, b* L
99.        CloseHandle(hThread);
    
100.     }
     
101.    closesocket(sListen);
     
102.    
     3 y: H3 L3 b, ~4 z: E4 A3 ?
103.    WSACleanup();
     - p# `  q7 |& m( ]2 y. ]
104.     return 0;
     ! j6 u. a: r  T% C
105. }

复制代码

9 I) O; o, t/ g: J9 ^0 [, D+ {

---

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

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   3 H. ~$ W% A8 _  ?+ D$ p
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   + t  g) c% J! ^( H" ~) W1 ^7 j
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   & B9 A* `4 L# a) D- m$ l, N
5. 
   
6. Server：
   " \) v! [% s! `, \+ s
7. #include <winsock2.h>
   3 i2 n0 n* L8 ?# R9 w* a" S
8. #pragma comment(lib, "WS2_32.lib")
   , e4 j& P, U" O; x
9. 
   
10. #include <stdio.h>
    " z3 \2 S" z3 p! }0 @
11. void main()
    
12. {
    # D* B7 v( y6 ]3 ~
13.     WORD wVersionRequested;//版本号
    & R! f/ C1 u# m
14.     WSADATA wsaData;
    
15.     int err;
    0 n$ r' i3 H0 H  |  s" Y/ U0 ?# s
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    2 q" u2 H' n# J2 z! N# B
18.     //加载套接字库,如果失败返回
    & [$ d1 ^: m/ y9 D. s
19.     err = WSAStartup(wVersionRequested, &wsaData);
    ; v" a+ ?7 I" z8 F0 B
20.     if (err != 0)
    
21.     {
    ' Z! i9 R( u% @
22.         return;
    
23.     }
    + o2 i) I' f! i' O
24. 
    : Q8 t1 F$ C* K/ v- z/ v
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    9 d5 w& q1 h0 [6 y/ ]) J( U2 Y) c
28.         HIBYTE(wsaData.wVersion) != 2)
    . Y! J5 @; W" H* [
29.          
    
30.     {
    
31.         return;
    
32.     }
    
33.      
    0 D, H4 ~" l# C
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    8 w6 H! D  s8 [# r1 o& r
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    - Z" \- v: ]* _* z( F
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    2 J' C0 J8 [1 E! O9 o. }6 @
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    / W7 N$ N: D2 X. ~6 [
46. 
    3 L( m8 v4 p4 Z# ]6 `
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    
50.          listen(socSrv, 5);
    
51.          
    " v/ q" z, `% E, E
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    ) ^0 a' x2 {/ c9 Z; x4 y$ E
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    4 a8 _8 R% `; r7 z+ u( o
55. 
    
56.          //循环等待接受客户端发送请求
    - p. `% T4 ~" R: w. E8 i' P
57. 
    
58.          while (1)
    , I$ ?* x2 @5 N
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    8 r" k' z* g) G' [# U! o+ I. c4 S
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    2 P6 X7 ~1 L9 p  z8 J; z
66. 
    6 m  G( ^6 J0 M5 P9 w$ Y) B
67.                    char sendBuf[100];
    
68. 
    5 M1 x: L/ H  o: k9 e" N# [* p
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    
73.                    //用返回的套接字和客户端进行通信
    
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    / A+ ~+ L- G3 {- }* h/ Q
76. 
    ) Q  m6 F  E8 m9 m9 E, v
77.                    //接收数据
    * j# C" V$ x/ _9 {( v
78. 
    
79.                    char recvBuf[100];
    ; s0 o; b& ]$ J. ?
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    " o9 C) ^; h& X* ~7 C
82. 
    
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    3 J5 Z0 [! @* X: l
85. 
    
86.          }
    
87. }
    
88. 
    
89. 
    
90. Client：
      o8 B+ h  [) [
91. 
    - V7 H! c4 K% C5 v# w
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    * ?1 W+ x/ L6 F; b
95. #include <string.h>
    
96. 
    1 i' D( m# Z8 V/ h( q, ?& W4 x9 L2 W8 N
97. void main()
    . Y6 B$ y' E, f1 N: \) [( W. O
98. {   
    
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
     1 A% ~: k- t, p2 F/ m
101.     int err;
     9 m+ E3 v9 n; B/ l4 C1 C
102.      
     3 Z) K# s! |; m6 E/ t% @
103.     wVersionRequested = MAKEWORD( 2, 2 );
     9 K' v1 t6 W4 U2 p3 X$ _
104.      
     # E. b& E- ]# \' q
105.     err = WSAStartup( wVersionRequested, &wsaData );
     - {: q2 r, T/ R$ e1 U% x
106.     if ( err != 0 ) {
     
107.          
     
108.         return;
     
109.     }
     
110.      
     0 l/ F- b1 n/ p
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     ) S0 y- W+ C  T# X( }; K  k
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     
115.          
     
116.         WSACleanup( );
     9 V3 E' K: I& E, r! [4 q6 |
117.         return;
     9 m4 S% q6 L$ B: l5 g6 h
118.     }
     / L% g3 _: R1 |9 ~
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     3 }# D, t) k- f0 o5 Z* j: S
122.     addrSrv.sin_port = htons(6000);
     5 ?: H) w0 t4 {/ a6 a3 m
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     " G# [$ s- t3 i- B3 Z# H; a9 I
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     4 B. K7 v8 Q; t8 p5 e( \0 M$ O: ]. C3 M
128.     recv(socketClient, recvBuf, 256, 0);
     , C+ a, Q0 y" |$ k- S' E! E' Y
129.     printf("%s\n", recvBuf);
     . Y6 ~8 w9 ~! d' n
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     
132.     WSACleanup();
     4 ?( K- U3 _9 |" H1 t1 u0 J
133.      
     ( C  Z, O6 s' E! d2 }
134. }

复制代码

$ B4 G( Y" {3 b6 Y' u2 u; K

---

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

Powered by Discuz! X3.2