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

admin

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

1. #include <winsock2.h>
   
2. #include <stdio.h>
   8 F2 F; N3 l7 f0 \; b* O9 i
3. #include <stdlib.h>
   , V# [- \8 D  [$ C- k
4. 
   
5. #define DEFAULT_PORT       5150
   ) I6 b: Z; S) T7 w3 E0 w
6. #define DEFAULT_BUFFER     2048
   
7. 
   
8. char  szServer[128],
   
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
      U3 r5 o# S3 F5 s( y/ E
11. 
    9 U8 o, W# ]; E9 A( k4 H) w% Q
12. int main()
    + [& h# n3 Y8 }6 H
13. {
    * A% Y- G: U( ~, p" Q5 Z+ a# q
14.    WSADATA      wsd;
    ( b. J2 M# a2 _2 j& @
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    
18.     struct sockaddr_in server;
    ( t4 o# y- K( k3 J
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    3 z0 z9 d4 f( U
21.     {
    
22.        printf("Failed to load Winsock library!\n");
    : S- E& ]; _# t6 h& W! U
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
    
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
29.     if (sClient == INVALID_SOCKET)
    % t* L4 [; f1 U
30.     {
    9 @) F7 u! q5 p
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    
33.     }
    
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    6 p+ b8 A7 [" W3 ^3 X) H/ r
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    - f. |3 b* w0 a5 _/ ]  @9 T
38.     if (connect(sClient, (struct sockaddr *)&server,
    0 c4 x$ [+ L# A. p+ g& Z
39.        sizeof(server)) == SOCKET_ERROR)
    6 x+ A  k6 l  G5 y0 ^" k
40.     {
    ! p/ v  L8 _+ D4 q$ j
41.        printf("connect() failed: %d\n", WSAGetLastError());
    6 @+ {0 @, ~  Q) q
42.        return 1;
    
43.     }
    5 }3 h3 M/ i% Y6 _
44.     // Send and receive data
    - x& V. [) e& g+ x
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    ; {) F. ?; L1 t: W1 Y7 o/ W
46.     if (ret == SOCKET_ERROR)
    
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    * y% X/ \, c- V9 k' O* S8 V! x
50.     else{
    . s6 g, J; Q. q% C/ k
51.        printf("Send '%s' \n", szMessage);
    ! Q8 Y) M% N, l( P8 i$ a% j1 w
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    " U4 ~' G6 _$ D% d+ |# \, W9 U
53.        if (ret == SOCKET_ERROR){
    
54.          printf("recv() failed: %d\n", WSAGetLastError());
    8 a' j) I; N4 n2 r% f" M5 g6 w' N
55.        }
    
56.        else{
    2 O$ U% }. b6 z  d$ H1 @3 q# V- \
57.          szBuffer[ret] = '\0';
    ; R% D9 T% a. n4 _$ v% V) o
58.          printf("RECV: '%s'\n",szBuffer);
    ! P5 J7 {  j+ U6 Q* C$ O
59.        }
    ! g$ u% \! l* }2 ]; q7 p/ q
60.     }
    ; E) Y& U8 ]& _& q  H
61.    closesocket(sClient);
    
62. 
    
63.    WSACleanup();
    + J' G$ V1 b3 i
64.     return 0;
    
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   
2. #include <stdio.h>
   4 g  A7 ]8 s5 N# ^
3. #include <stdlib.h>
   ( }% o& P- \# k" a" e
4. 
   
5. #define DEFAULT_PORT       5150
   5 Y' l5 S* Z* R- m' Z6 X
6. #define DEFAULT_BUFFER     4096
   . h; M, F* K* ~8 |, P
7. 
   
8. int   iPort     = DEFAULT_PORT;
   
9. char   szAddress[128];
   
10. 
    * G$ L- A, i$ V# C
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    2 }3 n: C0 v) @( }7 c/ p1 G6 ~
14.    char         szBuff[DEFAULT_BUFFER];
    7 F! u2 Z2 d5 W/ `4 M, L' Z: F
15.    int          ret;
    + M- A  b- k$ h. S
16. 
    
17.    while(1)
    
18.     {
      S0 g4 H# V; I; x( l  l& q
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    9 S# P; h4 d( \6 t; ~; k, K
20.        if (ret == 0)
    
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    8 Q4 a% u% b3 Z, N* E5 y
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    9 z& z8 p* b# Z% y- R6 P
25.            break;
    
26.        }
      E& K( C* G) B; y5 t) ^: \
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    ( G: S& y5 `- l, ?6 Y
29.       if(strcmp(szBuff,"abc")==0){
    
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    
32.        else{
    9 g. M& m/ J' G5 A) w2 k
33.          memcpy(szBuff,"Send the wrong string!",23);
    " q5 y) w, y( t9 L; X/ R
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    # o( R  J/ d" m+ J4 |0 Z+ x
39.     }
    6 e) {5 M3 q; r8 m9 Q. a! A; @% u/ L
40.     return 0;
    
41. }
    
42. 
    
43. int main()
    7 F/ t! E. m& I. J; B
44. {
    ! p! N1 z9 I6 t: [2 d9 v0 s
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    , V: Y/ {. l1 H2 R. W2 H) A7 X
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    # j/ W( O& T$ P8 d7 F$ S9 A
52.                       client;
    % D7 O. M& U) Z3 w+ K7 f6 E
53. 
    , K# C9 \" E0 X" h$ [+ ]
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    ! M2 F2 j4 o8 L& r
55.     {
    
56.        printf("Failed to load Winsock!\n");
    ) z. F( V* `2 k, t; X
57.        return 1;
    / l  ]7 R0 L4 X6 y" P0 X- m
58.     }
    / r! J0 f' G( p
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    1 }: a3 d# {$ N& \: E4 w
61.     if (sListen == SOCKET_ERROR)
    ! T7 u. ]2 O4 F- K( S& g2 O
62.     {
    : T4 F" q# p- {& r
63.        printf("socket() failed: %d\n", WSAGetLastError());
    : d( |; {  K' B! _: Y
64.        return 1;
    
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    
69. 
    
70.     if (bind(sListen, (struct sockaddr *)&local,
    " C3 E4 w& D: E: v' h
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
    4 |/ @" u9 o; ?/ p, s
75.     }
    ! G  z. o" p% `! N+ \% X, `
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)
    , _; \  C8 w6 ~3 o' v! x4 ]
80.     {
    
81.        iAddrSize = sizeof(client);
    1 l, [; S8 h$ A* y3 }  ~# o4 {( G
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    4 m/ X8 ~! ]% v$ f/ F# s
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    ; H) M9 Z) l+ A# Z
85.        {      
    9 m( F3 t9 Z; E( D! j8 _5 G! |
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    $ J$ |2 ]& \7 W& t
88.        }
    0 }* J" |9 H( X$ b8 e
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    ( i1 l" e+ ?' _$ o, W
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    - o2 K" j+ o# H; w) r/ n
98.        }
    % ^/ m' V  I& C$ f
99.        CloseHandle(hThread);
    
100.     }
     
101.    closesocket(sListen);
     $ L6 D6 C3 ]$ d
102.    
     . A, E* J$ o4 z* `# a
103.    WSACleanup();
     
104.     return 0;
     ; N  f; S6 \& |9 ~3 r! a
105. }

复制代码

, H7 q& g" N/ u. r
3 L8 O) f# f( F6 e4 _

3 B" |. P1 Q/ g- P

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   ( P) a1 j+ z/ p; y0 n
2. 
   % [* t4 Q+ \* [5 i5 k! c
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   : V5 j! B! ?) B, b
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   ' U4 ~; E5 Z% L2 ^! j6 A: ]
5. 
   ' o# S4 N: U' D5 Z
6. Server：
   
7. #include <winsock2.h>
   0 m( m$ J( g5 U/ @  v
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   $ e/ |- F: X" I
10. #include <stdio.h>
    ! j( p1 ?: }0 X; Q
11. void main()
    $ q* t: z2 }* x8 c9 w3 g
12. {
    & g! K; P, @4 W% t; P% j8 z
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    
15.     int err;
    4 A7 E8 r1 r( |; @$ l
16. 
    * G, i8 [+ A& I6 T6 q8 u' V
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    4 Q2 D0 o4 }/ {! Y5 K
18.     //加载套接字库,如果失败返回
    1 x; c" W, p4 k) f$ s4 |
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
    3 k( S; [2 Y3 E' S  o
21.     {
    * x/ h7 u! x1 U2 v& D
22.         return;
    
23.     }
    
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    # u, L# L5 K- F' |2 _+ v
27.          
    / i, C9 |% y$ Z3 B! V
28.         HIBYTE(wsaData.wVersion) != 2)
    
29.          
    
30.     {
    6 P* ^; h1 l" h
31.         return;
    
32.     }
    
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    " j% S- I9 c" P# ^3 }
38.          //Socket地址结构体的创建
    ' Z9 E6 ~8 S* N, w2 r5 M) H
39. 
    
40.          SOCKADDR_IN addrSrv;
    # ~. }" }+ o/ h0 p9 ]
41. 
    " Y  f% t2 J& P: y0 e  w
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
      l# l$ z8 V% T# P: o
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    8 I, R) {4 O4 v/ _  t: z
47.          //将套接字绑定到一个端口号和本地地址上
    : `7 X5 x& ~1 K  H8 r- @$ d
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    
49. 
    
50.          listen(socSrv, 5);
    
51.          
    * d$ C& u* q* T/ ~1 L9 l; u
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    4 u! s# w) a" G6 K0 h8 E7 ^
53. 
    * K5 i& J, P) G5 h
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    & G! j/ N" |) _* @, Q6 w- |; ^3 z
55. 
    . N2 \$ h. i3 h/ E) \
56.          //循环等待接受客户端发送请求
    
57. 
    . j+ U  c( T! f& a+ f
58.          while (1)
    ) I8 v& z. [8 L7 A. R
59.          {
    
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    1 F( w' }* m8 r
61. 
    ; |9 R2 T1 T- ?7 `
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    ) u. k) }; O" r$ X
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    ; P9 V! t5 _5 x$ |
66. 
    ! o/ _0 z8 t: F1 y* K
67.                    char sendBuf[100];
    ; }. q9 u6 F/ q1 G) a' ~' {
68. 
    5 n# a0 d5 f" h5 e' v
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    4 H; B& g$ b. q) {& {
72. 
    
73.                    //用返回的套接字和客户端进行通信
    6 ]5 E% f/ ~1 j' l
74. 
    , V% S. k6 q; Y  F
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    ( P- \# p: `/ [6 N; B
77.                    //接收数据
    
78. 
    
79.                    char recvBuf[100];
    5 U1 {  F. ~- t" @2 s) \
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    . l9 o- D* I5 N( j4 ^
82. 
    # K! _- J/ U  \) s3 t  Q
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    
85. 
    + N* X. [: c) E! v% E& i8 N& {
86.          }
    
87. }
    1 }2 k4 N* [/ x4 p2 _+ @/ a* Z7 X
88. 
    
89. 
    
90. Client：
    
91. 
    
92. #include <winsock2.H>
    * C- a: I7 o) q' L
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    $ B' F! J+ B$ N9 |& Z
95. #include <string.h>
    
96. 
    
97. void main()
    , h* w- X, O! D8 k8 h+ H6 l( a# I
98. {   
    
99.     WORD wVersionRequested;
    1 P# J( N2 V) }. h" h
100.     WSADATA wsaData;
     ; b8 R& ]5 m9 o2 T
101.     int err;
     
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     1 P4 U& }3 w* v- x0 j5 V
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     ' X- X5 a; v% {; L) M7 Z
107.          
     
108.         return;
     
109.     }
       q+ K9 F: c9 }) d
110.      
     ! I+ l7 n& S" F  |5 P! R
111.      
     # a0 V; b2 d4 s& ~" U' T! F- m! O2 I
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     ; r& d4 l& d' ]$ Y; p, H2 h
113.         HIBYTE( wsaData.wVersion ) != 2 )
     $ S9 G; q+ j' H# M% g8 ~
114.     {
     0 z+ J+ C) c: b. x( H$ \
115.          
     ; m- M' J' r! Y) L& \
116.         WSACleanup( );
     7 @6 R# [& ]4 @7 r
117.         return;
     
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     * `5 O2 n! y7 D1 d  k1 a1 F, |$ z7 b
120.     SOCKADDR_IN addrSrv;
     
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地址
     + {4 L& a  N; C
124.      
     5 ]' p6 \( c5 h+ e$ r  c" o
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     $ I) Z0 F. c/ j& W* u' W- B' M
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
       W+ D% {" y# J+ D5 m
132.     WSACleanup();
     
133.      
     
134. }

复制代码

( D* e( N4 X" ~& q) M  Y( l: L8 O! l
6 T0 w* E9 @, Z0 S8 u3 ]