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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
客户端程序：client.cpp

1. #include <winsock2.h>
   
2. #include <stdio.h>
   6 A" L4 I, W& T0 e% e
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   . L& B& F' e( H  m
7. 
   
8. char  szServer[128],
   
9.      szMessage[1024];
   6 {" z2 ^3 ?* g
10. int  iPort    = DEFAULT_PORT;
    5 a9 H1 W4 v; v: o! ~. g
11. 
    
12. int main()
    
13. {
    
14.    WSADATA      wsd;
    / M6 R; |" u  V
15.    SOCKET       sClient;
    ' V" A6 M+ m! ^& i/ o
16.    char         szBuffer[DEFAULT_BUFFER];
    2 d( r1 h# Y0 D& g  \
17.    int          ret;
      o5 ]8 z1 Y" N* D6 M% T
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    7 i, M2 m9 ]8 G9 ~' Z( G) }
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    
24.     }
    8 E% N: N' Z4 F8 p$ M4 }
25.    printf("Enter a string to send to server:\n");
    0 c" O5 D. [7 V
26.    gets(szMessage);
    6 z" t; c0 {0 F' b5 Q! U) G
27.     // Create the socket, and attempt to connect to the server
    # t7 _4 _/ \$ Y: o# w
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    " r7 m! ]: m, T
29.     if (sClient == INVALID_SOCKET)
    7 Y! V; @6 N& U# K; l
30.     {
    ' q4 d! B8 K! J
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
      F5 a) I0 u7 S" A# F
33.     }
    
34.    server.sin_family = AF_INET;
    - M, H  Y6 [$ S1 H4 a0 J$ t
35.    server.sin_port = htons(iPort);
    
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    & u( C! d) Z9 W1 i( \/ Q# Q
37. 
    ) T3 ?4 Z/ D+ u' e0 n
38.     if (connect(sClient, (struct sockaddr *)&server,
    ) p- l( {8 B2 R: @2 m7 u
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    ; b4 V8 L, \: X- t! V& I5 m* `
42.        return 1;
    
43.     }
    ; c% n% n4 G; ], K5 a1 {
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    8 _8 }2 U9 ^1 g2 i9 f
47.     {
    $ f) t2 s) m2 H! N) d+ G4 c0 y+ p
48.        printf("send() failed: %d\n", WSAGetLastError());
    9 q# K7 S# X) q2 H8 h. ]
49.     }
    - C' M8 G$ R' z3 U, ?
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    3 u* o8 ?5 U5 {& V7 s
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    ( M( ]; t# S9 k* E+ K
55.        }
    
56.        else{
    
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    - c+ e1 S  @7 S2 R4 b
59.        }
    5 }) Y1 ]! p8 M
60.     }
    
61.    closesocket(sClient);
    0 I; m. J/ }4 K& J: U
62. 
    ; Z4 A2 n, \0 t+ h
63.    WSACleanup();
    
64.     return 0;
    : W4 J/ m' j2 s7 r. U/ h
65. }

复制代码

服务器程序:server.cpp
/ D  |. p8 k; c0 \4 w: P! c

1. #include <winsock2.h>
   2 _: P( R* Y1 T: L6 j& v. J
2. #include <stdio.h>
   
3. #include <stdlib.h>
   ; W+ Y; s. X) B+ \
4. 
   8 Y) x- }: k# u! x. S1 G
5. #define DEFAULT_PORT       5150
   & v* E* D. p( W- b+ n9 F
6. #define DEFAULT_BUFFER     4096
   3 T$ U+ a1 ~8 J; t% j+ C! J6 ]
7. 
   5 F$ e8 q! U1 B
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   + T! O: i. p/ B
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    3 K: ], w+ v. I/ j! |. M" P- ?
15.    int          ret;
    ! p) x# Y+ l; s
16. 
    . K" Q) l% k4 q+ x. {, h
17.    while(1)
    
18.     {
    7 x) }% }) u0 p* T0 u- Y& a3 ?( |
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
      M( V( S  g1 C& j- m+ t
20.        if (ret == 0)
    ; m1 Y' j& }, ]
21.            break;
    ; c5 f; v- i9 [; W$ T7 S9 J2 m
22.        else if (ret == SOCKET_ERROR)
    
23.        {
    ) x3 |# D. e& x; J3 p$ d2 Y6 w
24.            printf("recv() failed: %d\n", WSAGetLastError());
    5 I* M/ ~. }& c& u: I8 O. B, V# U
25.            break;
    
26.        }
    2 c+ C5 M/ l1 ~) r, A; u
27.        szBuff[ret] = '\0';
    % x6 E. B4 i9 z
28.        printf("RECV: '%s'\n", szBuff);
    ) E, v  c# S3 F( V. J7 ^
29.       if(strcmp(szBuff,"abc")==0){
    8 n( [% |" s8 B  e% ~: w. ^/ C# M- C* l
30.          memcpy(szBuff,"Send the correct string!",25);
    8 K: _2 Y! n& G
31.        }
    
32.        else{
    6 C, P0 r  {  v0 @! o( M! {
33.          memcpy(szBuff,"Send the wrong string!",23);
    7 Z  d: i& x7 [7 D: |$ {% c
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    4 G5 k0 D% z+ _) h9 a
36.        if (ret == SOCKET_ERROR){
    * t, [' ~! U5 R7 {8 B
37.          printf("send() failed: %d\n", WSAGetLastError());
    * N  v+ `! n- |
38.        }
    / \3 ?. Z7 g! `4 |# v
39.     }
    8 b  n6 v2 k* V; ~6 ^0 K' X
40.     return 0;
    $ t9 d  k- v2 N! k* y
41. }
    
42. 
    + j+ `) b* c- V6 X: `
43. int main()
    0 k3 m% ~3 ]# u# O
44. {
    0 @" A: m* H( g( l8 I* Q
45.    WSADATA      wsd;
    - s# Z" N+ X$ Q) y
46.    SOCKET       sListen,
    & g. M3 f6 i( B! z. F3 W6 F8 U
47.                  sClient;
    
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    ! d6 g% V7 _: ?9 t9 s
50.    DWORD        dwThreadId;
    8 d" f# I) ^+ }1 A
51.     struct sockaddr_in local,
    7 B2 v+ g/ W6 w1 I) I! k
52.                       client;
    : O+ h: y' P* M! m# K% e+ l/ D; n( Y
53. 
    ; U! K: {1 \- b
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    # e. k& d1 ?( e' g5 t
55.     {
    
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    4 R+ D6 o1 Y$ g& Q% x: n
58.     }
    
59.     // Create our listening socket
    ( m' S$ T1 r% i9 L
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    . ~, P& H$ ?. i$ ^7 L* Z! h
61.     if (sListen == SOCKET_ERROR)
    ' |( _4 X' y" y+ B( E8 V. K2 r
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    % J, H. y6 i2 n% Y. m# T  X; I
64.        return 1;
    
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    0 y! \3 f5 r( w; k9 _
67.    local.sin_family = AF_INET;
    , [. I/ S* j7 F+ [, F, T+ r* Z( {
68.    local.sin_port = htons(iPort);
    
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    ! l. @; h2 s( S6 t% t' Q
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    8 d0 C9 V: f& q
74.        return 1;
    
75.     }
    
76.    listen(sListen, 8);
    # [4 ~; Q' v* ]/ K! q
77.     // In a continous loop, wait for incoming clients. Once one
      S0 P$ f1 j* R1 [4 }
78.     // is detected, create a thread and pass the handle off to it.
    
79.     while (1)
    
80.     {
    - H" z0 w7 _- L0 y# }$ A# l) d
81.        iAddrSize = sizeof(client);
    , ?2 K9 k) W6 @
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    ) i5 x- A: Y' |& T$ o3 ^
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    ' \- q$ p# L, X! M& O5 y/ s. Q
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    ' F- W3 D0 B/ w: b
88.        }
    ; B, S3 ^+ C; `$ I  A) Q; o
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    " A  F0 X0 ]- \* z% Q5 Q
94.        if (hThread == NULL)
    . f- Q/ H2 Y3 b% R, X2 E
95.        {
    " C' Y. b7 T9 `
96.            printf("CreateThread() failed: %d\n", GetLastError());
    3 }1 V0 G0 Z. b) a
97.            break;
    
98.        }
    
99.        CloseHandle(hThread);
    4 e5 M& q+ ^1 |! i
100.     }
     " I. d1 O" U, j' Q. t& x3 t
101.    closesocket(sListen);
     - _% S. Z0 R1 V9 A* h
102.    
     
103.    WSACleanup();
     % `; w& H* w' a6 ]/ \
104.     return 0;
     
105. }

复制代码

1 G8 M. R" ~: J4 m# O
: J4 j* P; v0 }5 Q% @" @* W- t
8 ^2 e3 q' L* z7 V
; x( q, Y9 H  E# p( x4 p! ^

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   " v- t$ q: E" n& ?; k8 M/ \2 n- Y
2. 
   , O1 r1 T: |) p! \" n: c' U
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   4 J4 V, l. J8 X7 Z9 G: U
6. Server：
   
7. #include <winsock2.h>
   7 z: `0 [/ K' J0 a
8. #pragma comment(lib, "WS2_32.lib")
     y. @4 f: |; B$ O  a7 x
9. 
   + C2 P% s+ g, _. ?
10. #include <stdio.h>
    
11. void main()
    
12. {
    " ]8 [% W  b+ I# C  l$ m6 w
13.     WORD wVersionRequested;//版本号
    ; q5 o+ V7 i& N  V. \9 W( ~) Y
14.     WSADATA wsaData;
    7 w) k8 h7 d* O2 t6 \
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    ! e* r! L7 Y, _3 h' A
18.     //加载套接字库,如果失败返回
    ; U( l" \! b  V5 b/ `; ^: F$ U" _, c( t
19.     err = WSAStartup(wVersionRequested, &wsaData);
    ) p. H; D/ |; C! a7 E
20.     if (err != 0)
    
21.     {
    
22.         return;
    
23.     }
    
24. 
    7 [' H& c5 K' D$ p' k, O
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    + r7 I! {1 Q) T' v7 U
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    ( |( V& o& X; t$ D# E1 @, _
27.          
    " a. w! o/ n  D3 B( g# `1 x
28.         HIBYTE(wsaData.wVersion) != 2)
    2 D7 v' K6 _6 f7 r/ W- y" S$ ]
29.          
    0 R* w( O( w7 N
30.     {
    
31.         return;
    # K1 d8 p. w! |1 l, L
32.     }
    ' f) A+ ~+ ^8 G: x( X
33.      
    ) u# m- k- r/ p. h& }  o
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    4 v) L! O0 W1 n1 L* I/ v& C" j
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    
38.          //Socket地址结构体的创建
    7 b5 o$ T) V0 M% ]: r
39. 
    & v* n2 y# K& N/ H; q
40.          SOCKADDR_IN addrSrv;
    4 U' U; k6 R0 A% }0 b+ D- C
41. 
    
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);
    ( W  {+ m2 _7 f& s4 J
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    ! B5 |. o$ P, v; @/ k: L& ~8 d' `
46. 
    6 _' M# w- O  l) P& J$ b+ j$ m, @
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    9 x4 d$ u, B7 e7 g# E9 K
49. 
    
50.          listen(socSrv, 5);
    . k( P8 _1 a0 B! ~, [3 @
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    
56.          //循环等待接受客户端发送请求
    
57. 
    
58.          while (1)
    
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    ' l) Q% t+ }* k& c$ T$ D
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    
64. 
    % m+ U, u8 F% G$ a: M
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    ( {1 M1 s! n( p! u8 _
66. 
    3 t) p: A6 ]' O. I! b6 `) }
67.                    char sendBuf[100];
    ( O" c; y7 W5 j& Y% y6 d
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    6 D! C2 _; ]) K1 i
73.                    //用返回的套接字和客户端进行通信
    
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    7 \; x1 }& T8 J! C9 e& Z3 [
76. 
    
77.                    //接收数据
    
78. 
    
79.                    char recvBuf[100];
    $ |5 ^$ p- p! M/ e+ w& _
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    8 ^7 h$ y+ [1 W0 O* r0 k& W
82. 
    
83.                    printf("%s\n", recvBuf);
      a$ n# H$ x; \, ^" G- J5 M) |; l
84.                    closesocket(sockConn);
    ! M, y5 S( @) n8 v
85. 
    
86.          }
    
87. }
    ' R$ V" o# K" [) a& ?/ t! J/ E. F
88. 
    
89. 
    
90. Client：
    1 [3 b/ Z* h" `; j) M
91. 
    
92. #include <winsock2.H>
    " Y3 K" l1 G. o% Q: h
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    6 K: ^; V$ R( Z) j* e5 m
95. #include <string.h>
    - E$ z8 A& A3 h" \# b
96. 
    - L, G3 e3 ]9 T& W/ k1 @
97. void main()
    $ _4 T( Y4 j0 P( [
98. {   
    
99.     WORD wVersionRequested;
    5 l6 L9 I4 o" z, H
100.     WSADATA wsaData;
     - O7 O( q& r1 b) b& f3 h2 q
101.     int err;
     
102.      
     ! R1 |0 j: b  g- L3 u4 z& t
103.     wVersionRequested = MAKEWORD( 2, 2 );
     1 Y4 W/ B0 ?1 I6 K' }; d7 S0 x
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     . r  `0 @* s2 @- V4 P8 B
107.          
     : s* V/ n0 f) k
108.         return;
     + k: \* p. [' `- e
109.     }
     
110.      
     
111.      
     : P& f' P/ t( R# ~
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     " ~8 ?" g+ L# t0 O
113.         HIBYTE( wsaData.wVersion ) != 2 )
     # q0 v3 Y  W0 o0 s# q
114.     {
     
115.          
     7 ~5 Y% `  O3 K7 g
116.         WSACleanup( );
     - d/ f7 F8 g& x- Y$ I; V
117.         return;
     4 I. _( I, q/ U) P
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     " p4 x, z% }$ j  @  E
122.     addrSrv.sin_port = htons(6000);
     
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     4 \* r7 s1 f2 u7 O+ I5 {
124.      
     8 P% c  J1 C8 L2 q: P1 N2 x
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     
126.     char recvBuf[256];
     5 k) X3 ~2 s# `) e& p" E! i
127.     char sendBuf[] = "This is Joychou";
     . e/ @3 D7 A4 w. v4 b
128.     recv(socketClient, recvBuf, 256, 0);
     - [, M/ U) i1 i
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     . G( y; q* A( Q7 b4 d8 d
131.     closesocket(socketClient);
     
132.     WSACleanup();
     
133.      
     2 D. X& v2 l. r# D% F9 e" G$ M5 V8 k% M  F
134. }

复制代码

9 X+ o! _( p9 I# A- h+ L8 X
5 q# F8 c: L1 T/ b7 N8 B