cncml手绘网

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

---

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

1. #include <winsock2.h>
   
2. #include <stdio.h>
   9 s  \+ l( a8 c8 b: [9 @
3. #include <stdlib.h>
   
4. 
   ( Q  r8 |' ?; h1 q, t: y
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   ! a$ l9 L9 t9 s/ m6 J
7. 
   
8. char  szServer[128],
   
9.      szMessage[1024];
   0 g; N- R3 U( L% H5 Z# t* Z
10. int  iPort    = DEFAULT_PORT;
    # R* f( Z. @$ H1 M
11. 
    ' _: A" L) t* R. y5 a
12. int main()
    : \8 j6 l0 I% j7 ~1 y% D6 i9 @
13. {
    $ d  H. D' V1 w, y
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    % v& n8 v4 }$ p; c
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    6 v% g& ^7 L# C! `% ~" c6 L
18.     struct sockaddr_in server;
    & H: ^0 z$ x6 I3 Y/ U
19.     struct hostent    *host = NULL;
    , J" m( T' @) r/ F" ?) m
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    1 b+ }  k* Z3 {1 {& ~# W- j
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
    # E4 G; y3 n( I: J
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    & m. I, ~# m  E
29.     if (sClient == INVALID_SOCKET)
    
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    
33.     }
      ^9 A& A1 U9 o5 p* a% O
34.    server.sin_family = AF_INET;
    . Y) v) k4 S( X
35.    server.sin_port = htons(iPort);
    ; S8 h) N1 p* g* g5 t+ h
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    & r  Y0 r5 k1 S$ Y# C9 }, H# m, X
37. 
    1 G  k* a8 K( n+ j) ^' Q) ]
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    : q/ V; }/ i, N4 q; J: S0 L/ C2 ?3 R
40.     {
    5 M9 m; R) d3 P: ]: n7 J0 B
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    
43.     }
    
44.     // Send and receive data
    ' B0 q' V/ h% Z( K* M
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    : I! y6 O4 O4 v  l; L! v
46.     if (ret == SOCKET_ERROR)
    % \7 c( h1 n5 L" N4 X
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    ' F; h/ C; X+ q: B2 x' h
50.     else{
    
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());
    : w7 @- D( f6 }0 K1 o6 B7 e( O
55.        }
      `& j% p; _; X/ v2 N" j7 [$ d/ F
56.        else{
    / Q5 u" i$ S. r* R# g9 J
57.          szBuffer[ret] = '\0';
    3 w2 R; j1 Z+ m9 }' |2 v9 h
58.          printf("RECV: '%s'\n",szBuffer);
    4 s& ~; Y9 U' I$ d1 Z& ^
59.        }
    
60.     }
    
61.    closesocket(sClient);
    " t& g0 Z% D& Q3 i% M; F
62. 
    
63.    WSACleanup();
    # j" n; V# ~2 C! r$ S& M4 F: U
64.     return 0;
    8 R: @  S7 c, t. T6 V2 c: u" T
65. }

复制代码

服务器程序:server.cpp
% g7 S8 }9 j) y

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   5 h( I) C1 f/ B5 O
5. #define DEFAULT_PORT       5150
   3 o0 W# ^$ y6 \7 H6 T$ A% q# t; F) Z
6. #define DEFAULT_BUFFER     4096
   3 O8 O$ v. M5 U& {: Q8 g8 O
7. 
   
8. int   iPort     = DEFAULT_PORT;
   , E4 [/ Q9 t( C5 ^  h! V. ]
9. char   szAddress[128];
   3 S, P) D, X' Y
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    / q+ O7 L) B2 W4 V( `7 e1 W
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    ' Z) {' U$ x- ]8 g" a7 |7 ?3 H& Q
15.    int          ret;
    ) p( ~4 ]. ~0 Q' S. C
16. 
    
17.    while(1)
    
18.     {
    
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    3 A+ U( h, C8 V4 N
20.        if (ret == 0)
    ( S/ C: h! K7 y# a$ G% S
21.            break;
    8 n0 }2 w* v& `$ P+ t
22.        else if (ret == SOCKET_ERROR)
    2 P, i$ q, j2 f' I* G
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    8 O5 z- I$ `( }$ l5 p1 Y
25.            break;
    
26.        }
    
27.        szBuff[ret] = '\0';
    % M% R" [; m, ?# _
28.        printf("RECV: '%s'\n", szBuff);
    3 x1 [4 X( g9 D4 B: H. K
29.       if(strcmp(szBuff,"abc")==0){
    ! v8 O$ I( h" Q; D& f7 P
30.          memcpy(szBuff,"Send the correct string!",25);
      f+ @3 U7 g/ V" T3 i
31.        }
    $ d7 G1 m- G7 ~& A4 v8 V7 v' b  ?) m
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    ) R; P& x  v4 w
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    , U: U( Z# f+ Q5 @0 f
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    6 i4 M* X" R1 l% Y0 M4 X( S
39.     }
    
40.     return 0;
    
41. }
    ' |/ j9 G6 l; {2 q$ a' G
42. 
    . b& w, P+ j6 _$ [# @
43. int main()
    4 R9 b# {7 O7 o* M8 l$ p/ M
44. {
    + m! d1 e9 K0 Q3 A* X/ M  N. c0 h
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    2 a6 w1 s9 n7 f# }" w7 \, L
47.                  sClient;
    % H- n# c) L% q) {! {5 j% H, f
48.    int          iAddrSize;
    6 I# \6 h# \- n( ^. c; s* K% o
49.    HANDLE       hThread;
    5 U  L, n8 o, z; ^% x, O( y
50.    DWORD        dwThreadId;
    9 [" B9 r9 Y9 {6 }$ x
51.     struct sockaddr_in local,
    
52.                       client;
    0 \; g1 r& _: i1 q# P  b5 z
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    
58.     }
    ; ]/ N5 ?7 r6 X
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    $ r. r2 }. V* H' l1 Q. t5 O
61.     if (sListen == SOCKET_ERROR)
    6 J* H& }2 C( z8 m* y# ^5 Q
62.     {
    2 ~5 \: W5 Y7 b' w
63.        printf("socket() failed: %d\n", WSAGetLastError());
    # j  J# z, p# o
64.        return 1;
    
65.     }
    ( f4 F1 t- O% Y  I
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    ' k0 s: `3 l4 ^! a9 ?
69. 
    3 b9 U, e# x8 \: t( V& X! U
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    ) j# O) v# ~  U" q
72.     {
    ) @/ i3 m8 [+ }+ v0 k4 i& r
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    
75.     }
      `# n$ [+ H) u' \: Z0 y" M
76.    listen(sListen, 8);
    . [/ o! M7 }/ d3 X
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)
    2 s% j' L$ P3 L3 d; a) D9 W
80.     {
    
81.        iAddrSize = sizeof(client);
    2 E5 n, u: t+ m) S! z- e
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    , X# u# P. \; i$ q
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    9 E& v8 I$ `+ Z$ T
87.            break;
    ; H! E0 V3 t% C7 V4 p7 E7 f' V1 j, L
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    2 `; H; o* Z3 [* n' S; Y+ g& k
91. 
    % e* F! S4 J+ t3 o' Q' q+ p
92.        hThread = CreateThread(NULL, 0, ClientThread,
    & J2 k& O3 _9 ^0 G+ r7 V; W
93.                    (LPVOID)sClient, 0, &dwThreadId);
    + w0 o' [+ l+ Z( z, _& O# W
94.        if (hThread == NULL)
    ) F& M7 l( _5 I% ?! X1 y! |- W- s$ d
95.        {
    5 \" ]7 ~" }5 [0 e! Q7 n& }
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    ; X4 e2 R( [1 ^9 p/ [$ a6 @
98.        }
    
99.        CloseHandle(hThread);
    
100.     }
     1 {7 f1 Z4 ]5 s+ A0 R3 ]$ a0 F
101.    closesocket(sListen);
     $ I0 R$ {8 v. L( }7 R/ c) L
102.    
     
103.    WSACleanup();
       b: R  ~8 ~+ m
104.     return 0;
     ( Q! }" h4 G1 {1 M+ l4 t( _
105. }

复制代码

9 J) k; |7 O0 p1 _
  h% a! {9 T& |5 O; E

---

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

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
     n" F! ?1 s8 L1 ?* @0 V3 W- b2 f
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   9 M3 Y1 `; Y2 ~" _- a2 [! c
6. Server：
   
7. #include <winsock2.h>
   ! \+ @( T* I* r
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   
10. #include <stdio.h>
    % r0 w% }" d' @  h
11. void main()
    
12. {
    9 h/ T  m1 s8 U: ^, o9 e6 }
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    * I) v; |) M; u5 {0 r
15.     int err;
    7 ^5 g  H. s4 i' n; z* y5 F' \) [
16. 
    ( d  _0 P3 [2 x5 ]: C8 ?  t- S
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    * Y3 q- j5 n) k
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    4 l1 _4 y, U' G. H9 z, ~) ^
20.     if (err != 0)
    3 G* q% T/ x  k8 X" Q; `7 Z
21.     {
    ) g1 P' }5 `5 y
22.         return;
    * x8 H1 U# N( s1 h5 n3 C( _7 n, W, v7 z
23.     }
    ( U3 Z( O. Y+ V8 J
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    ( P0 n% N/ e. I3 `9 G2 O% V/ R* b
27.          
    : A( [: Q+ m1 F7 q
28.         HIBYTE(wsaData.wVersion) != 2)
    0 X# E6 u) b" o' w& g0 m
29.          
    0 N% J  j- E) l" m/ A" O) N
30.     {
    
31.         return;
    / m0 q; x5 V6 w- d
32.     }
    
33.      
    / d- f: P+ J7 Q8 @2 p4 |, o0 F' s
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    ) N5 U3 X9 ~! v( s+ p, q
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    4 V6 ~  p5 z$ F, f! x9 I3 \
37. 
    
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    * r8 T  w. X6 w# H
41. 
    8 j# s% [* x4 p6 z# w' g% J$ ]
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    
44.          addrSrv.sin_port = htons(6000);
    - Q8 \  C$ _2 r( A
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    3 u, q+ d. M0 R3 u- ~8 R. B
47.          //将套接字绑定到一个端口号和本地地址上
    ) M3 `6 ^" U( _% `% A- T! {
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    6 I8 h- f: i+ d( H" s$ U2 Q2 a  ^0 N
50.          listen(socSrv, 5);
      b! J1 m4 l; t6 i; @( y
51.          
    * Q" b. E% i1 c' F7 M; D
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    6 J! ?* Y8 q0 @7 g% T4 J% s
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    / |2 y  T9 x5 W
55. 
    
56.          //循环等待接受客户端发送请求
    
57. 
    
58.          while (1)
    : B  K" [# J% p! ~* U3 {
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    ) s" F3 Y8 U: L  G
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    . x  R5 r8 U* M' C: p
63.                    //此时程序在此发生阻塞
    / q8 T( k& X' b. v/ W
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
      @) N4 F3 M+ K. H9 w
67.                    char sendBuf[100];
    
68. 
    + l" F) \5 B( u5 z' G
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    ! c' ?) k0 f% V' y& {2 p
70. 
    + X: c7 |4 x- A! S
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    
73.                    //用返回的套接字和客户端进行通信
    $ R! {4 {% ?  S4 m: X6 ]
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    # H' |* ^. e! _
77.                    //接收数据
    
78. 
    # h/ V' Y; E/ i' c' S2 Y1 |7 P
79.                    char recvBuf[100];
    
80. 
    8 h0 w( @6 z1 H# [
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    2 B/ \' T1 Y" ~% o
83.                    printf("%s\n", recvBuf);
    / j8 \8 Q% m- A0 l3 _( h7 s  w
84.                    closesocket(sockConn);
    3 L9 y" ?" o  h$ q$ z* f
85. 
    
86.          }
    9 c& \1 r+ S, H8 A
87. }
    
88. 
    
89. 
    3 B. h) C& Y- H) V. m& Q
90. Client：
    % A  o5 l  P; @* o
91. 
    
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    ) Y3 s+ R. y- n: L7 j
94. #include <stdio.h>
    
95. #include <string.h>
    
96. 
    . u8 q% j0 ^& k# a6 H8 {* A
97. void main()
    , D; ~3 m1 x3 E+ m- W, U6 w0 U3 p
98. {   
    
99.     WORD wVersionRequested;
    0 g& }& H/ {7 L' i/ I) H
100.     WSADATA wsaData;
     
101.     int err;
     , W; h7 n. Q  {2 n# t
102.      
     ! U" C8 c" y- U, N4 l9 J# Z
103.     wVersionRequested = MAKEWORD( 2, 2 );
     7 Z- G  g7 V5 d% ]
104.      
     5 L! {: Z3 l8 a2 P
105.     err = WSAStartup( wVersionRequested, &wsaData );
     ; O' h5 j6 E7 W/ f, W5 w
106.     if ( err != 0 ) {
     - J! j; ]% \0 [/ {* _
107.          
     
108.         return;
     - O0 E& u0 A' U7 K( t
109.     }
     : Y* I) O8 s( ~- I. R7 g& k
110.      
     3 v% C* z( F8 \" H& d
111.      
       J0 I, K! \# w& F! C( v5 @
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     " |' ]# e0 i6 K8 ]" |
113.         HIBYTE( wsaData.wVersion ) != 2 )
     6 K6 q( Y0 e6 [. b+ O* d# Y! u5 h( D& T
114.     {
     6 D) q7 G) p2 ?( X, M9 t
115.          
     
116.         WSACleanup( );
       y* c  G( n3 d* z5 D) n9 t" r( o( u
117.         return;
     9 n& W: l. q0 l0 U- |, m6 g1 V. m2 G5 ?
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     " D7 g# p) j: M  r
122.     addrSrv.sin_port = htons(6000);
     
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     
124.      
     1 l+ B5 t0 G+ d
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     1 l  l# p% U% F; x  Z0 J9 E& ~* }
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     4 R8 R  m3 D3 D$ x
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     
132.     WSACleanup();
     4 G) ]' A. R4 Y. O  e
133.      
     
134. }

复制代码

---

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

Powered by Discuz! X3.2