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

admin

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

1. #include <winsock2.h>
   ' t& Z$ X, D# L8 {
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   3 I' a4 ^( [( Z
7. 
   - Z& k2 x5 R9 B1 F
8. char  szServer[128],
   
9.      szMessage[1024];
   : w5 u0 c4 o  b! [  K" S
10. int  iPort    = DEFAULT_PORT;
    6 u9 d# n9 ~* m! Q+ d+ U! Q. O
11. 
    
12. int main()
    : `7 M/ A, ~9 q
13. {
    ' _3 x& n4 X" X) f3 g) x
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    3 L1 y! A) h6 s) R' H
17.    int          ret;
    ; l- J" q+ d8 G
18.     struct sockaddr_in server;
    - [. r4 M$ y% ~) l3 A* K
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    % h. V5 K- ^1 ]- h
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    3 t. c* e& O. i2 F2 c! P; f) `# {% \
23.        return 1;
    
24.     }
    
25.    printf("Enter a string to send to server:\n");
    # x2 J7 i( A& Z. G& w, H
26.    gets(szMessage);
    / n8 G0 @7 u9 _
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.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    3 K1 s" S* u- Y% C5 ?" z, |
33.     }
    " _# _0 {! }# E/ G
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    0 v3 R; k" j" t, S4 U; ~8 ?
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    ! V2 b( m/ E* }+ T
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    " D8 G- k& F" \% ?8 W% H7 e
39.        sizeof(server)) == SOCKET_ERROR)
    8 L1 C  V& E6 j* S% N
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    6 M& C# _: _- w: S
43.     }
    0 u+ z* |; a0 _1 k) {, X
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    2 F" ]0 P' A# r. t
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    9 l1 x' T" l; L' t9 {: ]
49.     }
    & p1 a: K/ W7 z+ e+ h
50.     else{
    ! K+ s: P. n4 Y8 w8 m. [+ G) x
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    1 L: G3 q: _% v# M+ k' X
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    
56.        else{
    
57.          szBuffer[ret] = '\0';
    ' E$ Z6 ~( T. P7 U& {1 b' z* n5 ~
58.          printf("RECV: '%s'\n",szBuffer);
    2 ^4 i" _/ c3 l- }# o: ~
59.        }
    ! v, P) k1 |, }: ^
60.     }
    * n( G5 |5 _3 j. s" b' `: K# d
61.    closesocket(sClient);
    ; r$ l9 T' G& o
62. 
    
63.    WSACleanup();
    ; n  l1 N) _0 \$ R
64.     return 0;
    
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   + p# z9 S2 b& p0 v! V& B% S/ \
2. #include <stdio.h>
   0 Q) Q) e0 t6 Q8 a- d6 Q1 i* Q
3. #include <stdlib.h>
   % g% n; B" Y! `2 g
4. 
   : K, w" S/ m/ M7 z4 C9 G5 B
5. #define DEFAULT_PORT       5150
   * `; i! l9 c$ h
6. #define DEFAULT_BUFFER     4096
   
7. 
   . E( F. Z3 {1 s* a# ^
8. int   iPort     = DEFAULT_PORT;
   ! A+ b9 W: |6 s: t4 F& |4 _
9. char   szAddress[128];
   
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    7 K% I/ F2 K3 u1 I! i
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    
16. 
    . }7 P' \( h: D4 t9 v$ f* K
17.    while(1)
    
18.     {
    % |6 z% A6 `9 V! W, V. I
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    % M  y" C& _# C7 o( V; V' ?8 P
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    : q; o. S8 N* g
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    
26.        }
    , w8 c& N$ p  _+ ?* h
27.        szBuff[ret] = '\0';
    6 V( ?$ _, G" G$ N8 e- \
28.        printf("RECV: '%s'\n", szBuff);
    , }' J1 [5 L+ [  a% j
29.       if(strcmp(szBuff,"abc")==0){
    
30.          memcpy(szBuff,"Send the correct string!",25);
    / I7 {6 Q0 h) I# _
31.        }
    
32.        else{
    ' ^# J7 c+ R# }# e
33.          memcpy(szBuff,"Send the wrong string!",23);
    # ?$ Q% Q  Z& T* c' P
34.        }
    % b& X( K  K; j3 ?
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    2 z4 L6 J( w0 D: L& [
39.     }
    + L9 E' H: o4 O  T
40.     return 0;
    
41. }
    
42. 
    
43. int main()
    ( A  q! y4 l& l, H* U
44. {
    # n2 Z% _- K7 l& y: b# i
45.    WSADATA      wsd;
    5 v* S! ~2 a, Y
46.    SOCKET       sListen,
    
47.                  sClient;
    
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    2 L6 e, p$ ?2 q& }6 v2 ~# f8 Z
51.     struct sockaddr_in local,
    1 N+ `5 Q% L1 W+ {9 Z- u
52.                       client;
    
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
      u) m5 E% O0 n) l$ I
55.     {
    4 E7 b7 o/ A8 E7 X
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    ( o4 R9 L% I' H
58.     }
    
59.     // Create our listening socket
    3 U. t6 x5 w/ @- Y4 V
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    , @* F, t5 j! z2 b% r& o+ @- c
61.     if (sListen == SOCKET_ERROR)
    1 [3 j# `+ ^; d( ~( y- A; e
62.     {
    / f9 m4 d" o! q, f* X
63.        printf("socket() failed: %d\n", WSAGetLastError());
    ( S( b3 _/ l' h! O' @- ^! X7 o. [
64.        return 1;
    % F- G+ ?! ?( E/ R
65.     }
    5 v5 u/ ?$ V( {- @4 W7 @/ ~
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    ; a: D2 K& ~5 [3 d
68.    local.sin_port = htons(iPort);
      C; D: _( Y" t
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    2 f7 a/ R- l; i  c1 b
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    3 s  r7 T" u, s- W
75.     }
    
76.    listen(sListen, 8);
    
77.     // In a continous loop, wait for incoming clients. Once one
    % _& b  U! k. j8 N- H" J; ?
78.     // is detected, create a thread and pass the handle off to it.
    
79.     while (1)
    & k9 M! K" ~, e: A1 F
80.     {
    # ^- e( n4 ?2 Y: A1 S5 l  d  \
81.        iAddrSize = sizeof(client);
    $ W* B3 E# ]! L' e
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    2 K! h0 I' [+ ?; _8 b
84.        if (sClient == INVALID_SOCKET)
    8 V) v- n( M- B- q
85.        {      
    ) d' \& d/ e6 O3 k
86.            printf("accept() failed: %d\n", WSAGetLastError());
      g' n! }4 u. Z4 H
87.            break;
    $ N) ?, b- S7 _' t( {$ j
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    2 W. J2 Q( J) n' Q8 c3 `2 @+ J
91. 
    % @1 M: D2 y6 ]% R% G- `# l
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    : g9 u) R: ]! }# U
94.        if (hThread == NULL)
    9 J: s4 Q8 ?* w- V! R- \' j" ?
95.        {
    ) ?6 ?9 z6 r+ D
96.            printf("CreateThread() failed: %d\n", GetLastError());
    0 a5 |% E# O0 P# W+ F! v- Y
97.            break;
    
98.        }
    ) T! ~/ _' U  ]1 a, {9 p
99.        CloseHandle(hThread);
    ! U2 @6 d  [0 N: D
100.     }
     & v% O6 g, ~4 `' o3 X
101.    closesocket(sListen);
     
102.    
     : i" b( ^/ w& |. T, `( n! `
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

$ }4 @2 M$ x- e

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   " j/ @2 [  M0 i) N1 ?7 a
2. 
     _8 V  X$ `# n' Z$ O! O
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   1 _6 W! h0 N/ p! e, J0 Z
6. Server：
   , J& x* K" c8 G! z8 J- F* Q
7. #include <winsock2.h>
   & p* G0 g, q3 }4 @
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   
10. #include <stdio.h>
    
11. void main()
    
12. {
    
13.     WORD wVersionRequested;//版本号
    7 M$ h# J/ x' q- n) G0 E/ p" w
14.     WSADATA wsaData;
    
15.     int err;
    ' J1 B" U2 }2 \: a2 X
16. 
    ) [8 u$ R( M5 b
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    - a- Q* R) b/ P) Y- j, R
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
    / `' y$ p( ]1 U5 B: R9 L
21.     {
    
22.         return;
    3 k/ w7 N% [5 J" j
23.     }
    + Y! y9 x# k: ^  ]
24. 
    4 o* r7 ?( I( c! t
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    ! P. S: r# P' {, t; ?
28.         HIBYTE(wsaData.wVersion) != 2)
    ' M9 `: {/ ?! m2 c
29.          
    
30.     {
    
31.         return;
    + W$ U8 e# X* z+ @2 o+ i9 q
32.     }
    : U: u7 q& Y4 |
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    , F: h: G7 Q) ]
35. 
    ) F% _# S# u6 G, G( T* S4 `% u
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    8 C; U( O2 `' j: J1 @* u
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    * g' R! S( z0 _5 R0 j
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    . H0 F& Q/ }+ E: S5 C& h
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    ' y: {$ G3 l7 i8 Z% r6 O5 ^
47.          //将套接字绑定到一个端口号和本地地址上
    8 s( p8 ~% a8 L4 n& g
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    5 a  n& t" f% m5 A: D
50.          listen(socSrv, 5);
    6 T- f) o$ o* k9 c) _
51.          
    3 j$ `2 R! A" Y) e" D. e
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    $ M- W1 {% |) S# l8 s; ~0 F, |4 z
56.          //循环等待接受客户端发送请求
    . Q. A$ C8 s1 U0 Z& i6 {
57. 
    
58.          while (1)
    9 U# f* e) r# [' I& }. v' u( G
59.          {
    - U# V! v. [  Y- R$ _; X
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    . C# |/ [# |- g, v; p
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    $ Z2 M' L0 {% f2 a
66. 
    
67.                    char sendBuf[100];
    
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    ' @( ^) C6 j3 n+ [5 j( |" }
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    , w$ b9 [/ Q& B& R8 f
73.                    //用返回的套接字和客户端进行通信
    
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    / w7 x# Y; e( y8 \/ @
77.                    //接收数据
    , K" J- [+ ~- Z* b6 K: T
78. 
    
79.                    char recvBuf[100];
    
80. 
    - S! _4 z$ _! n* ^' f4 n
81.                    recv(sockConn, recvBuf, 100, 0);
    6 }' b( n5 a" y9 Q7 L& y: y' o
82. 
    . c! s  e1 L! n% p" h  z8 F
83.                    printf("%s\n", recvBuf);
    + g# D: b  n# n% g- w
84.                    closesocket(sockConn);
    
85. 
    
86.          }
    
87. }
    
88. 
    
89. 
    : ~- C, {4 H6 Q2 m$ y( ~, _  |4 d
90. Client：
    
91. 
    ! k  f8 h, r3 I. e& T  v# D3 U
92. #include <winsock2.H>
    9 ^5 i! S& q" l0 x. f& N  r
93. #pragma comment(lib, "Ws2_32.lib")
    ; B2 }8 E# Y* m: c. s
94. #include <stdio.h>
    % K$ m( A  x+ {4 ~- h$ T- T
95. #include <string.h>
    / G% @, g+ h  K" q0 P6 U$ r$ V
96. 
    
97. void main()
    * K: W0 ?. Q; V6 a+ S, Z6 Y
98. {   
    
99.     WORD wVersionRequested;
    - S8 R( ^) k& m1 U# k$ x  `
100.     WSADATA wsaData;
     
101.     int err;
     
102.      
     / t5 T1 ]$ q! w  p9 f
103.     wVersionRequested = MAKEWORD( 2, 2 );
     & y( c0 y" j8 V  ^" S$ z* N
104.      
     9 S( Z- c' n+ \& K
105.     err = WSAStartup( wVersionRequested, &wsaData );
     4 O* L# @" A! {% I7 a% T7 ]. A
106.     if ( err != 0 ) {
     
107.          
     2 \& ^( |) a7 S" X! l# I
108.         return;
     
109.     }
     $ A5 M3 ^* z: G- h# j7 X$ T' A
110.      
     8 {2 c4 r: ]$ O  y# C( {
111.      
     ! e/ {+ N& ]# m  t
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     6 n8 n+ Z7 X3 l" Q/ o2 v. S! D
114.     {
     
115.          
     
116.         WSACleanup( );
     ) y! z) v+ R& m& K/ h
117.         return;
     
118.     }
     9 g2 _' s' {% J+ \9 \
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     . v- Y( Y- }. @! @) u: U% X
121.     addrSrv.sin_family = AF_INET;
     . c/ N9 t) N" u+ ^
122.     addrSrv.sin_port = htons(6000);
     % t, G5 |% T/ N- ]. }+ C
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     
124.      
     6 i+ X0 o6 {: k  M5 n* x
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     7 m8 r7 q: L- T" g) Y
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     ) m5 n+ J& c3 N
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     0 }4 T: A1 B& G* j
131.     closesocket(socketClient);
     
132.     WSACleanup();
     
133.      
     & g+ p8 y3 F- ?2 ~  N
134. }

复制代码

: d% {9 D8 g9 g2 I3 T& c: l