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

admin

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

1. #include <winsock2.h>
   + S3 L0 v/ [2 t3 j* l
2. #include <stdio.h>
   
3. #include <stdlib.h>
   3 I; \: H/ ]7 a/ k# r
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   
7. 
   
8. char  szServer[128],
   + t- ~( s/ V- V9 q
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    
11. 
    
12. int main()
    
13. {
    
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    . E; Y/ s6 C3 J! I' H2 x
16.    char         szBuffer[DEFAULT_BUFFER];
    6 [; m# B) \. S: O% s
17.    int          ret;
    
18.     struct sockaddr_in server;
    - ]9 j! D8 F7 n% j
19.     struct hostent    *host = NULL;
    : P. U7 W7 U0 Z. v& L% `/ q. O6 j+ ~- P5 u
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    * Z4 g' \6 c, ^( |/ |0 u
21.     {
    8 g: b: H/ z6 r* }' e- I* m
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    
24.     }
    - v; A0 T0 w2 A. D2 d
25.    printf("Enter a string to send to server:\n");
    2 J' l, L5 o* l4 C1 |4 V
26.    gets(szMessage);
    2 |) K9 ^+ T, x. E6 @9 I, i
27.     // Create the socket, and attempt to connect to the server
    
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    . S6 p- q! F# @3 W$ N$ x+ w
29.     if (sClient == INVALID_SOCKET)
    
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    0 K: t& s1 ~' r( f
32.        return 1;
    2 B3 k5 v7 i. J$ D6 j$ i2 B
33.     }
    
34.    server.sin_family = AF_INET;
    / j* U  ^& M& V
35.    server.sin_port = htons(iPort);
    
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    % F; {4 m4 h; C. p$ u- g7 Q
38.     if (connect(sClient, (struct sockaddr *)&server,
    ! i" }, B! @6 V+ i- I
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    / L- x' }& U  x1 Z
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    
43.     }
    % {& z- Q' E7 o( K" j( |7 Q6 q
44.     // Send and receive data
    ' L: Y+ L) @' G
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    4 h+ W6 Y6 Q9 `
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    
50.     else{
    . _9 T6 K# d4 _$ u% w  N0 ~1 C
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.        }
    
56.        else{
    
57.          szBuffer[ret] = '\0';
    : R. k; P' H! A
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    
60.     }
    + k* g! O; U% w. o; P" q& x; t! J
61.    closesocket(sClient);
    & z1 g1 f2 J( {6 f& @1 [$ W* s
62. 
    ' ^+ Y9 c4 j' B; k, j3 r
63.    WSACleanup();
    
64.     return 0;
    9 C* |2 J( Q9 p0 a+ d% e
65. }

复制代码

服务器程序:server.cpp
, Y* T1 J+ E9 U* M" k. |( K

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     4096
   6 a& W; F) u7 [4 W" y: r: f4 Q
7. 
   / |! [" N- P: \$ i$ s7 [
8. int   iPort     = DEFAULT_PORT;
   0 G3 \: s9 ^/ Z
9. char   szAddress[128];
   # s7 O' r6 k: f- }
10. 
    * t% \( O# E' @
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    8 m. E" L5 d& Z7 L
14.    char         szBuff[DEFAULT_BUFFER];
    8 D$ X# K- {5 G/ Z
15.    int          ret;
    
16. 
    
17.    while(1)
    
18.     {
    6 ~( z3 Q- o3 X& ]) H, O0 J" B% L
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    7 }/ o3 e5 w; S1 n3 S
23.        {
    ( G. _2 [# S, d: L
24.            printf("recv() failed: %d\n", WSAGetLastError());
    , C9 m( ]/ \" i7 K% G' Z
25.            break;
    5 f7 l. }3 v6 c  h! b, G+ G
26.        }
    
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    ) h- d0 T- g* Z; V. y( X0 q1 J
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    7 L# P3 f0 C% ^6 h5 V; r& ]% K
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    7 h; {9 @& U! d7 z& p9 U% Y
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    # c' N- u; E2 a4 j
39.     }
    
40.     return 0;
    
41. }
    ' U/ W8 Z3 O5 u" V- d8 K4 I6 {/ V( X
42. 
    ) Q( z, m2 P0 B
43. int main()
    
44. {
      s1 k  l1 W! _6 [5 F, m
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    
48.    int          iAddrSize;
    . y8 K1 Q4 M; t4 b0 f
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    # D3 u' n& `- R6 m% Q+ f
52.                       client;
    & U8 a+ w+ ^0 }2 L4 N8 ?, |$ i
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    ! P2 N  b" J* o& s. }6 `
56.        printf("Failed to load Winsock!\n");
    $ A/ i9 F# m6 S' Y2 p/ c( G" l- G$ G- l2 R
57.        return 1;
    
58.     }
    
59.     // Create our listening socket
    9 u" O& R3 h* T# }+ C$ {
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    - N# Z$ Y" a3 |" `/ Z) d$ E
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    0 j. ~9 b* L0 ~- b% N) O" v# V  T
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    + [% G" E* ?- U" B% H) \
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    7 c7 F! u9 B( e
69. 
    $ H) i1 d& W4 @) X2 ^5 ?
70.     if (bind(sListen, (struct sockaddr *)&local,
    , O+ S  X' f) p
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    - J5 g- h9 `9 Q  i9 @
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    0 u( y7 w0 T# |( M2 t8 K( k7 G
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.
    ; e7 J4 S1 b  I- ?* F2 b
79.     while (1)
    8 I5 G: I# r9 s, [
80.     {
    $ o! F) W7 s& y8 v+ d9 j* \
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    2 V; M6 I9 g- I$ P9 U
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    $ Q- r; A+ n4 n: O  M* q7 G
88.        }
    1 e; x+ I: I3 g; s* X
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);
    
94.        if (hThread == NULL)
      x$ ]5 g% v! y# W- i
95.        {
    " e/ \" [( K5 t0 j+ Y5 g
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    
98.        }
    2 A/ e+ m1 f  H% r5 {0 P! O1 Y" b
99.        CloseHandle(hThread);
    . x+ S. k, ~, H% R
100.     }
     3 o0 ^/ L" S; I. z  I
101.    closesocket(sListen);
     3 S! e$ ?9 l1 W7 d3 Y4 v7 d: Y" a& t
102.    
     % x. C; N. Q  r* s  {2 Q& A8 k. M
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

: K0 U/ _9 W) k5 a1 h) @
0 p# |6 X* q9 g2 c* ?1 h$ R6 o- f
8 ~0 Z. A: t4 p/ ]( k/ Y, ^
0 J) O. v- e: a  _) h
" P7 }( \8 F+ O8 @

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   5 Z1 @9 D3 m! L
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   ' f) @" U4 z3 H
6. Server：
   
7. #include <winsock2.h>
   . f+ {. y8 x# h+ _# D4 O7 q6 A4 L
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   % v5 d2 i3 P4 p( m2 P
10. #include <stdio.h>
    
11. void main()
    
12. {
    ' }& q; s4 A+ Z
13.     WORD wVersionRequested;//版本号
    . y7 \" J& q; G- h  q
14.     WSADATA wsaData;
    
15.     int err;
    ' q5 I% q4 V( z- ^1 D& @* G
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    + r4 O$ v1 `# K* @& v" s$ w
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
    ' w- e- S' L6 L( U5 f
21.     {
    0 B& a; ~3 ^9 q' H
22.         return;
    
23.     }
    ; a9 e6 U) A/ V+ X3 W. h. P2 n
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    + O, i; ~$ W" }5 U
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    & r2 O0 p# ?* {! s) g* D9 Y
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    . c; |0 W2 f2 F# d# b
30.     {
    
31.         return;
    ) f0 N5 h/ L1 q7 |1 x* l
32.     }
    
33.      
    % M2 v$ i* |9 n" L
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    " R) j' {, O7 e
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    $ j  Q( m. F! \9 M/ e1 R
37. 
    - m# V) Q' H* O* g9 `4 n. M# f1 b
38.          //Socket地址结构体的创建
    + z" @, p/ a) n1 t' T
39. 
    
40.          SOCKADDR_IN addrSrv;
    . \4 j8 b' E" I9 }7 |
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);
    * _2 K# {; V( `
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    
50.          listen(socSrv, 5);
    
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    7 C7 Q3 L* W8 }' e, r2 S6 g
56.          //循环等待接受客户端发送请求
    ; r/ S! O8 x* z# u, [8 J
57. 
    9 @# N$ x3 S1 z, V- y# }; w& N
58.          while (1)
    7 D# W$ V3 E  I8 m, i  ?8 ]% S
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    
64. 
    ; V& K: {$ Z8 f3 N) o1 y% R3 f. M
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    ! l" U7 p0 e# x& Q
67.                    char sendBuf[100];
    2 ?' k" o$ y# L& @: g0 C8 s
68. 
    0 a& w4 }  [3 T, |
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    3 v, Q6 z  n; A" l3 c) T/ c; X4 I
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    ! u; x8 s1 g# @+ H8 f5 _/ W2 B% M3 q
72. 
    
73.                    //用返回的套接字和客户端进行通信
    2 C' M! S* e, V9 G. b+ i; M
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    ' T5 F* o1 Q& F% P7 B
76. 
    
77.                    //接收数据
    . i; @( y9 O% `9 Y. y, h
78. 
    
79.                    char recvBuf[100];
    0 _4 L6 D  N, h/ Q$ o( k/ N
80. 
      h4 A/ J3 z( Q" ~  i( }
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    , ~7 X1 j" X) R" A1 y' D
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    , z; i* R) Y$ O! j7 G8 k5 M" C
85. 
    5 K2 J" z! R. J: \4 [
86.          }
    
87. }
    ( X# B( A5 q( g
88. 
    ) q. w/ A* I. x) F: y9 E
89. 
    " {' R% U& P& n# [" ]: h
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()
    
98. {   
    
99.     WORD wVersionRequested;
    $ Z+ A) |* l/ s1 U3 J1 w& f
100.     WSADATA wsaData;
     # s. T& j( `( H- b
101.     int err;
     
102.      
     8 z6 n4 ^  w/ H# i
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     5 I  l9 \: B$ \  F0 Z- `
105.     err = WSAStartup( wVersionRequested, &wsaData );
     7 j" Q$ _+ c- a3 ?5 s, H2 |, [
106.     if ( err != 0 ) {
     8 y6 ?1 z4 x1 ^0 t4 x6 B( O  ?$ [
107.          
       Q6 G; Z* u& [7 T
108.         return;
     
109.     }
     
110.      
     
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     , Y1 x( L) Z2 U
115.          
     
116.         WSACleanup( );
     
117.         return;
     
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
       u. u0 F" i; _' ~
122.     addrSrv.sin_port = htons(6000);
     
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     " K( {, k' o8 [2 q' u
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     : z/ P! u9 ^3 w: Q
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     3 y, R% S+ ?" z2 g" M. W
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     : q4 F5 X. C: ]- o5 B; o
132.     WSACleanup();
     + |9 p1 S, R5 S& W) D8 q
133.      
     
134. }

复制代码