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

admin

程序很简单，windows环境下的，客户端和服务器程序都在本机运行，在客户端输入发送给服务器的字符串，服务器收到字符串后会打印出来，同时与"abc"比较，与"abc"相同就会返给客户端，输入的是正确的，不同会告诉客户端输入时错误的。
0 z7 }8 a* D3 o$ Q1 _9 d' r8 _客户端程序：client.cpp
) m3 q2 }/ v, {4 i3 @

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   8 {  q% w+ V4 ~4 g
4. 
   
5. #define DEFAULT_PORT       5150
   5 o7 Z- @; X9 r! h/ v4 s
6. #define DEFAULT_BUFFER     2048
   
7. 
   
8. char  szServer[128],
   6 v+ K& r/ |7 W  n
9.      szMessage[1024];
   ; P& p- c5 A4 H; S/ X! M" y% \5 N
10. int  iPort    = DEFAULT_PORT;
    4 k- Y8 k2 N# @) k! F2 ?
11. 
    9 ?/ @1 S% {/ d7 G% y
12. int main()
      ~& c& x" |8 {7 ~5 z$ R6 M
13. {
    4 D% j. L0 A4 k4 a! A1 S+ n. Q( O
14.    WSADATA      wsd;
    
15.    SOCKET       sClient;
    & D: O5 D6 v7 Q4 J+ _" k
16.    char         szBuffer[DEFAULT_BUFFER];
    
17.    int          ret;
    + G! p7 Q+ @+ W/ {7 S/ h
18.     struct sockaddr_in server;
    
19.     struct hostent    *host = NULL;
    
20.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
21.     {
    # g5 [: N0 r4 s/ Z6 ^
22.        printf("Failed to load Winsock library!\n");
    7 D- ?: |" P! H" ~- J
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
    0 P  \' v( R# b! d
28.     sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
29.     if (sClient == INVALID_SOCKET)
    - w0 D0 C) e2 O$ y; _
30.     {
    4 g5 P! x4 o) D* ^% h0 p% B
31.        printf("socket() failed: %d\n", WSAGetLastError());
    9 z. }. n# a+ n8 J5 j8 G
32.        return 1;
    
33.     }
      |7 R3 v' j- Q( [; f
34.    server.sin_family = AF_INET;
    8 j5 M: ?! p! a4 B
35.    server.sin_port = htons(iPort);
    
36.    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    
37. 
    
38.     if (connect(sClient, (struct sockaddr *)&server,
    ) r+ B4 C5 W2 X4 H- f; O9 ]0 K
39.        sizeof(server)) == SOCKET_ERROR)
    % ^# V5 Y0 b7 i
40.     {
    
41.        printf("connect() failed: %d\n", WSAGetLastError());
    ( Q- p7 o3 B# ]# C$ r
42.        return 1;
    - y4 v3 b+ s! ]; g
43.     }
    
44.     // Send and receive data
    + g) }4 d3 W# o' Q  g1 S
45.     ret = send(sClient, szMessage, strlen(szMessage), 0);
      o; `# @, w$ ]! U/ J$ }
46.     if (ret == SOCKET_ERROR)
      }0 L. ?- t4 z5 @# D
47.     {
    
48.        printf("send() failed: %d\n", WSAGetLastError());
    
49.     }
    
50.     else{
    ) p7 p9 F; @/ D  [! ?8 f; y7 g
51.        printf("Send '%s' \n", szMessage);
    
52.        ret = recv(sClient, szBuffer, DEFAULT_BUFFER, 0);
    
53.        if (ret == SOCKET_ERROR){
    5 }* [: _3 F: b  {8 P
54.          printf("recv() failed: %d\n", WSAGetLastError());
    ) T. s' v" X1 i- R- `$ o
55.        }
    ' S% v% s( O. i# w
56.        else{
    ) k7 j7 d! r/ ~. g1 x
57.          szBuffer[ret] = '\0';
    ; X# I; z( h3 ]
58.          printf("RECV: '%s'\n",szBuffer);
    1 J: }/ _6 f+ B6 `, M
59.        }
    
60.     }
    
61.    closesocket(sClient);
    
62. 
    
63.    WSACleanup();
    
64.     return 0;
    8 X1 y. p7 I% M
65. }

复制代码

服务器程序:server.cpp

1. #include <winsock2.h>
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   5 L1 G5 e  N' S9 U3 ?
4. 
   - Y: J5 x# Z7 T( ?6 j% a
5. #define DEFAULT_PORT       5150
   ' \9 N7 f, L# c( g+ A% [
6. #define DEFAULT_BUFFER     4096
   # B; t4 w# s2 G. g
7. 
   
8. int   iPort     = DEFAULT_PORT;
   & l  |( Y2 w$ R8 m4 l
9. char   szAddress[128];
   ) m  h0 B7 ?5 q# J/ E
10. 
    
11. DWORD WINAPI ClientThread(LPVOID lpParam)
    
12. {
    
13.    SOCKET       sock=(SOCKET)lpParam;
    6 R! U9 \$ j9 H, P1 e. r
14.    char         szBuff[DEFAULT_BUFFER];
    8 _& {2 s* e8 o4 A: A$ n
15.    int          ret;
    
16. 
    
17.    while(1)
    
18.     {
    + Q2 a! ?4 Q1 f- r) y6 x9 C
19.        ret = recv(sock, szBuff, DEFAULT_BUFFER, 0);
    
20.        if (ret == 0)
    
21.            break;
    6 e; v6 w1 i' i/ @; w# o
22.        else if (ret == SOCKET_ERROR)
      b, h/ f  C$ e9 e* f  g0 ?4 J7 e; C- F
23.        {
    0 |/ p' `0 a8 a# n, I2 O
24.            printf("recv() failed: %d\n", WSAGetLastError());
    ! n+ y) ]0 V8 x% i: I
25.            break;
    
26.        }
    
27.        szBuff[ret] = '\0';
    / Q( k7 j9 e$ r8 B
28.        printf("RECV: '%s'\n", szBuff);
    
29.       if(strcmp(szBuff,"abc")==0){
    
30.          memcpy(szBuff,"Send the correct string!",25);
    
31.        }
    6 [- O/ }2 ~/ `' c9 }5 ]
32.        else{
    
33.          memcpy(szBuff,"Send the wrong string!",23);
    6 B) s. ~; Y4 }& J
34.        }
    
35.        ret = send(sock, szBuff, strlen(szBuff), 0);
    - b  B+ x- x6 \9 r4 {5 N/ |* b2 C# B
36.        if (ret == SOCKET_ERROR){
    
37.          printf("send() failed: %d\n", WSAGetLastError());
    
38.        }
    
39.     }
    ; g0 I4 I  v, b
40.     return 0;
    8 }0 Q: {2 {4 p+ j/ y! T: Z: d+ H
41. }
    
42. 
    . _: `) t3 i7 t' `. U9 s2 ?
43. int main()
    
44. {
    ) V1 h5 a- Y* r6 _: {3 i" i
45.    WSADATA      wsd;
    
46.    SOCKET       sListen,
    
47.                  sClient;
    
48.    int          iAddrSize;
    
49.    HANDLE       hThread;
    0 m+ ]1 a/ \; g  D& i6 }
50.    DWORD        dwThreadId;
    ! I/ d1 |1 S9 {! O& r: e
51.     struct sockaddr_in local,
    5 I1 ]- b3 X: |; b$ s& K' j
52.                       client;
    & O7 P% _1 I3 ~6 Z2 U
53. 
    - G: V' V( L( L
54.     if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)
    
55.     {
    
56.        printf("Failed to load Winsock!\n");
    8 v, G5 y( }* ^2 V* u5 u9 `
57.        return 1;
    
58.     }
    - |; i6 D6 _6 |
59.     // Create our listening socket
    
60.     sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
    ! r: q1 W* B9 i! p! l) D2 q
61.     if (sListen == SOCKET_ERROR)
    
62.     {
    4 g1 X2 t0 K+ P  P& T
63.        printf("socket() failed: %d\n", WSAGetLastError());
    2 v: N9 V' c2 g8 I. m% G
64.        return 1;
    
65.     }
    
66.    local.sin_addr.s_addr = htonl(INADDR_ANY);
    $ I! m9 @2 Z' N* w
67.    local.sin_family = AF_INET;
    
68.    local.sin_port = htons(iPort);
    ; ~! [6 O6 O0 x
69. 
    ' s* ~% D+ O7 A$ j% @  b% t5 e' z
70.     if (bind(sListen, (struct sockaddr *)&local,
    
71.            sizeof(local)) == SOCKET_ERROR)
    
72.     {
    
73.        printf("bind() failed: %d\n", WSAGetLastError());
    
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)
    + T& d# A$ M% f
80.     {
    
81.        iAddrSize = sizeof(client);
    - }7 W/ M4 B1 R& Q9 d( g1 F% v2 L
82.        sClient = accept(sListen, (struct sockaddr *)&client,
    
83.                        &iAddrSize);      
    1 C) h' i! A: I( ~0 N! b# F+ [; |5 T
84.        if (sClient == INVALID_SOCKET)
    
85.        {      
    
86.            printf("accept() failed: %d\n", WSAGetLastError());
    ; F% U, ]7 o( K0 q1 E
87.            break;
    7 Y: N$ q' ~( `; C8 `& i% `% V
88.        }
    
89.        printf("Accepted client: %s:%d\n",
    
90.            inet_ntoa(client.sin_addr), ntohs(client.sin_port));
    
91. 
    * F0 G' I& |3 _
92.        hThread = CreateThread(NULL, 0, ClientThread,
    
93.                    (LPVOID)sClient, 0, &dwThreadId);
    
94.        if (hThread == NULL)
    
95.        {
    7 X, |/ G- P8 V# u0 [
96.            printf("CreateThread() failed: %d\n", GetLastError());
    
97.            break;
    8 v' C  b* p8 |+ P
98.        }
    
99.        CloseHandle(hThread);
    
100.     }
     9 Z" |0 n# L" x# ~8 f
101.    closesocket(sListen);
     
102.    
     
103.    WSACleanup();
     
104.     return 0;
     ) j8 D  h. _. V, m2 |: ^3 o
105. }

复制代码

9 H" e1 f& q$ M. H! }


% ?, w3 u) o& C5 r5 Y& g
4 F3 r8 Z8 W/ @  X& Z* H

admin

1. 作为服务器，你要绑定【bind】到本地的IP地址上进行监听【listen】，但是你的机器上可能有多块网卡，也就有多个IP地址，这时候你要选择绑定在哪个IP上面，如果指定为INADDR_ANY，那么系统将绑定默认的网卡【即IP地址】。
   " t$ d! a) W2 W5 F
2. 
   8 m7 e' ~1 y* @+ ^  B- L( c9 ?4 _
3. 作为客户端，你要连接【connect】到远端的服务器，也是要指定远端服务器的（ip, port）对。
   
4. 当然，在这种情况下，不可能将IP地址指定为INADDR_ANY，系统会疯掉的。
   
5. 
   3 d2 n0 \$ A: r
6. Server：
   4 o8 X' H! D0 U9 \4 `8 N
7. #include <winsock2.h>
   3 J: z; L7 B0 E. f$ d& e
8. #pragma comment(lib, "WS2_32.lib")
   
9. 
   
10. #include <stdio.h>
    
11. void main()
    
12. {
    : n; b1 s. u2 Q. M0 i7 Q
13.     WORD wVersionRequested;//版本号
    
14.     WSADATA wsaData;
    . ^0 L% }% L9 c4 p) T1 {
15.     int err;
    
16. 
    
17.     wVersionRequested = MAKEWORD(2, 2);//2.2版本的套接字
    + c* X8 }& S/ H$ h2 j3 r( t: M: D
18.     //加载套接字库,如果失败返回
    . j5 p: m$ Z) o! l
19.     err = WSAStartup(wVersionRequested, &wsaData);
    
20.     if (err != 0)
    
21.     {
    + v. R2 M% O4 G+ J( \0 j" O
22.         return;
    ) H7 z' @, g' t3 e, o( N/ L: ~  V
23.     }
    ' `+ V% [% _+ j
24. 
    
25.     //判断高低字节是不是2,如果不是2.2的版本则退出
    
26.     if (LOBYTE(wsaData.wVersion) != 2 ||
    6 s" H! m) u2 e$ ?9 t
27.          
    
28.         HIBYTE(wsaData.wVersion) != 2)
    3 y. e- G; ~4 q+ S8 N% A, H* S5 Y- @
29.          
    
30.     {
    % L' c0 |$ v7 b) V% [
31.         return;
    
32.     }
    
33.      
    $ s- b8 x% B" e6 B9 n! ~# N1 G
34.          //创建流式套接字,基于TCP(SOCK_STREAM)
    
35. 
    
36.          SOCKET socSrv = socket(AF_INET, SOCK_STREAM, 0);
    
37. 
    + S4 a8 t0 }; L7 g2 d2 B1 t# s, d
38.          //Socket地址结构体的创建
    % ?4 _4 x  O" V" [
39. 
    / j% A7 V: X" x
40.          SOCKADDR_IN addrSrv;
    
41. 
    
42.          addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//转换Unsigned long型为网络字节序格
    6 v. I+ K' Z5 ?5 [5 \* m' F
43.          addrSrv.sin_family = AF_INET;//指定地址簇
    
44.          addrSrv.sin_port = htons(6000);
    # j: X3 ~& J( B, x) u2 T
45.         //指定端口号,除sin_family参数外,其它参数都是网络字节序,因此需要转换
    
46. 
    
47.          //将套接字绑定到一个端口号和本地地址上
    
48.          bind(socSrv, (SOCKADDR*)&addrSrv, sizeof(SOCKADDR));//必须用sizeof，strlen不行
    ' p" g5 B4 ^: ^6 m/ }
49. 
    
50.          listen(socSrv, 5);
    
51.          
    
52.          SOCKADDR_IN addrClient;//字义用来接收客户端Socket的结构体
    ! T* ^: P2 C6 F. C5 d
53. 
    : C5 a! s$ E- @! R6 k; k3 b4 M
54.          int len = sizeof(SOCKADDR);//初始化参数,这个参数必须进行初始化，sizeof
    
55. 
    " X8 d% z& v) a% Y4 G
56.          //循环等待接受客户端发送请求
    5 ^! o. I, i$ o. u, Z# Y1 v) F
57. 
    
58.          while (1)
    ) V( c- E; T5 [, o& Z' X
59.          {
    & Q; Z9 G& w/ H+ `1 f, u4 @7 p; f" J
60.                    //等待客户请求到来；当请求到来后，接受连接请求，
    ! a  p2 u) Q- i- A  p- g6 Y4 T3 w
61. 
    
62.                    //返回一个新的对应于此次连接的套接字（accept）。
    9 y5 w$ s: y' Q. R
63.                    //此时程序在此发生阻塞
    6 h  N- \( l2 T
64. 
    - ?1 r3 d! Z7 K. u- D& k
65.                    SOCKET sockConn = accept(socSrv, (SOCKADDR*)&addrClient, &len);
    ! ?  k6 \$ I& u* i! K
66. 
    
67.                    char sendBuf[100];
    
68. 
    
69.                    sprintf(sendBuf, "Welcome %s to JoyChou",
    1 O( S1 C4 o6 H1 O
70. 
    
71.                             inet_ntoa(addrClient.sin_addr));//格式化输出
    
72. 
    
73.                    //用返回的套接字和客户端进行通信
    
74. 
    
75.                    send(sockConn, sendBuf, strlen(sendBuf)+1, 0);//多发送一个字节
    
76. 
    
77.                    //接收数据
    
78. 
    - I2 i# k3 |$ M& V7 k- l) \& k
79.                    char recvBuf[100];
    
80. 
    " |+ h$ A9 L5 U; [: Z
81.                    recv(sockConn, recvBuf, 100, 0);
      ~& t% W& ^5 p, i' X& B
82. 
    0 F/ x8 C4 u3 H) A# {8 P4 F" n
83.                    printf("%s\n", recvBuf);
    
84.                    closesocket(sockConn);
    
85. 
    
86.          }
    
87. }
    
88. 
    
89. 
    3 \1 I, l/ P7 U; {1 W
90. Client：
    ; m8 h3 h! k  O5 F0 q! v
91. 
    
92. #include <winsock2.H>
    9 Y, x+ p; d0 ^6 F5 m5 m
93. #pragma comment(lib, "Ws2_32.lib")
    & @% Y; q: y0 ^( y0 _' l
94. #include <stdio.h>
    
95. #include <string.h>
    
96. 
    
97. void main()
    1 w1 ]0 l* ~7 ]% F& d; H4 O
98. {   
    ; z. |+ u! d; n+ a# X& \. `% y& h
99.     WORD wVersionRequested;
    8 {" v9 H+ C9 {4 u- c) a+ L$ F# l
100.     WSADATA wsaData;
     
101.     int err;
     
102.      
     
103.     wVersionRequested = MAKEWORD( 2, 2 );
     
104.      
     
105.     err = WSAStartup( wVersionRequested, &wsaData );
     , J/ G  r7 @$ T1 a, J. b4 Z
106.     if ( err != 0 ) {
     ! C9 L5 Z" U# @3 ~$ a
107.          
     
108.         return;
     
109.     }
     
110.      
     
111.      
     ; |, }$ l4 Y% F
112.     if ( LOBYTE( wsaData.wVersion ) != 2 ||
     + S! j. P6 k7 i3 [" e$ [6 g
113.         HIBYTE( wsaData.wVersion ) != 2 )
     
114.     {
     ' K& x+ p$ c# q: p$ L
115.          
     
116.         WSACleanup( );
     7 b( ]+ G- z8 `1 B1 R6 e
117.         return;
     
118.     }
     
119.     SOCKET socketClient = socket(AF_INET, SOCK_STREAM, 0);
     
120.     SOCKADDR_IN addrSrv;
     ! X0 \+ B8 P6 g; L; d
121.     addrSrv.sin_family = AF_INET;
     
122.     addrSrv.sin_port = htons(6000);
     ! g* M/ j& n0 h0 g
123.     addrSrv.sin_addr.S_un.S_addr = inet_addr("192.168.1.101");//服务器端的IP地址
     
124.      
     
125.     connect(socketClient, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
     4 Y( f) w/ f: J
126.     char recvBuf[256];
     
127.     char sendBuf[] = "This is Joychou";
     
128.     recv(socketClient, recvBuf, 256, 0);
     
129.     printf("%s\n", recvBuf);
     7 s; R- i3 u0 v) L9 Y3 ~
130.     send(socketClient, sendBuf, strlen(sendBuf) + 1, 0);
     1 r4 F  L0 s! E6 t+ I5 l% ?2 X% q
131.     closesocket(socketClient);
     
132.     WSACleanup();
     2 i( ]% o8 S* U
133.      
     & H) |0 D! _" X' B2 ^" |% a
134. }

复制代码

8 X- w. r9 O, K8 L9 D/ ?1 G
2 T" N8 ]% c+ r1 a  {