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

admin

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

1. #include <winsock2.h>
   7 E) N, W5 r, m
2. #include <stdio.h>
   8 ?  F  v, P+ r) X# h0 z+ P
3. #include <stdlib.h>
   
4. 
   + q$ ?* T& f& a' I7 j
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     2048
   
7. 
   / b% U9 M' W$ b2 N! q/ B: j% a
8. char  szServer[128],
   # E/ r6 u( S6 j4 |( d
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    
11. 
    
12. int main()
    2 G- d$ r% |& R" I
13. {
    
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
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)
    
21.     {
    : ?9 a8 O: q* A: l, t+ C5 }
22.        printf("Failed to load Winsock library!\n");
    
23.        return 1;
    ) X" y7 Y7 v8 v9 l; H* K; I$ A
24.     }
    . Y( H3 m/ H7 v: n: I
25.    printf("Enter a string to send to server:\n");
    8 R" [+ c6 i6 p+ f  N8 P" ~
26.    gets(szMessage);
    
27.     // Create the socket, and attempt to connect to the server
    & t' c& C6 N3 a" Y$ q
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
29.     if (sClient == INVALID_SOCKET)
    
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    
32.        return 1;
    : C9 G$ f3 T$ r9 d" U7 i
33.     }
    % |! O% s3 j  Q( ?" D& r
34.    server.sin_family = AF_INET;
    * U# W, ^& i# M7 T
35.    server.sin_port = htons(iPort);
    
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    / x, y0 v& C$ Z9 c5 A- i/ O0 [
37. 
    0 N  `0 ?( E( T' l
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    
40.     {
    & ~" q, n: @  |% m
41.        printf("connect() failed: %d\n", WSAGetLastError());
    " a  K; U0 g0 n
42.        return 1;
    0 B8 B5 A* X  J0 {+ U5 F! t- u
43.     }
    % V# M$ b3 _% G$ T6 O9 L! G
44.     // Send and receive data
    
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    
46.     if (ret == SOCKET_ERROR)
    5 q! k2 s1 l+ k' e  @, R8 Z
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    6 R+ Q; z& P% ~* ?2 A
49.     }
    8 N3 \' p5 i2 A8 D+ y: n/ u
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
    & r* T+ _/ W) p2 I# N4 s
54.          printf("recv() failed: %d\n", WSAGetLastError());
    # p! l6 g* D- \+ f$ c
55.        }
    
56.        else{
    2 }% @$ V" P+ ?5 `! p8 F2 W
57.          szBuffer[ret] = '\0';
    : S; n# p# L7 W6 c' B4 g  K
58.          printf("RECV: '%s'\n",szBuffer);
    $ F% b1 z* M, N% m' f; W( N6 S/ A
59.        }
    
60.     }
    
61.    closesocket(sClient);
    
62. 
    
63.    WSACleanup();
    
64.     return 0;
    
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
   & U# |- K) i; {! J: a/ b2 P
5. #define DEFAULT_PORT       5150
   4 H; [# h3 X& N3 `  d4 q
6. #define DEFAULT_BUFFER     4096
   
7. 
   , n& u3 r& E$ I1 |9 E
8. int   iPort     = DEFAULT_PORT;
   + ^$ M- S. d- ~3 N; w; c- f+ ~
9. char   szAddress[128];
   
10. 
    6 _0 d5 s0 R- d: ~% r
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    + B2 T- ?3 H7 h9 ^
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    ' K5 a$ t3 o9 a) @# _$ i
16. 
    8 r) @7 E* r- B
17.    while(1)
    
18.     {
    
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    & J1 Q# X0 r+ w( ?4 U3 l, J5 U# T, M
20.        if (ret == 0)
    
21.            break;
    ( B; C$ p7 l2 V, C2 R
22.        else if (ret == SOCKET_ERROR)
    " J4 u  u4 J5 Z& D2 N! u7 d' J
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    * q4 N- U. I3 V. G. E" v* t: c
25.            break;
      L2 O  z2 `7 o, `7 o1 d. F4 `
26.        }
    
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    
39.     }
    6 g: t% h* K$ q9 z2 F
40.     return 0;
    6 j; z0 |: l2 J! J7 `6 a
41. }
    4 u9 w. f& f9 R9 i0 w$ r* H3 P/ r
42. 
    1 u# R3 m" P+ {' w- O5 x+ B% l
43. int main()
    ! j( b! q) J  _" {+ |+ y( L5 }/ n7 n
44. {
    , W; @2 O2 M. w& b
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    # t- m  A0 Y9 K
47.                  sClient;
    
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    7 z! ^  D4 D- H! I$ i, h
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    
52.                       client;
    
53. 
    
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    
56.        printf("Failed to load Winsock!\n");
    4 E2 q0 A; ]4 p
57.        return 1;
    
58.     }
    
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    % _" g- t7 i3 q
61.     if (sListen == SOCKET_ERROR)
    : k- M( R. x" A; w' U4 k
62.     {
    + B- o* E& k) x& S- d: O
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    ; ~, j8 `: i0 v( H  p2 C! ]
65.     }
    8 z- x( P% Q- E
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    8 Z4 S% h& |! ?$ K2 S# H! n7 T+ d
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    1 |+ {1 j" A' d+ w! }
69. 
    8 j0 l+ d, ~& L" D
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    # R; o7 F8 ^% L7 @
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
74.        return 1;
      O1 E. x8 W- H# ^( e# E7 i
75.     }
    . F. q( D* ~* ]3 G
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);
    ' P" [9 S9 `( }. O
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    ; h+ E7 r& |. D5 U0 D* Z* T% P
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    . b+ `! A4 s, z- `- L0 k' O
85.        {      
    5 f$ ^; u. Q2 u
86.            printf("accept() failed: %d\n", WSAGetLastError());
    
87.            break;
    
88.        }
    + X4 u8 [% p" m7 `4 d
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
      W& @0 Y4 n0 H2 i/ q4 u' ~
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    + S: W1 g3 y4 W2 t2 p4 v' E  W
94.        if (hThread == NULL)
    
95.        {
    8 y5 B) g/ t7 |( i$ }
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    
98.        }
    2 c1 j. a7 Y4 Y- T: }2 S
99.        CloseHandle(hThread);
    1 L/ X4 ?5 P2 B+ o: [# e3 p7 p
100.     }
     & W/ f6 F6 o9 X! G) j
101.    closesocket(sListen);
     
102.    
     6 s  r+ f# D. n* p0 }9 \
103.    WSACleanup();
     
104.     return 0;
     
105. }

复制代码

! U* c9 U( `9 [2 t* v


8 h" ~$ p) n5 o2 `- {' Q; e

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   
2. 
   
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   7 e. e( g+ _! t/ p# ~) U
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   " L6 N9 `5 h" K) j
6. Server：
   ; @5 ~% G4 y2 V
7. #include <winsock2.h>
   
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   % O( \- C; ^: s
10. #include <stdio.h>
    
11. void main()
    : N* i1 I( x: ]- s, ~2 c/ V
12. {
    
13.     WORD wVersionRequested;//版本号
    / I1 c5 _% h. \# }$ l3 w2 b$ P
14.     WSADATA wsaData;
    
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    8 W; J. Y5 ~5 w# v& p0 N
19.     err = WSAStartup(wVersionRequested, &wsaData);
    2 e% ~, Y- S+ a
20.     if (err != 0)
    
21.     {
    
22.         return;
    9 r6 O* ~0 x  ~
23.     }
      q5 Z! [% K, O; T0 u
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    3 M2 n0 f* i' A
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    ( i# A. K2 l- ?3 j9 i
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    4 X6 P) R0 ~4 p: V2 m7 e
29.          
    
30.     {
    * J. t, l& n% {; e
31.         return;
    
32.     }
    
33.      
    
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    , R& w0 F/ u, W: @- u
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    $ k+ b6 W3 |' h7 d3 K: [% {
37. 
    * J& S& O" \4 {! [1 W0 T' G! _& M. R
38.          //Socket地址结构体的创建
    
39. 
    
40.          SOCKADDR_IN addrSrv;
    ( z9 [* |4 m  d6 _# f. Z& k" y
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    ' Q) e- [. c' c
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    / J+ \! A* K) q, n" @/ u/ O; J
44.          addrSrv.sin_port = htons(6000);
    
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    3 b/ h) R8 A7 ~: {. S
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    / x; W2 D) O- G6 d3 t
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    ( h. z' X& [: Y9 d5 z+ d) W
49. 
    
50.          listen(socSrv, 5);
    # ^: V. [5 S$ G( E$ u/ \
51.          
    ( O( i& k* R* V: t
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    
53. 
    
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    : @. U" q4 }# `, T: a1 o8 t2 E' }) E
55. 
    $ ?. [% F! y4 T3 P0 ^- w
56.          //循环等待接受客户端发送请求
    
57. 
    
58.          while (1)
    # Q! W: G5 I+ N0 Z
59.          {
    5 v$ d( R% ^. u
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    9 H! w! C, U' F6 R: |
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    
63.                    //此时程序在此发生阻塞
    ; o2 Z2 i6 G! ]; D5 O% j' ~
64. 
    
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    + y) u1 m: x  j/ m
66. 
    0 W* E  c& Y9 _2 b, A4 R) z# I! M7 w
67.                    char sendBuf[100];
    % B" ]) b* r2 j. f5 I
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    ; |. p. d' F- r. a2 l9 [) n, S
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    
73.                    //用返回的套接字和客户端进行通信
    
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    + z! Q/ `9 t9 q" V% d3 L/ S
76. 
    ( x* G$ t, k& d3 x8 Y8 O
77.                    //接收数据
    - I' P6 e' _- r5 ]' B% M3 v
78. 
    4 N6 _  L8 ?" p4 ~. l$ B7 G
79.                    char recvBuf[100];
    
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
      [7 S% [2 d: {5 y% x, Q5 q
82. 
    % Z3 K( \  Z. N6 T' Q& }2 b% T
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    
85. 
    
86.          }
    4 @- \7 z) o% q6 Q4 o* f
87. }
    
88. 
    + H4 {! O3 w. q3 x$ X8 \& R
89. 
    $ Z6 A( L5 }" {5 D2 k% W
90. Client：
    + K* Z  R. m7 G7 M9 |+ k
91. 
    
92. #include <winsock2.H>
    
93. #pragma comment(lib, "Ws2_32.lib")
    
94. #include <stdio.h>
    + E- g( w- F1 q( {
95. #include <string.h>
    % d7 s% |3 b* Q" j: v
96. 
    
97. void main()
    . M+ |0 J% K% b, n0 T
98. {   
    
99.     WORD wVersionRequested;
    / I% B, S  [# \/ t0 c3 y. g
100.     WSADATA wsaData;
     
101.     int err;
     ' ?7 {9 e3 v6 d0 w. @$ U( H. k& @
102.      
     2 P3 {: k- v! r- O+ \$ J0 o
103.     wVersionRequested = MAKEWORD( 2, 2 );
     5 P9 t8 d6 W6 f
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     
106.     if ( err != 0 ) {
     
107.          
     , Y& w5 J) O9 e; w: e2 s8 T, y0 [" n5 E8 s
108.         return;
     2 n! z# t' f0 T2 A2 E
109.     }
     
110.      
     3 g; s0 U! N, {( l- P% }4 V" c
111.      
     2 L' ]" u7 o' v' e+ z
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     
115.          
     
116.         WSACleanup( );
     
117.         return;
     
118.     }
     2 ~+ v$ d" e! N  n
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     ( Q) L3 Y/ K0 s. Q
120.     SOCKADDR_IN addrSrv;
     8 Y- Q( p4 h4 R; {
121.     addrSrv.sin_family = AF_INET;
     6 Z( O" }" a; h% R
122.     addrSrv.sin_port = htons(6000);
     & _( m3 S0 k0 @8 z* E
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     % S9 [1 T7 z4 D4 ]: O! S
126.     char recvBuf[256];
     * w/ O$ ^1 b) L' J
127.     char sendBuf[] = "This is Joychou";
     + X( N" V4 _* H, S9 @0 w* c' v+ _8 T
128.     recv(socketClient, recvBuf, 256, 0);
     5 o9 {$ z5 b- i( t
129.     printf("%s\n", recvBuf);
     % Y5 E  i$ o# E
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     
131.     closesocket(socketClient);
     2 F9 ~3 ]8 x. U+ u1 a2 ?
132.     WSACleanup();
     
133.      
     ) x$ r( K& P5 R9 r& i! Y7 p+ b6 H
134. }

复制代码

  W+ |0 v2 E7 `( @. I7 T