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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
  K9 W' _4 g0 b) }客户端程序：client.cpp
# M" c7 j3 Y7 u7 p, \0 B

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
     d8 ?6 J. H7 J# F+ {9 [* W
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   $ ~& k/ |. h9 O* ?
7. 
   
8. char  szServer[128],
   2 w- r( z6 q1 d+ A3 g+ r( n
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    
11. 
    8 R3 h7 L; ?) ~% |) d: q
12. int main()
    3 b! x' g/ A1 ^! n
13. {
    4 J) F* z" V$ S8 g4 E
14.    WSADATA      wsd;
    - t9 `1 `2 I! ]* s, G, `- {, @( Y
15.    SOCKET       sClient;
    , z* i; ?' v9 s8 v. H3 G# T& \& e
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    % ~# D, L' |$ ]! D5 K. [& ?
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    5 l: G1 V/ q! i* t
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
    0 t0 a. z+ [1 H& a% m$ A1 [' }3 q
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    9 j; j+ x, Q0 B
29.     if (sClient == INVALID_SOCKET)
    ! K1 P) L4 z5 n* D* D9 W# |
30.     {
    2 e& x$ k* D! I0 \7 T( C6 j
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    
33.     }
    
34.    server.sin_family = AF_INET;
    9 [- {3 ?) m* X1 l& e/ Y; V/ a
35.    server.sin_port = htons(iPort);
    
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    1 @9 v5 W8 k: T
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    " q1 t( U' j# G% G9 B: C! n5 J! W
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    : u/ M& C" g4 O* m, ?
42.        return 1;
    
43.     }
    $ u8 N" w, D# z# i  B  v! X
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    & X7 g  ^' w2 l' P( T  o
46.     if (ret == SOCKET_ERROR)
    
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    
50.     else{
    : R8 D; c! q* g: D$ m
51.        printf("Send '%s' \n", szMessage);
    4 R  J* _  s9 d" p
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    2 [* b& L- o& M3 |
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    : T7 l0 @. O( J0 g. E/ m. A8 ^
56.        else{
    
57.          szBuffer[ret] = '\0';
    6 s, y2 b) E2 }6 h: ~5 v+ B2 s
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    $ A/ U0 ?5 E/ p$ s* B' L7 @8 _
60.     }
    
61.    closesocket(sClient);
    
62. 
    / s2 V' C3 \# @. V; H3 K
63.    WSACleanup();
    
64.     return 0;
    # I( O0 w3 ^( \. Q
65. }

复制代码

服务器程序:server.cpp
  s! O1 g6 n4 M

1. #include <winsock2.h>
   
2. #include <stdio.h>
   8 @8 C5 {. n2 b  U3 O; u
3. #include <stdlib.h>
   7 R% r# H0 v# O' {. Z
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     4096
   # z$ Q% S7 ~4 p+ F7 u% L+ I* l
7. 
   ; }2 G6 b3 v5 H* D1 a
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   : f" Q9 `5 s1 [+ e
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    " g1 ?$ P* H' c8 L- {
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    # s7 [$ d1 P, a4 J+ t0 l; N
15.    int          ret;
    ' L& k* x- O; ]) |/ U0 d4 ~. U" `
16. 
    
17.    while(1)
    / \8 `; N+ x- C3 L. X
18.     {
    ; r8 L6 c. j# {& ?6 r
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    
23.        {
    % R2 h7 y2 r8 m& Y' s, \1 ]
24.            printf("recv() failed: %d\n", WSAGetLastError());
    
25.            break;
    ( j, r& u4 n4 i" G: B0 E2 f% y* u- }
26.        }
    
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    + D( D( y1 `& G" ]
30.          memcpy(szBuff,"Send the correct string!",25);
    : k$ f4 A! e: b( J: H  D  ^1 d
31.        }
    ( `' t! `- j- D& j
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    3 a  j; `* B6 ~: d
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    , R+ _) v6 p- ]6 X8 X
39.     }
    % d/ b8 J8 s6 d# Q7 k
40.     return 0;
    ) d2 o; O/ }5 ~
41. }
    ' K* x2 E( Q8 f( B
42. 
    
43. int main()
    
44. {
    3 V, t$ b) n' k( S* o
45.    WSADATA      wsd;
    0 p* v5 \7 d8 M) O6 m) W
46.    SOCKET       sListen,
    % o, I' y+ V- [
47.                  sClient;
    
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    3 d( a; V. o3 H, k
50.    DWORD        dwThreadId;
    5 ^" p$ J1 L( H7 _8 ?
51.     struct sockaddr_in local,
    
52.                       client;
    
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    5 U/ {0 B( w  R
55.     {
    
56.        printf("Failed to load Winsock!\n");
    
57.        return 1;
    
58.     }
    
59.     // Create our listening socket
    1 r3 g+ s5 Q( p( c1 v( {
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    , O  j, u" {2 s8 o# n* c9 ]' ~! s
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    ; @- F- B; N# v7 g
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    + [0 y& }* @) g5 [$ t. r* ?9 y
67.    local.sin_family = AF_INET;
    , f4 |0 ^1 p- ]6 p
68.    local.sin_port = htons(iPort);
    7 V' L: y# \5 ?2 t3 a0 j7 O3 b
69. 
    & p7 `' s; Q! i0 X' s. B0 D0 T, I  L
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
      u9 F; h$ ~4 |3 ?% `8 s' f% w
72.     {
    ! @: M) [8 V, |3 n8 F
73.        printf("bind() failed: %d\n", WSAGetLastError());
    + S( ~) w* h8 Q6 L6 t; P
74.        return 1;
    1 t( r% d' r/ ]& M) B
75.     }
    
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.
    ' p) c  X" a$ U" V" `# A# d: m
79.     while (1)
    , ^$ x1 v  Q- g1 `, x% d% z
80.     {
    : S) ?/ d* X/ X* e9 v/ v' F
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    , h% |# |' n2 A; `5 @
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    , p2 m, j. F, q" d. ^/ y
87.            break;
    
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    - w: S  b9 B- f) r8 O  d
91. 
    . O8 S! ]8 f  A/ |- H2 e3 g
92.        hThread = CreateThread(NULL, 0, ClientThread,
    : e7 _& G+ p# p* z; h& l6 D
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    6 e* l5 h0 C2 c; U
97.            break;
    
98.        }
    
99.        CloseHandle(hThread);
    9 A$ \* b1 W8 T6 M
100.     }
     
101.    closesocket(sListen);
     / }2 q7 X, j, Y/ x( J8 F2 h4 l4 l; p/ |
102.    
     # Y6 l3 f3 B, `) D" y
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

/ a7 l2 Q9 Q) L2 ]
% g* Y: K+ c1 m8 r
  h* N" s, o3 L8 k
, w3 S% f9 Q& h. N) {2 W7 Y" E! d

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   3 V- m# R% l9 E/ w9 B1 p/ B( b/ Y
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   ' I* K3 E# |- h
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   
6. Server：
   
7. #include <winsock2.h>
   
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   
10. #include <stdio.h>
    
11. void main()
    
12. {
    
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    9 L' t2 ^3 D3 F% j5 Y
19.     err = WSAStartup(wVersionRequested, &wsaData);
    0 o9 ?, z3 n7 P7 {: q' B+ i" ]6 ^
20.     if (err != 0)
    
21.     {
    
22.         return;
    
23.     }
    4 y. b8 _2 W+ D2 Y
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    / x1 D6 r2 ]" t8 O2 ~
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    - X9 e( d: E7 N
27.          
    3 H+ f" h6 R; e4 O7 W
28.         HIBYTE(wsaData.wVersion) != 2)
      s% w- N1 d0 E+ C( Y: k5 ]
29.          
    ; x3 e$ }! W( E
30.     {
    ) K. b+ l+ A3 n
31.         return;
    2 x1 f2 ?- M  M+ e+ ]' e5 Q
32.     }
    # Z- I- _" y, l1 n/ ~, ]$ ^2 N
33.      
    4 S3 s' C5 e2 {% b% @) z. p# K
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
      r, P+ C  ?, U. e  Y! f8 X
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    3 ^, L3 r# b. K. x# Y# i8 |
38.          //Socket地址结构体的创建
    ' q+ P6 L" T7 l0 _
39. 
    + s& Y5 j# S# k! ^, K: W! [
40.          SOCKADDR_IN addrSrv;
    
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);
    # v; ]6 S, {3 P. K2 ~+ d4 }
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    ) |/ r1 R5 g2 N. |4 D( z
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    2 g" ^9 h4 Z& d5 I2 K3 J: X, @
49. 
      ?0 u$ L/ }/ v) A3 S
50.          listen(socSrv, 5);
    
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    0 t4 U& i  I% H+ E$ P( ]0 _
53. 
    / ?, c7 ~" v9 Z$ O8 c8 q$ {  e
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    0 c* {+ Y4 k  A" ?
56.          //循环等待接受客户端发送请求
    ( N7 T7 k0 ~0 Y, ?& j* a$ z, i
57. 
    # N) I2 k- m% \! `+ L* X3 N
58.          while (1)
    ; O9 n, i+ g5 z$ x
59.          {
    - M* i& ~6 L3 V- f7 D
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    . }' T) s& {0 V
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    1 s5 U2 B" p9 w5 x7 V" c' ^
63.                    //此时程序在此发生阻塞
    * @+ ~1 i" `5 A0 {  p$ Y
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    " O! l% ^0 z# c# u
66. 
    
67.                    char sendBuf[100];
    ) `1 _6 U0 G& ]3 @  S- }
68. 
    5 g  k8 q; F/ L; E  e* Q
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    / N6 _/ l. L. ^
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    # T; @2 A2 g& h: j+ ?8 J! N6 T
73.                    //用返回的套接字和客户端进行通信
    
74. 
    ) y- d. w; \2 L" y! U" \7 s
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    
77.                    //接收数据
    + P' y5 J, O2 ?; U$ b& w! r
78. 
    
79.                    char recvBuf[100];
      ?1 a; {2 ~1 O4 Q
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    ' _- E1 \4 D9 [* ]: c) H
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    
85. 
    
86.          }
    
87. }
    
88. 
    & a9 e* S* }2 y' O
89. 
    
90. Client：
    
91. 
    
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    
95. #include <string.h>
    
96. 
    
97. void main()
    6 _8 _1 X/ l8 u& x5 U1 j
98. {   
    
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
     5 J3 k7 U* G9 R2 `
101.     int err;
     
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     
107.          
     
108.         return;
     
109.     }
     
110.      
     
111.      
     6 @+ Q6 |* d$ P) L& _0 k, N
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     3 M& P/ K( e5 R
113.         HIBYTE( wsaData.wVersion ) != 2 )
     % P/ |) I7 A0 q7 S
114.     {
     * ]4 D  S  _' ^/ F# k
115.          
     
116.         WSACleanup( );
     4 R2 F" O2 f+ l5 }' I
117.         return;
     ) L. l/ r& P& r
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     ( H- ?4 ]0 K( u
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     / l& Y0 q+ u8 Q1 Z+ |1 h  L- M
122.     addrSrv.sin_port = htons(6000);
     7 s7 r$ t( M9 w. P
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     # v+ a. W% [2 Y
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     . G0 w7 ]9 ^" _  _! `
126.     char recvBuf[256];
     7 P( L% _) Q% A; w- I* q
127.     char sendBuf[] = "This is Joychou";
       U+ x1 W3 e& k$ t
128.     recv(socketClient, recvBuf, 256, 0);
     $ L0 \* \, a/ m0 r2 K' I
129.     printf("%s\n", recvBuf);
     ( l: n2 [! I' B, ]
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     4 y1 ]+ ]" j7 D- G+ O  s' z/ L5 E
132.     WSACleanup();
     
133.      
     ) z( m1 b/ w% R
134. }

复制代码

4 A& s0 H* ?+ [5 y) A! h