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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
+ \% T- `; j! Q& F) k客户端程序：client.cpp

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. 
     a  {3 _. s6 Z$ ^/ F- ~) U
5. #define DEFAULT_PORT       5150
   2 i4 K: c. @7 z- G
6. #define DEFAULT_BUFFER     2048
   
7. 
   7 F8 ~  [: B. O, D1 r: ]- ^7 Q% X# M
8. char  szServer[128],
   
9.      szMessage[1024];
   
10. int  iPort    = DEFAULT_PORT;
    6 h7 X0 E1 V+ i, I7 y8 L3 T# o7 p/ v
11. 
    * F* D+ }: |# o
12. int main()
    2 N) C) _8 C- p
13. {
    / Q3 f3 ~* F. s2 S2 B
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    
16.    char         szBuffer[DEFAULT_BUFFER];
    , J. Q6 Y' f$ {+ h
17.    int          ret;
    
18.     struct sockaddr_in server;
    : m: W4 }. a( V  k& X/ S
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
      A5 m+ h; j" v! }
21.     {
    # e5 \- h/ B) `3 R" q  T  N9 U
22.        printf("Failed to load Winsock library!\n");
    
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)
    5 ~, _( r5 \% V. B- c9 N0 A8 K
30.     {
    
31.        printf("socket() failed: %d\n", WSAGetLastError());
    . t; G- t2 k; n0 y/ u6 ]
32.        return 1;
    
33.     }
    4 Y! c! A8 H9 _) |( q' ?
34.    server.sin_family = AF_INET;
    
35.    server.sin_port = htons(iPort);
    ) H+ z, ]; }7 y0 a' Q' y8 \' V! G
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    , k6 P! ?& t0 A2 y( t
37. 
    4 }7 l2 z9 @" |& D
38.     if (connect(sClient, (struct sockaddr *)&server,
    
39.        sizeof(server)) == SOCKET_ERROR)
    6 }+ m8 @2 L/ H$ U+ G
40.     {
    : ?/ O, ?2 Q9 o, R/ t
41.        printf("connect() failed: %d\n", WSAGetLastError());
    2 o( o8 J7 ]! z" J! \! `
42.        return 1;
    
43.     }
    
44.     // Send and receive data
    8 _: W% a% h6 I
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
    0 b& x2 H- k$ V4 g7 h
46.     if (ret == SOCKET_ERROR)
    
47.     {
      @2 e9 F: d0 }! @6 k
48.        printf("send() failed: %d\n", WSAGetLastError());
    : P/ u  j- T" e) w, S' X$ T0 r9 r
49.     }
    
50.     else{
    
51.        printf("Send '%s' \n", szMessage);
      l  S2 G* @" d5 B/ u) Z
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
    7 b/ J" q  c) z1 g0 c
54.          printf("recv() failed: %d\n", WSAGetLastError());
    % ]( z& F8 G3 x- a
55.        }
    ' U9 H9 l: n. O: N
56.        else{
    
57.          szBuffer[ret] = '\0';
    
58.          printf("RECV: '%s'\n",szBuffer);
    7 I4 r( S9 `. t/ R7 k' _9 E; i/ Q
59.        }
    
60.     }
    
61.    closesocket(sClient);
    
62. 
    5 m  K6 V/ B- l+ D4 q7 u1 `
63.    WSACleanup();
    
64.     return 0;
    + L. c3 _* w- h: m3 L
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   5 r4 L! k* K* M* \
4. 
   
5. #define DEFAULT_PORT       5150
   
6. #define DEFAULT_BUFFER     4096
   # C2 \3 _1 x6 e: ]
7. 
   
8. int   iPort     = DEFAULT_PORT;
   . i- O3 o- w! N/ C/ b6 h/ V5 I
9. char   szAddress[128];
   0 @/ g# E+ e' C1 v1 T8 U* o
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    7 p* S9 L$ ]( m" F" V4 ?8 [
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    . a$ ?6 k9 U0 W. [8 ]- t, Z( `5 P
14.    char         szBuff[DEFAULT_BUFFER];
    
15.    int          ret;
    7 ], J! {8 {1 ^4 E
16. 
    
17.    while(1)
    
18.     {
    
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    
21.            break;
    
22.        else if (ret == SOCKET_ERROR)
    
23.        {
    
24.            printf("recv() failed: %d\n", WSAGetLastError());
    6 i1 k, _; A8 r
25.            break;
    
26.        }
    % D0 W# [$ i- Y
27.        szBuff[ret] = '\0';
    
28.        printf("RECV: '%s'\n", szBuff);
    % B4 z5 Q0 b/ ^% p: K- r
29.       if(strcmp(szBuff,"abc")==0){
    3 |" R1 P$ r) c( p( z
30.          memcpy(szBuff,"Send the correct string!",25);
    " k3 q& d% Q8 h  {; _: m
31.        }
    " u# ^  j, g/ R8 q" X% S. I3 q9 T
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    
34.        }
    : m5 ^! H( p- T$ X5 s4 _+ b! o' R
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    
36.        if (ret == SOCKET_ERROR){
    / L5 b' n& E/ t
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    
39.     }
    ( g6 Z. {) N- W. A+ r
40.     return 0;
    4 X% y0 o: L' @% ?3 B% K
41. }
    
42. 
    
43. int main()
    
44. {
    
45.    WSADATA      wsd;
    7 ~1 ~7 _; z; |" ?
46.    SOCKET       sListen,
    
47.                  sClient;
    ; s# O9 z( a! C3 W1 A; O. ^
48.    int          iAddrSize;
    9 V7 P( ~! A& _( U, q7 R
49.    HANDLE       hThread;
    
50.    DWORD        dwThreadId;
    
51.     struct sockaddr_in local,
    ) R; |* m. e" O, L
52.                       client;
    " Q1 I3 C( P' g- j4 a  G
53. 
    2 H" x4 H  {  `$ d$ @, x: P
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    ) F1 v$ x3 F# _; g. a
55.     {
    
56.        printf("Failed to load Winsock!\n");
    6 n+ L2 ^7 K0 V, y& b+ j
57.        return 1;
    # Q8 n5 s$ S; i! k& |( U$ g& \
58.     }
    
59.     // Create our listening socket
    3 E0 X' j! u0 e2 X* B) d
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    : u  C6 Y) L: J; y' s  a8 t7 u3 b
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    ' S0 g: g  K  Q3 X; ~
63.        printf("socket() failed: %d\n", WSAGetLastError());
    
64.        return 1;
    4 b/ R+ v% Z' ~
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    + H' ?: s* \0 ]! |! i7 b
69. 
    0 U5 X  A5 E; @! h
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    ( b) M6 X+ o: l2 Y% b# m' l
73.        printf("bind() failed: %d\n", WSAGetLastError());
    3 Q$ ~$ f# Z/ k6 D  ]
74.        return 1;
    + h$ ^! \/ K% T
75.     }
    / P' k. m/ i$ X$ @+ a* u
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.
      w% A+ k+ R1 C' _! t/ d
79.     while (1)
    
80.     {
    $ i. C$ ^  f( a* [1 r
81.        iAddrSize = sizeof(client);
    % X. l/ O- K% m1 R% c
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    0 `- I0 I3 r* W. g" U. H  y& k0 V7 w
87.            break;
    % v* i5 m- e0 _) v! |
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    6 X# M" i8 z# n$ V, Z5 o
91. 
    - C7 _% l0 _0 ~
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    ) `$ Q8 ?& s" y, @5 M
95.        {
    & `6 A6 ~4 Z2 Q* c: Q2 D0 ^# @: G
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    
98.        }
    4 `% Z% r) ^4 \, r: t2 p
99.        CloseHandle(hThread);
    * x) E, h# ?7 m' e
100.     }
     
101.    closesocket(sListen);
     4 o4 ]& l- V, h2 |% ^: ~
102.    
     
103.    WSACleanup();
     
104.     return 0;
     4 l0 i8 K4 ?$ W; i+ i7 \
105. }

复制代码

  q) [: f+ [' }# i  ^+ b5 W: t

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   # F7 r8 ^* \# B9 l* i& d' _& `
2. 
   ) ^4 t, j1 Z3 @2 P; m
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   $ ?/ \0 C( ^0 W+ c9 U# ~( {1 B/ _
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   ! o! F% F* p. U/ [# Q- [( {
5. 
   6 c# j7 P% P! U) F
6. Server：
   
7. #include <winsock2.h>
   ; I" U, w. C, M; }
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   ' I# u5 S- o) M. t7 W6 l1 w
10. #include <stdio.h>
    
11. void main()
    
12. {
    " h$ l/ u: b6 n& h
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    
15.     int err;
    
16. 
    , ~! u2 U: B1 [, L& f
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    
18.     //加载套接字库,如果失败返回
    $ r1 j" u3 ^- S. A) n
19.     err = WSAStartup(wVersionRequested, &wsaData);
    ' U( Y7 n# K8 o( g) \
20.     if (err != 0)
    
21.     {
    & O4 }8 s& E$ W' y
22.         return;
    1 y: m- T' N& e
23.     }
    
24. 
    9 Z: g8 P  ^2 ]3 C: q5 @2 v- E0 ]
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    + v( Q8 X+ j; j8 z: g! W0 ~  G
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
      @* q( ~: w- x3 |% U
27.          
    7 ^& ~" S# o0 t: r
28.         HIBYTE(wsaData.wVersion) != 2)
    % P9 w. R& W4 z  S4 ~# t% C0 e
29.          
    ) q$ i* d$ @0 A; b  a: L
30.     {
    ' P/ d! [  m9 e3 g: i* r' q3 r! v  |
31.         return;
    5 Q+ y6 _  s( A, ~
32.     }
    
33.      
    5 b$ q  D0 s9 x* w7 A0 ~$ r1 R
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    
38.          //Socket地址结构体的创建
    
39. 
    ; ?5 x7 T+ d) y1 `2 Y# ]% v
40.          SOCKADDR_IN addrSrv;
    
41. 
    1 {( Q# U6 O( Q0 ]8 ?( @
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);
    : _0 M' D/ r5 h9 @! v% W- `# q
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    ! g$ x, F; n% _
47.          //将套接字绑定到一个端口号和本地地址上
    ( d6 W# _! Y3 _7 \, w; _0 a; T
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    / s$ |8 x. Y  L, A
49. 
    
50.          listen(socSrv, 5);
    
51.          
      O* v% \- g6 b8 l, z
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    , ^% D( v, w8 w, m9 t5 S
53. 
    1 L& z; Y- r$ i  |) o
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    % i7 }  H+ A' @! N! |: p7 j
55. 
    
56.          //循环等待接受客户端发送请求
    
57. 
    , }! |3 j- X7 ?
58.          while (1)
    3 u) O  w( d& M1 u4 ^
59.          {
    ' w+ N8 P1 J# d
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    $ V' O* ~* G8 W' }
63.                    //此时程序在此发生阻塞
    
64. 
    ; z( I+ f; t4 o2 x5 b! Y- `$ [
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    
66. 
    
67.                    char sendBuf[100];
    8 S# \. I: O- Q& m7 ^* V  h
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    
70. 
    ) T+ O- O1 ^0 H2 P# D/ }
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    / M# a) o( X7 |3 ~" R
72. 
    # x( p+ q) e  p; I% K
73.                    //用返回的套接字和客户端进行通信
    
74. 
    ; |* ]" a$ R/ y4 S$ w
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    9 P% O$ T  x4 F4 Y7 n9 @* A
76. 
    
77.                    //接收数据
    
78. 
    ( v. i2 c- a$ A  D5 W; }
79.                    char recvBuf[100];
    ) _3 O4 K8 \7 b5 n( [: @5 l
80. 
    
81.                    recv(sockConn, recvBuf, 100, 0);
    
82. 
    
83.                    printf("%s\n", recvBuf);
    % K, H, `9 t6 ^* H, k
84.                    closesocket(sockConn);
    8 _: j4 {$ m0 g- s  N
85. 
    
86.          }
    
87. }
    
88. 
    1 a# E8 o+ l, C
89. 
    $ @3 F* A" C$ K3 y" f/ R* h
90. Client：
    
91. 
    - I1 E0 ^/ H+ B. g. E
92. #include <winsock2.H>
    9 ~  ~. Y: S9 ?& B; h
93. #pragma comment(lib, "Ws2_32.lib")
    . E  K; h$ \# K  H" W
94. #include <stdio.h>
    
95. #include <string.h>
    
96. 
    * R. H+ U+ Y) @# t: S
97. void main()
    
98. {   
    
99.     WORD wVersionRequested;
    
100.     WSADATA wsaData;
     
101.     int err;
     3 ?$ C5 _6 @! k2 }
102.      
     9 M2 G2 B0 s$ p% c) m% L
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     4 M( I9 B8 e& \- q2 x/ W
106.     if ( err != 0 ) {
     
107.          
     : r( z, d& F/ a5 |8 |3 l5 m
108.         return;
     , L6 `# G; |. \' r; V! O
109.     }
     
110.      
     ( b+ E! L- n* t( M5 @: f* V3 j. G# K
111.      
     , `% p- K3 X0 `& }* Y, A
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     " o; ?& Z/ Z, j4 Z2 ~3 R/ O
113.         HIBYTE( wsaData.wVersion ) != 2 )
     ! m* S/ d8 }0 X% {: ~, g
114.     {
     
115.          
     6 D7 z. p+ t  a8 t  m
116.         WSACleanup( );
     
117.         return;
     
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     . n8 R; @8 T/ D9 b; U* H. T
120.     SOCKADDR_IN addrSrv;
     
121.     addrSrv.sin_family = AF_INET;
     1 Z' i+ ~$ \, f9 A
122.     addrSrv.sin_port = htons(6000);
     
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     6 Y( x8 t4 v- G3 `- Q* y
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     3 i( s* l6 j$ l
128.     recv(socketClient, recvBuf, 256, 0);
     5 H+ v; J+ t7 l! ~6 ~
129.     printf("%s\n", recvBuf);
     
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     & N% F, \% f5 c$ a" Y2 K
131.     closesocket(socketClient);
     
132.     WSACleanup();
     
133.      
     
134. }

复制代码

  c3 T4 `0 {8 W' j+ ?