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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
7 N6 H% J2 g3 }7 O客户端程序：client.cpp
/ f4 C' ?0 t) Y: [3 n! a

1. #include <winsock2.h>
   
2. #include <stdio.h>
   ; X# r$ K. R% n/ [) X" w& T3 L
3. #include <stdlib.h>
   $ i% j) E, W. V5 v) |$ |  V$ n
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   ' T+ P8 B: r$ ?5 \4 |0 J
7. 
   & w  P4 M2 P" M  W
8. char  szServer[128],
   * g! t/ [) k8 l$ b' t% ]5 [7 ?
9.      szMessage[1024];
   ) X: X" v: C9 D5 C
10. int  iPort    = DEFAULT_PORT;
    
11. 
    9 @9 j$ t6 i6 R5 I$ d2 T
12. int main()
    6 X% f- \( f5 _
13. {
    
14.    WSADATA      wsd;
    " r  X8 N$ E3 F
15.    SOCKET       sClient;
    * B# _' w' R7 v# ]3 a% _: i
16.    char         szBuffer[DEFAULT_BUFFER];
    9 G. B, l& e2 K$ U
17.    int          ret;
    
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    ) b6 l6 u+ b, i( D# r& s
23.        return 1;
    
24.     }
    
25.    printf("Enter a string to send to server:\n");
    / v" W7 z& n& U# E
26.    gets(szMessage);
    - W1 U( c) ]. u" e3 ]
27.     // Create the socket, and attempt to connect to the server
    ) K6 q. P: e5 p# C
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    ! P1 y' m# V% }( @/ S2 K
29.     if (sClient == INVALID_SOCKET)
    
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    8 E1 l3 F$ [$ V
33.     }
    
34.    server.sin_family = AF_INET;
    & S. D4 {' y* {5 l: b
35.    server.sin_port = htons(iPort);
    & {* P% M, X9 K
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    . n! o& u* m' o
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    0 X  B0 ~7 A" Y, A& A
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    9 o! m( G6 S$ j
41.        printf("connect() failed: %d\n", WSAGetLastError());
    
42.        return 1;
    / q1 n3 I$ W- {$ ^
43.     }
    " N% y. r* T' B6 j8 J
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    
47.     {
      m: w; I. E% Y) {/ u  i
48.        printf("send() failed: %d\n", WSAGetLastError());
    6 p" J( Q8 c) B' b
49.     }
    
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    % h, l% e/ \% K, z  a: H! H: V8 s- `5 O
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    
55.        }
    5 @: U# W# F2 k5 u9 }7 a  D2 A
56.        else{
    
57.          szBuffer[ret] = '\0';
    6 F2 e% a1 e$ w) K7 p2 D6 S
58.          printf("RECV: '%s'\n",szBuffer);
    
59.        }
    
60.     }
    
61.    closesocket(sClient);
    
62. 
    . n; i. ]* x" z3 B" L
63.    WSACleanup();
    
64.     return 0;
    
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   6 _0 c; p! |# L7 H: F1 _, Q
2. #include <stdio.h>
   . b$ x/ u4 A  |9 `* ^
3. #include <stdlib.h>
   : S* m: h4 r/ t3 \+ K, C" m
4. 
   + h& [0 }% [/ r" v% \6 `# h
5. #define DEFAULT_PORT       5150
   / e$ j' k! U+ x% V8 ^/ ?0 ~; _, N
6. #define DEFAULT_BUFFER     4096
   0 J- Y+ w: L0 y: C' [# K
7. 
   ( m# O' z% Y+ O) e
8. int   iPort     = DEFAULT_PORT;
   # X' t2 x: ~; \( w8 N5 G9 l
9. char   szAddress[128];
   - B' h! t: q8 m) o  g6 b: x2 G+ E% m
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    ) p% @1 y7 T3 i
13.    SOCKET       sock=(SOCKET)lpParam;
    
14.    char         szBuff[DEFAULT_BUFFER];
    ; g5 C1 d+ D" o2 A" E3 U7 \
15.    int          ret;
    
16. 
    
17.    while(1)
    
18.     {
    ! k: W4 i/ X. }0 x8 e
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    $ w: d5 D1 F  j5 {
20.        if (ret == 0)
    
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    / i  w( {. Z- G( U) b" t. Y) M
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    % |- R# i$ J, y+ @/ y7 B
25.            break;
    
26.        }
    
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    0 I0 y. s! {' q7 L0 x/ n% I
30.          memcpy(szBuff,"Send the correct string!",25);
    : b7 e; J8 d" j, u3 r
31.        }
    / W2 K. k0 A5 O* j1 X( a5 X
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    ) [8 _! H/ g  f' v. w! Y
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    4 F6 ^, ^' j' y- ^# D
38.        }
    0 Y- _$ `, p  k
39.     }
    
40.     return 0;
    
41. }
    : K& S& ~! k: X7 a, O! @* g4 R0 O
42. 
    
43. int main()
    
44. {
      X* v* \& A; u- W
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    . r$ X2 W1 V) O$ V7 b5 r
47.                  sClient;
    3 J' d* w3 U; {, d6 q
48.    int          iAddrSize;
    - x$ L$ o0 F# ]& S6 ~2 j( s
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    ( i8 y1 g% w1 E
52.                       client;
    
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    6 @" K8 }. d; C, a
55.     {
    
56.        printf("Failed to load Winsock!\n");
    8 L. y% s3 v* A
57.        return 1;
    7 ~1 S0 N/ y6 r4 D
58.     }
    
59.     // Create our listening socket
    8 g- N' t" O5 i* p" W& \
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    
61.     if (sListen == SOCKET_ERROR)
    9 t1 {* j# b5 Q
62.     {
    
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    3 T/ g( x: A. x" a5 J" y# d
65.     }
    . ^. [7 v# N9 j$ K) S, G8 X
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    , v# W# q& h+ o2 k% j) v
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
      `1 |2 ]5 y& M6 e+ k. o
69. 
    - F5 T9 T( _, G! W- I& e2 L
70.     if (bind(sListen, (struct sockaddr *)&local,
    6 e; p, H9 V- W3 \, d
71.            sizeof(local)) == SOCKET_ERROR)
    , b- N! C6 E1 [3 d1 h& i* n
72.     {
    2 V; m+ F$ H5 b6 U; i) l0 z% N! L! w
73.        printf("bind() failed: %d\n", WSAGetLastError());
    4 K0 O4 _) {) H" S
74.        return 1;
    
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.
    
79.     while (1)
    
80.     {
    
81.        iAddrSize = sizeof(client);
    
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    + |0 l& G! _; ~- [& {
85.        {      
    6 K2 H! }5 `6 `, C, w
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    ; I0 t- Y0 F8 d' }
88.        }
    ! V/ h& _3 y5 K2 j( R
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    1 U. D+ e1 c: B; W, Q" M' e
92.        hThread = CreateThread(NULL, 0, ClientThread,
    5 u7 g8 @. b* n* k4 [
93.                    (LPVOID)sClient, 0, &dwThreadId);
    8 U# j/ W) ^/ |/ G1 f
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    5 E! |3 j4 k& y- G
98.        }
    3 m+ Y- ]2 w0 H7 A, C4 E
99.        CloseHandle(hThread);
    
100.     }
     
101.    closesocket(sListen);
     # P. Y- k- S- ?: c' F/ H% @
102.    
     
103.    WSACleanup();
     * I: W- v" M( X
104.     return 0;
     
105. }

复制代码

: ~: L/ l: D% @  |$ a
3 C8 T) ?2 |8 \- l& t: v6 K5 X
$ x3 O$ v! d. c2 h

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   8 A/ ~( f/ t# A& F" \: `
2. 
   * s6 Q4 v5 J- m5 s
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   1 K' e0 g* R: z; o
6. Server：
   0 c0 m4 B2 I; G
7. #include <winsock2.h>
   8 W$ {5 G! p5 A+ Q  T3 s! M
8. #pragma comment(lib, "WS2_32.lib")
   4 h# [8 V" E" F- n4 U" {6 J4 G
9. 
   
10. #include <stdio.h>
    
11. void main()
    & O+ ?' S  V2 a0 l1 F
12. {
    2 R0 D- |0 V! {* G/ ?- k
13.     WORD wVersionRequested;//版本号
      E1 j- R8 \0 s4 a+ e
14.     WSADATA wsaData;
    
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    + P3 i* I; C2 O
18.     //加载套接字库,如果失败返回
    
19.     err = WSAStartup(wVersionRequested, &wsaData);
    5 a7 {! ?" _9 c, c6 s
20.     if (err != 0)
    " t; O; ?. M- n( c& B
21.     {
    
22.         return;
    1 l. h9 \, ?$ |
23.     }
    ! G: t3 G. ^  L1 N4 X. H; j
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    4 Z6 }% q% f1 p  E! l
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    6 w  c9 E: i5 m5 L" x! u, k- U
29.          
    3 k, k  G2 F3 M
30.     {
    5 q/ I6 V/ h" H; t: f' ?
31.         return;
    
32.     }
    $ X2 Q7 f+ Y: a5 v; k
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    / w- l0 V  W( j) }' M' u3 b- j
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    
38.          //Socket地址结构体的创建
    
39. 
    1 a9 B" K' k1 d& p) `7 q+ f
40.          SOCKADDR_IN addrSrv;
    
41. 
    , s* K) G" D$ m0 K) X' V& S$ O" g
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);
    " Z: F6 F* [, \5 w) G/ N% [8 v
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    8 a; h: Z, Q8 C, V" J9 W$ J6 V+ ?
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    8 c3 Y: Z7 q, J
50.          listen(socSrv, 5);
    
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    ; c) H3 t0 C5 Y; @: i! a/ ~
53. 
    ) @# F2 b1 K; G  z% ~
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    , b! v$ f) D! U7 d1 Q% H
55. 
    6 @: M8 g7 j0 t8 G/ |5 }- D1 }
56.          //循环等待接受客户端发送请求
    / j' ]4 R/ {# {. T% J
57. 
    
58.          while (1)
    
59.          {
    5 D. X. c. d( {) B2 X. ~; b3 ]6 N
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    ' e0 s7 l; V, ^) S
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    6 R/ w. T7 G) n
63.                    //此时程序在此发生阻塞
    9 Q2 o! n4 [! V+ W) ^  n) J
64. 
    7 Z6 Y; O0 p# E+ K1 g: C( P* Z
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    ! C  {$ u0 p1 h& ~9 _* j6 p
66. 
    
67.                    char sendBuf[100];
    
68. 
    7 W" O2 w( b4 A
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    , u" v  J- ~! i% x6 h
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    6 e4 X( K: Y* Y. Z3 G! W8 T4 n3 X
73.                    //用返回的套接字和客户端进行通信
    ; F$ z# ?8 t: n+ F9 H
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    
77.                    //接收数据
    $ q9 ~+ s; }6 [, E% s! F
78. 
    6 X/ W+ j8 U3 I- E: J; z- c; J
79.                    char recvBuf[100];
    
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    / F; Q" F1 X8 e( w4 J& _+ r: G2 {0 ?
82. 
    ( ?) e0 O! d! Z6 |  e- R7 q
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    5 ^* ]: P' E, T" m) F8 I
85. 
    * f7 M1 u. Q0 w: N
86.          }
    . ?: K6 n& U  _# y5 J
87. }
    - X6 X; b5 G  H4 @( |/ E' D  L
88. 
    + a( q+ v* Z2 V' t0 O& N5 q
89. 
    $ U5 N+ J# E. G2 }2 v. e: h
90. Client：
    
91. 
    " Z: g  N' u( \  {7 M
92. #include <winsock2.H>
    3 ]2 _- g5 H- ?# y- I* t8 A
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    
95. #include <string.h>
    
96. 
    
97. void main()
    
98. {   
    
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
     8 Q5 C4 `' I) ]8 K. s, O) A
101.     int err;
     1 n- ]% A2 {  U# B1 U3 B
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     4 f0 C" y6 i* \; V: \
106.     if ( err != 0 ) {
     
107.          
     2 U/ q5 `! t, [' ^
108.         return;
     ( a( t2 \3 S, E6 u
109.     }
     7 L# V  t4 U0 E( W  R- L
110.      
     
111.      
     
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     # W0 G8 u* |7 L3 Q
114.     {
     
115.          
     
116.         WSACleanup( );
     
117.         return;
     2 t% e  E( Z4 t: W  R
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     ) U; Z' q: M: J6 B# b
121.     addrSrv.sin_family = AF_INET;
     
122.     addrSrv.sin_port = htons(6000);
     
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     
124.      
       x6 R" u/ q! X( ]' E
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     5 D+ y1 t) v' G, B0 A5 J
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     ; U0 ~4 `! p6 ^6 x/ Y
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     % S' H+ w4 n. E5 J" Z& p. `: e8 ?
131.     closesocket(socketClient);
     
132.     WSACleanup();
       q, f2 m( I3 j; u4 I6 k) o
133.      
     - ~8 t# ], p; [% G2 |% o- M
134. }

复制代码