cncml手绘网

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

---

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

1. #include <winsock2.h>
   # x8 ^& W: m' U" d4 Y9 u6 b, i
2. #include <stdio.h>
   
3. #include <stdlib.h>
   8 H3 r* S8 e& y5 G" P7 m% A
4. 
   
5. #define DEFAULT_PORT       5150
     k8 @/ ]8 p6 d0 _) v) l3 V( u
6. #define DEFAULT_BUFFER     2048
   $ f( e: Q* @) d/ J9 Z, X$ t0 ^
7. 
   
8. char  szServer[128],
   # R! l7 I- p2 [4 ~9 s5 L
9.      szMessage[1024];
   ! V1 i# s8 p8 T* n, o7 m6 X, G2 Q- D: [$ n
10. int  iPort    = DEFAULT_PORT;
    
11. 
    1 v( c  _) H# P: p# R
12. int main()
    
13. {
    
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    & z  S8 G5 u) ~
17.    int          ret;
    
18.     struct sockaddr_in server;
    1 @, t/ T! N1 {6 }9 _1 U( C
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    + j' ?+ A! H/ ?1 J% ]
24.     }
    $ p% ~: a+ i# @  q* `
25.    printf("Enter a string to send to server:\n");
    
26.    gets(szMessage);
    
27.     // Create the socket, and attempt to connect to the server
    2 J2 I- b. t2 G7 D: b. M7 a5 |/ T. X
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
29.     if (sClient == INVALID_SOCKET)
    4 y2 w) a0 O! m
30.     {
      _4 T/ J9 x0 I! u
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    / x, x& ]5 W: K4 e& z
33.     }
    
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    * i: w8 R% z; ^% |
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    6 e: |! s* O( v' Q) U/ b, z
37. 
    9 [6 S+ ]9 I( C- p, ?+ \
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    . Z7 L7 j3 J1 c1 C1 x8 Z" [
42.        return 1;
    
43.     }
    
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    6 n" q' N2 X3 x! T2 ?
47.     {
    % Z) @7 e, @9 k  R5 J
48.        printf("send() failed: %d\n", WSAGetLastError());
    4 B- m2 x) [, W" F5 O
49.     }
    4 k7 f9 _4 U0 g, }, |
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    - Y3 W& x$ j( O  T+ N
53.        if (ret == SOCKET_ERROR){
    2 T! ?# F4 t+ V' v9 I' l! z
54.          printf("recv() failed: %d\n", WSAGetLastError());
    ) V/ B+ N" f, j9 K& f- ?3 D
55.        }
    
56.        else{
    
57.          szBuffer[ret] = '\0';
    1 F" [9 z. ~4 H/ Y$ {
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    
60.     }
    ! o5 R* T8 E0 ^( z* ~5 K
61.    closesocket(sClient);
    
62. 
    2 Q$ J) B% v( q2 ~, s
63.    WSACleanup();
    8 k7 H4 o- P# ^" u' v" w1 C$ S2 I
64.     return 0;
    5 A# i0 ^# e0 a3 N
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   
2. #include <stdio.h>
   1 v% m9 g' Q& }8 R6 k" S
3. #include <stdlib.h>
   
4. 
   % m  J1 s4 d, D! ^, l( Z$ Y1 K
5. #define DEFAULT_PORT       5150
   ' F4 s( k7 n. C$ E) p9 q+ p% H9 n
6. #define DEFAULT_BUFFER     4096
   
7. 
   
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    ' h/ O  {/ K% ?+ ~1 ]; |1 m
15.    int          ret;
    * m  L" Z) f& D+ ]3 a
16. 
    4 B+ \$ a8 o& {9 N6 `" B$ m$ ?% O1 s, a
17.    while(1)
    , S( v. e9 S; M. A; v
18.     {
    
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    / U; y) \6 K; k
21.            break;
    5 H* o2 H; x; v' G: o& [: N6 |. N$ Z
22.        else if (ret == SOCKET_ERROR)
    
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    + {" U$ ~9 M8 G# z% B* L( F" ]
25.            break;
    
26.        }
    
27.        szBuff[ret] = '\0';
    * i( I$ V, A  m! e# E& z2 x
28.        printf("RECV: '%s'\n", szBuff);
    4 R5 m( k9 a- N
29.       if(strcmp(szBuff,"abc")==0){
    7 W- c6 q! ^- a0 l) i
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    * D" o% H6 J% ]. A& y( I
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    $ }" t) P5 a, ?
34.        }
    - u3 X2 |) R  P! }$ ^
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    ' v% f2 ]" ?& x
36.        if (ret == SOCKET_ERROR){
    , K! `% W2 Z2 X
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    
39.     }
    ! d* D- c+ k/ m8 g+ z/ r
40.     return 0;
    
41. }
    
42. 
    7 |( N4 L. K* q# o% f1 {# p5 D
43. int main()
    3 _7 n, k5 d0 `& I& Z" S
44. {
    
45.    WSADATA      wsd;
    ( ]# v  m2 W0 w, M
46.    SOCKET       sListen,
    
47.                  sClient;
    . c5 E6 j) q* m- S
48.    int          iAddrSize;
    : r" y0 B* |. s+ A' K
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
      a- y# I8 y! [- e
52.                       client;
    
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    9 C! G* B& v/ V4 [4 e+ m; B
55.     {
    
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    ; z9 h/ ?8 A, i2 @* K5 X* a6 H- F
58.     }
    
59.     // Create our listening socket
    1 X% I3 f6 G2 _+ s  _% |$ `4 V1 N: S
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    ; _- Q/ z, U* U4 P8 z
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    
69. 
    & v- {( j7 g$ e, x+ _
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    ) B0 o/ m( u) K9 i& p
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    . O3 {+ l; P: `$ ^. q2 R
74.        return 1;
    - m2 w3 l1 W2 r: R+ }
75.     }
      K8 ]6 @* ]2 X; @
76.    listen(sListen, 8);
    8 }. ~# b& b: h, q- x: p
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)
    1 w" H  Q+ G9 \% |
80.     {
    
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    " Y& I, W( j$ [2 s. e5 M& r  @
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    / C3 A" T7 r% X( h- u
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    * u" _' N3 H3 s
88.        }
    - N3 y5 J) h: I* D* R% O, x
89.        printf("Accepted client: %s:%d\n",
    4 `5 ]; _( H$ f& n9 m$ u7 n) f2 y
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    ' Y5 s/ A  k8 D, R% k$ A
93.                    (LPVOID)sClient, 0, &dwThreadId);
    ; d# X1 c: F$ T6 K# u4 I
94.        if (hThread == NULL)
    
95.        {
    $ D& {- \+ y( w7 K
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    
98.        }
    0 T) e$ n# i2 J
99.        CloseHandle(hThread);
    
100.     }
     
101.    closesocket(sListen);
     
102.    
     ( J& _+ d2 d3 n5 J& g
103.    WSACleanup();
     , e% v, V* q2 T& f& T
104.     return 0;
     + B! d. ?8 b0 s, l$ _
105. }

复制代码

; _- l  n( G7 E/ M5 _* I- A" n

- Y: W6 v) H2 l* A, ~% \& D; u) y
0 d8 z1 S% C- X0 O  L& ?

---

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

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   : D; u5 s. M/ n+ Q2 z9 K
2. 
   # J7 C9 M, ^- S: [: N
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   4 \+ u' q: ]/ ], Y, ?1 c; s
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   3 D% r6 M' i" n
5. 
   2 [% I! e0 K1 l0 }% r" U* L9 |
6. Server：
   6 `6 I; c$ H1 h4 X1 ^/ s
7. #include <winsock2.h>
   
8. #pragma comment(lib, "WS2_32.lib")
     w+ W( V3 ^4 j. ?( O
9. 
   
10. #include <stdio.h>
    
11. void main()
    . ]( ^" h, b  b
12. {
    
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    5 j- j" k  H1 K: Z2 e
15.     int err;
    2 E9 Q7 }$ A" Q) ?" Y; ~  A4 Y
16. 
    : I2 K& `% q' Z% T% [# U$ h, h: ?
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    / V7 R: X3 a9 D0 l
19.     err = WSAStartup(wVersionRequested, &wsaData);
    , Y0 e& s$ U5 p
20.     if (err != 0)
    
21.     {
    5 z6 Q  _: S4 S- m
22.         return;
    / K2 P; u0 h/ C5 ]( N# I5 _
23.     }
    
24. 
    % j9 b# `) e/ t; }3 h2 V; z
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    / I; R, @5 {  q) ?0 W3 ]
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    1 u/ v+ S* X& ?' k" [$ J
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    ' a* i/ P2 @) d  \+ g. O
29.          
    1 }( q0 K- D5 j( |2 ?; Z! _( K" }+ O* L
30.     {
    
31.         return;
    
32.     }
    + K/ n0 l. o7 U6 \4 W
33.      
    3 M& g+ d% q$ L1 u% V) J
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    $ N9 V& M) }& t$ L3 U
38.          //Socket地址结构体的创建
    
39. 
    : r$ P! x+ t' @! T( N
40.          SOCKADDR_IN addrSrv;
    ) B" b- K# b; s0 \
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    # S; i& U) }& T9 X0 V
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    
44.          addrSrv.sin_port = htons(6000);
    8 y  \, F" j+ C
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    . x" [, q( Q" R+ H
46. 
    0 X, m" g& E7 j3 P& Y
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    5 |! f  e7 ^/ d3 T1 `  g
49. 
    0 p2 U9 M4 L+ J: O7 l
50.          listen(socSrv, 5);
    2 u0 O. ?. ], c" b5 N- i  C0 u
51.          
    2 v/ |  ~9 T. }3 D# s3 p$ Y
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    7 V4 Y8 }* p& v" U3 }2 _8 W3 d
55. 
    
56.          //循环等待接受客户端发送请求
    ! q. k0 i2 Z* C: j
57. 
    
58.          while (1)
    
59.          {
    . \- C- l/ l" l  m
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    * B% J, N9 ]% o2 O# t
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
      T( Y- C) M5 S5 {% l) U
63.                    //此时程序在此发生阻塞
    
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    2 Y4 S% x& Q+ O1 h
66. 
    ! d: s, U4 m% Q, @" O
67.                    char sendBuf[100];
    . X3 F9 [7 T* C# w8 N1 J
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
      A  V1 n+ }9 K' `2 G- R
72. 
    ) \* D; X/ j2 |& h+ C; \7 ^- t5 A
73.                    //用返回的套接字和客户端进行通信
    
74. 
    5 h; K' v3 N+ b+ @2 `
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    1 z: M% o& h+ g( }9 |
76. 
    
77.                    //接收数据
    2 s) J8 U' N! `+ g' Z' y
78. 
    
79.                    char recvBuf[100];
    5 H$ N1 ^/ P5 Z- V7 `! z4 ^
80. 
    . D/ s* k: Z% {- \; |
81.                    recv(sockConn, recvBuf, 100, 0);
    " v+ v& B) R. C' a
82. 
    
83.                    printf("%s\n", recvBuf);
    ) t& S- p; z! g" w: M, x( F6 g6 q
84.                    closesocket(sockConn);
    : P( g$ ]' F! v5 ^- t5 F/ Q/ @. n
85. 
    6 w, c5 `5 B, L# I! Z
86.          }
    
87. }
    + r" @2 W/ u. D$ }
88. 
    
89. 
    / I9 ^+ U% ?( R8 u1 \
90. Client：
    4 {) w, u* h$ k  J! U
91. 
    
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    2 o% F: r3 A6 L! S2 e
95. #include <string.h>
    
96. 
      k, H9 E. n6 F
97. void main()
    . e3 _. K9 X1 G/ r5 w( F
98. {   
    
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
     
101.     int err;
     ; N  k5 @# |4 U  L0 U( X# w
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     9 t1 i7 c% @) F3 C+ i
106.     if ( err != 0 ) {
     
107.          
     
108.         return;
     0 S& J5 X4 V7 Y& Z. f5 g" R
109.     }
     , I- U4 [* A2 ~: B% e- j0 e2 E: I
110.      
     ; e& s; _5 E8 y' k/ M" M, L3 E
111.      
     , e( r2 z5 _+ R7 Z  [) \
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     " i3 ]3 V1 S. E4 `: T
114.     {
     - B& q2 S1 M! o1 ?* C
115.          
     " I1 P0 H7 ~0 d/ a7 v# F7 u; G* l
116.         WSACleanup( );
     
117.         return;
     7 m0 e8 O9 F% b' Z
118.     }
     0 Q/ N* n5 f  Q" n9 D" t7 V
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     * Q& Y1 J9 G$ ~! C+ W( x
121.     addrSrv.sin_family = AF_INET;
     " M' b! D3 B2 D! A. t7 R
122.     addrSrv.sin_port = htons(6000);
     9 v6 o; _5 r7 ]5 Q. h0 ^; b
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     - ]2 c( f2 B! E( q9 R, T
124.      
     9 z/ c( [) f$ z; P
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     ( j3 D0 G! D7 O1 y* B" y
126.     char recvBuf[256];
     * S" w" k% J7 L; w
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);
     
131.     closesocket(socketClient);
     # y5 M# `) z( o
132.     WSACleanup();
     
133.      
     3 f4 k: \% L: v- ^& T" ?, r/ y3 Q
134. }

复制代码

) Q. d# B* c( R; C; M

---

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

Powered by Discuz! X3.2