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

admin

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

1. #include <winsock2.h>
   0 j- y( f; Q3 }! k5 K8 `+ y
2. #include <stdio.h>
   5 [& o$ i6 H1 Z
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   
7. 
   ) r# w8 F7 x9 }2 P. a+ n- Y
8. char  szServer[128],
   
9.      szMessage[1024];
   " a0 I$ x0 w5 ~# {; u9 _9 y" H
10. int  iPort    = DEFAULT_PORT;
    ( a% @8 M' ?, G! f+ z% H$ [
11. 
    
12. int main()
    
13. {
    
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    + W  E+ y, ^' ~2 M0 T* \
17.    int          ret;
    2 M7 b  b4 @& l2 N# s
18.     struct sockaddr_in server;
    . ^7 h/ N9 \' b' p, z) ?7 |
19.     struct hostent    *host = NULL;
    , h$ u. c1 K1 ^% }, V$ G
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    % [" M- G+ b  g5 g- O8 q
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    " n) s) ^# ~5 p' m; h3 j3 v4 f5 ?
23.        return 1;
    
24.     }
    
25.    printf("Enter a string to send to server:\n");
    # S) m' W$ h* N; l8 J6 @
26.    gets(szMessage);
    
27.     // Create the socket, and attempt to connect to the server
    
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    ; G! \$ j4 K. N8 v
29.     if (sClient == INVALID_SOCKET)
    
30.     {
    * L+ S, B' g; t- M- d
31.        printf("socket() failed: %d\n", WSAGetLastError());
    5 j# {3 J  L: S1 W
32.        return 1;
    
33.     }
    * @  [. J0 \$ L7 W
34.    server.sin_family = AF_INET;
    # B$ n9 p9 `& H9 F% E' }- ?
35.    server.sin_port = htons(iPort);
    
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    ; I' f4 ?7 t5 z5 Y* F) _+ |5 m3 M& j
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    5 G$ d7 @4 f: n
43.     }
    # c# r; M# m: J! a5 v
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    
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());
    
55.        }
    1 d" p0 T0 [( Z' U) b9 i
56.        else{
    6 P4 }- r. J" `3 @
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    
60.     }
    
61.    closesocket(sClient);
    
62. 
    + S$ j( B. a: ^! W9 V+ K4 B
63.    WSACleanup();
    
64.     return 0;
    2 o$ W& |$ O  w& F
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   # @" x) n( e2 @5 i# C5 f, P
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   : S3 s7 {: `1 s1 g; N' G7 S8 s
6. #define DEFAULT_BUFFER     4096
   
7. 
   
8. int   iPort     = DEFAULT_PORT;
   " k% R" U  J8 m0 W( q4 c' W
9. char   szAddress[128];
   
10. 
    , r0 I* v; J1 H# t% f, `; Y& J
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    1 S9 u! x5 q% \
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    ( P$ f$ R8 f( V3 g. f8 E
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    
16. 
    ) `& f7 e1 |0 _  M
17.    while(1)
    
18.     {
    7 O- r) i  i2 q/ w! m3 r. ?
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    ; X' ^1 L! B' u- _2 v$ L
20.        if (ret == 0)
    9 G; ?3 [1 F* f+ N5 p# M' }
21.            break;
    8 W8 I# w$ ]; E3 X) }
22.        else if (ret == SOCKET_ERROR)
    ( F( M2 l' I6 k$ ?
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    # ?9 @7 E+ M$ N9 H6 l
25.            break;
    7 {& d0 |+ d1 c4 C/ Q* k: p0 i
26.        }
    0 d) e! B1 K( ]# R9 l3 a% @
27.        szBuff[ret] = '\0';
    * }" S6 E7 x) I& v0 f
28.        printf("RECV: '%s'\n", szBuff);
    ( A  F/ [) y1 m2 D
29.       if(strcmp(szBuff,"abc")==0){
    " X# g2 G3 v1 t, H& A& I. n1 n4 A
30.          memcpy(szBuff,"Send the correct string!",25);
    * v3 @! N" y: k7 N, u* L( ^
31.        }
    : ]$ }8 @' \9 Y1 g$ {* A
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    , B  M9 s$ F# p9 f2 I* c
36.        if (ret == SOCKET_ERROR){
    1 Y  F. Z) Y/ r4 E; a) h
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    
39.     }
    
40.     return 0;
    7 L4 O) a1 M9 L3 x1 E3 X
41. }
    
42. 
    + g5 x# t+ M& d1 N+ ?) _
43. int main()
    
44. {
    
45.    WSADATA      wsd;
    . L& J# \: J$ _- c2 `5 o7 t& c
46.    SOCKET       sListen,
    : I1 i8 m) t+ T2 A: a" e# _. h6 V
47.                  sClient;
    % K( }, U: p. `- x3 i
48.    int          iAddrSize;
    " r$ b# h5 v9 P. |8 e' U" J
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    6 N. h( ]3 o! i. C( X; T5 |) y
52.                       client;
      M- n* T& C  U, W, o
53. 
    1 W3 E2 X6 t$ C' d4 ?9 ~5 f; r
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    " i; L9 k$ d, d/ X
55.     {
    ( j5 K7 k' y3 T. n& `/ h
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    
58.     }
    
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    : ^5 E: T# t9 F
62.     {
    ( V( z8 R, a% D5 S0 l) j/ ^
63.        printf("socket() failed: %d\n", WSAGetLastError());
    * C! {2 _# V/ n' b& o$ D
64.        return 1;
    3 M* b/ w: |! U. [$ k) q
65.     }
    . N$ P7 S) P7 U1 g2 X$ T& T  Y
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    9 T( c7 ]( x! S$ e5 _4 l: c
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    $ j. N# C' G( B
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    3 X+ u3 h% z" [7 S  U0 @
74.        return 1;
    8 `' I" T+ k" L8 p/ l4 d9 V6 {
75.     }
    1 z) P9 X0 Y# m
76.    listen(sListen, 8);
    
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)
    # U# F8 p( a: [$ f7 q* _
80.     {
    / w$ ]) d! J/ Q3 S
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    8 H7 K' Z8 @& B$ ]
84.        if (sClient == INVALID_SOCKET)
    5 A( [" p7 A$ X  o& j$ z0 g
85.        {      
    $ f7 q) ~& ]) }: I2 b* a
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    4 b. p+ v+ z$ s6 n0 x! S  z2 ]
91. 
    3 t7 m* O8 K9 r4 L/ h+ j  C* m& N
92.        hThread = CreateThread(NULL, 0, ClientThread,
    ( L. Y! f1 c6 q" L
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    
98.        }
    - a9 N7 x. C  A+ W
99.        CloseHandle(hThread);
    5 E/ f( b: e4 R- J
100.     }
     2 }" f  z# ~- y% b* d7 i7 t
101.    closesocket(sListen);
     5 m2 u4 X3 u2 I& Z3 c
102.    
     
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

' s* d/ [! j5 K

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   + }- {! @; }5 L' b* _% ~; O" Z$ L
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   ; n6 V- m6 j2 Y7 V1 J1 \5 m0 g/ `
6. Server：
   
7. #include <winsock2.h>
   $ f  D# O0 j! g5 {$ ?
8. #pragma comment(lib, "WS2_32.lib")
   3 c& _, j9 x0 c) i# _/ v  X
9. 
   
10. #include <stdio.h>
    
11. void main()
    
12. {
    " K, n% \/ M7 a
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    8 z# a6 t5 v# H7 O+ ~
15.     int err;
    9 C5 z. Y6 X6 I: \1 I) F* c+ X
16. 
    ( |7 Z. B, g* f' H# U9 y# @
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
    ' U4 q1 V7 m- z: G- N9 P
21.     {
    
22.         return;
    / C& r, B) S3 B/ z  c8 H
23.     }
    ' g  ~- h4 s+ s$ H
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    2 [9 g# x8 x9 \
30.     {
    
31.         return;
    
32.     }
    & ?+ `1 v4 _, Z9 l% `, {5 I
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    ; v  `# n; u2 ?# T8 d
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    
38.          //Socket地址结构体的创建
    - F& D1 {0 a2 e' R7 L/ g! Z) z
39. 
    
40.          SOCKADDR_IN addrSrv;
    & b3 W) M- ?, I) X: a" d) H& ?% M8 Z( `
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    6 }8 ~/ l3 `- H$ r: Q8 Z/ ?3 d) `
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    2 h( s9 z/ ~1 ~$ q7 M# y8 z
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    . l* r  }! L" R1 u
46. 
    9 V2 @- ]7 c1 a' L. E
47.          //将套接字绑定到一个端口号和本地地址上
    - d3 J9 q6 N" L5 T0 y' e) Y% |
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    
50.          listen(socSrv, 5);
    
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    ' q( N9 b/ @( o  }. m3 \  p
53. 
    5 H. C3 E, s) `* i$ d! m4 V
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    9 e1 ?- P) H" j+ Y
56.          //循环等待接受客户端发送请求
    
57. 
    
58.          while (1)
    5 `! Q: T9 K" m" \  t/ r; D! _
59.          {
    ; {* O" K1 m& Z3 d7 o- S
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    * `4 o# V4 e# l( A
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    6 z: q" b+ a  J# T6 G% L( d# ~+ s
63.                    //此时程序在此发生阻塞
    / G1 q5 @7 M! I" F, q& p/ }7 k6 p
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    
67.                    char sendBuf[100];
    
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    3 O) d; N( p% }5 r" U% @
72. 
    0 e/ p+ m! k5 ^1 l3 C. k% e3 M5 Y
73.                    //用返回的套接字和客户端进行通信
    $ g. r- |+ T+ I! ^" @" S
74. 
    ; e" K8 G, k! U) a  j1 Z
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    * }! P6 L$ X5 K: P5 N, I( X) P
77.                    //接收数据
    
78. 
    6 I# C1 A& A4 y& r; g0 G: J. C
79.                    char recvBuf[100];
      e- w! Z' P# ^% W
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    + f: h+ p9 q, K+ a  I- j2 a! ]4 U
82. 
    ' ?+ q1 Y6 L' _) N2 a8 W
83.                    printf("%s\n", recvBuf);
    2 o. Y9 o! O) P! N# p
84.                    closesocket(sockConn);
    
85. 
    
86.          }
    . k$ L: I; Z. [7 f6 `# r
87. }
    ! H  i' h9 o0 c  J0 l2 N
88. 
    
89. 
    : p: G  d4 e4 e
90. Client：
    
91. 
    5 c4 Y6 C# V/ ?& s
92. #include <winsock2.H>
    + @- s  H- q; P( f
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    ; R' p3 m$ P0 T$ E3 M* [
95. #include <string.h>
    
96. 
    
97. void main()
    
98. {   
    
99.     WORD wVersionRequested;
    0 K3 T+ O% A* J7 ]* R2 ]5 g
100.     WSADATA wsaData;
     
101.     int err;
     
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     * O# S2 D% Y  y5 Z# i
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     
107.          
     * U1 q; S' s4 b2 L, m' _5 g4 z( ?
108.         return;
     : U5 j8 G; f3 k8 m% S0 M
109.     }
     
110.      
     6 F+ U' E$ T; u: z& ~
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     ; i# }% Z0 W8 Z- P& W$ i
113.         HIBYTE( wsaData.wVersion ) != 2 )
     0 ^; }4 [1 k; y2 j1 @9 |5 W
114.     {
     
115.          
     2 `- V3 j% C5 Q# I1 R* {1 `
116.         WSACleanup( );
     ! ~2 Q# ^) F: q3 |* p
117.         return;
     5 Q. _3 D% H: x3 }( ?
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     ! P8 e& |" ^5 M- q# P+ q1 Z
121.     addrSrv.sin_family = AF_INET;
     , ?  c  s3 O$ i( L) O! Q% I
122.     addrSrv.sin_port = htons(6000);
     , e, T- k  d5 O5 r& ]2 N
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     3 t. n- r, v( [0 x5 ?
124.      
     . ^7 A: g) u* r! f6 l
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     
126.     char recvBuf[256];
     1 l/ P% U# Q6 S6 Q) a! O+ H
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     , o; H% V/ d! r
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     ( L& f1 H& w9 ^6 r( ?" {
132.     WSACleanup();
     
133.      
     & u# r1 c# Z, L& u1 I, i1 y
134. }

复制代码

& W. N4 t2 a0 V8 @1 i% |" h6 v