基于Win32的多线程客户/服务器通信

素颜马尾好姑娘i 2022-09-18 04:51 156阅读 0赞

客户端：

[![复制代码][copycode.gif]][copycode.gif 1]

![None.gif][] //  Client.cpp : Defines the entry point for the application.  
![None.gif][] //  
![None.gif][]  
![None.gif][]\#include  " stdafx.h "  
![None.gif][]\#include  " resource.h "  
![None.gif][]\#include <winsock.h>  
![None.gif][]  
![None.gif][] \#pragma warning(disable:4700)  
![None.gif][]  
![None.gif][] \#define MAX\_LOADSTRING 100  
![None.gif][]  
![None.gif][] //  Global Variables:   
![None.gif][]HINSTANCE hInst;                                 //  current instance   
![None.gif][]TCHAR szTitle\[MAX\_LOADSTRING\];                     //  The title bar text   
![None.gif][]TCHAR szWindowClass\[MAX\_LOADSTRING\];             //  The title bar text  
![None.gif][]  
![None.gif][] //  Foward declarations of functions included in this code module:   
![None.gif][]ATOM                MyRegisterClass(HINSTANCE hInstance);  
![None.gif][]BOOL                InitInstance(HINSTANCE,  int);  
![None.gif][]LRESULT CALLBACK    WndProc(HWND, UINT, WPARAM, LPARAM);  
![None.gif][]LRESULT CALLBACK    About(HWND, UINT, WPARAM, LPARAM);  
![None.gif][]  
![None.gif][] int APIENTRY WinMain(HINSTANCE hInstance,  
![None.gif][]                     HINSTANCE hPrevInstance,  
![None.gif][]                     LPSTR     lpCmdLine,  
![None.gif][]                      int       nCmdShow)  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]     //  TODO: Place code here.   
![InBlock.gif][]    MSG msg;  
![InBlock.gif][]    HACCEL hAccelTable;  
![InBlock.gif][]  
![InBlock.gif][]     //  Initialize global strings   
![InBlock.gif][]    LoadString(hInstance, IDS\_APP\_TITLE, szTitle, MAX\_LOADSTRING);  
![InBlock.gif][]    LoadString(hInstance, IDC\_CLIENT, szWindowClass, MAX\_LOADSTRING);  
![InBlock.gif][]    MyRegisterClass(hInstance);  
![InBlock.gif][]  
![InBlock.gif][]     //  Perform application initialization:   
![InBlock.gif][]     if (!InitInstance (hInstance, nCmdShow))   
![ExpandedSubBlockStart.gif][]     \{  
![InBlock.gif][]         return FALSE;  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]    hAccelTable = LoadAccelerators(hInstance, (LPCTSTR)IDC\_CLIENT);  
![InBlock.gif][]  
![InBlock.gif][]     //  Main message loop:   
![InBlock.gif][]     while (GetMessage(&msg, NULL,  0,  0))   
![ExpandedSubBlockStart.gif][]     \{  
![InBlock.gif][]         if (!TranslateAccelerator(msg.hwnd, hAccelTable, &msg))   
![ExpandedSubBlockStart.gif][]         \{  
![InBlock.gif][]            TranslateMessage(&msg);  
![InBlock.gif][]            DispatchMessage(&msg);  
![ExpandedSubBlockEnd.gif][]        \}  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]     return msg.wParam;  
![ExpandedBlockEnd.gif][]\}  
![None.gif][]  
![None.gif][]LRESULT CALLBACK WndProc(HWND hWnd, UINT message, WPARAM wParam, LPARAM lParam)  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]     int wmId, wmEvent;  
![InBlock.gif][]    PAINTSTRUCT ps;  
![InBlock.gif][]    HDC hdc;  
![InBlock.gif][]    TCHAR szHello\[MAX\_LOADSTRING\];  
![InBlock.gif][]    LoadString(hInst, IDS\_HELLO, szHello, MAX\_LOADSTRING);  
![InBlock.gif][]  
![InBlock.gif][]    WORD version;     // used to store the socket version   
![InBlock.gif][]    WSADATA wsaData;     // used to store info about socket   
![InBlock.gif][]    SOCKET theSocket;     // used to create client socket   
![InBlock.gif][]    SOCKADDR\_IN serverInfo;     // used to specify a local or remote endpoint address to which to connect a socket   
![InBlock.gif][]     int rVal;     // used to store return value   
![InBlock.gif][]    LPHOSTENT hostEntry;     // Windows Sockets allocates this structure   
![InBlock.gif][]     char \*buf =  " Data On Socket ";     // Data to be send on socket   
![InBlock.gif][]  
![InBlock.gif][]     char data\[ 5\];  
![InBlock.gif][]     switch (message)   
![ExpandedSubBlockStart.gif][]     \{  
![InBlock.gif][]     case WM\_COMMAND:  
![InBlock.gif][]        wmId    = LOWORD(wParam);   
![InBlock.gif][]        wmEvent = HIWORD(wParam);   
![InBlock.gif][]         //  Parse the menu selections:   
![InBlock.gif][]         switch (wmId)  
![ExpandedSubBlockStart.gif][]         \{  
![InBlock.gif][]         case IDM\_ABOUT:  
![InBlock.gif][]            DialogBox(hInst, (LPCTSTR)IDD\_ABOUTBOX, hWnd, (DLGPROC)About);  
![InBlock.gif][]             break;  
![InBlock.gif][]         case IDM\_EXIT:  
![InBlock.gif][]            DestroyWindow(hWnd);  
![InBlock.gif][]             break;  
![InBlock.gif][]         case IDM\_COMMUNICATE:  
![InBlock.gif][]             // get the version of socket   
![InBlock.gif][]            version = MAKEWORD( 1, 1);  
![InBlock.gif][]             // The Windows Sockets WSAStartup function initiates use of WS2\_32.DLL by a process   
![InBlock.gif][]            rVal = WSAStartup(version,(LPWSADATA)&wsaData);  
![InBlock.gif][]             // store information about the server  
![InBlock.gif][]             // Here we are suppose to pass the server information to the client,  
![InBlock.gif][]             // so that the client knows where is the server  
![InBlock.gif][]             // I am using the machine name on wich my server.exe is running   
![InBlock.gif][]            hostEntry = gethostbyname( " seclore3 ");  
![InBlock.gif][]             if(!hostEntry)  
![ExpandedSubBlockStart.gif][]             \{  
![InBlock.gif][]                MessageBox(hWnd, " Failed in gethostbyname API ", " Gethostbyname Error ",MB\_OK);  
![InBlock.gif][]                WSACleanup();  
![InBlock.gif][]                 break;  
![ExpandedSubBlockEnd.gif][]            \}  
![InBlock.gif][]             // here we are creating the socket   
![InBlock.gif][]            theSocket = socket(PF\_INET, SOCK\_STREAM, IPPROTO\_TCP);  
![InBlock.gif][]             if(theSocket == SOCKET\_ERROR)  
![ExpandedSubBlockStart.gif][]             \{  
![InBlock.gif][]                MessageBox(hWnd, " Failed in socket API ", " Socket Error ",MB\_OK);  
![ExpandedSubBlockEnd.gif][]            \}  
![InBlock.gif][]             // Fill in the sockaddr\_in struct   
![InBlock.gif][]            serverInfo.sin\_family = PF\_INET;  
![InBlock.gif][]            serverInfo.sin\_addr = \*((LPIN\_ADDR)\*hostEntry->h\_addr\_list);  
![InBlock.gif][]            serverInfo.sin\_port = htons( 8888);  
![InBlock.gif][]             // Connect to the socket we just created                   
![InBlock.gif][]            rVal=connect(theSocket,(LPSOCKADDR)&serverInfo,  sizeof(serverInfo));  
![InBlock.gif][]             if(rVal==SOCKET\_ERROR)  
![ExpandedSubBlockStart.gif][]             \{  
![InBlock.gif][]                MessageBox(hWnd, " Failed in connect API ", " Connect Error ",MB\_OK);  
![InBlock.gif][]                 break;  
![ExpandedSubBlockEnd.gif][]            \}  
![InBlock.gif][]             // Send the data to the server   
![InBlock.gif][]            rVal = send(theSocket, buf, strlen(buf),  0);  
![InBlock.gif][]             if(rVal == SOCKET\_ERROR)  
![ExpandedSubBlockStart.gif][]             \{  
![InBlock.gif][]                MessageBox(hWnd, " Failed send ", " Send Error ",MB\_OK);  
![ExpandedSubBlockEnd.gif][]            \}  
![InBlock.gif][]             // Get/Recieve the data sent by the server   
![InBlock.gif][]            rVal = recv(theSocket,data, 5, 0);  
![InBlock.gif][]             if(rVal)  
![ExpandedSubBlockStart.gif][]             \{  
![InBlock.gif][]                MessageBox(hWnd,data, " Data from server ",MB\_OK);  
![ExpandedSubBlockEnd.gif][]            \}  
![InBlock.gif][]             break;  
![InBlock.gif][]         default:  
![InBlock.gif][]             return DefWindowProc(hWnd, message, wParam, lParam);  
![ExpandedSubBlockEnd.gif][]        \}  
![InBlock.gif][]         break;  
![InBlock.gif][]     case WM\_PAINT:  
![InBlock.gif][]        hdc = BeginPaint(hWnd, &ps);  
![InBlock.gif][]         //  TODO: Add any drawing code here![dot.gif][]   
![InBlock.gif][]        RECT rt;  
![InBlock.gif][]        GetClientRect(hWnd, &rt);  
![InBlock.gif][]        DrawText(hdc, szHello, strlen(szHello), &rt, DT\_CENTER);  
![InBlock.gif][]        EndPaint(hWnd, &ps);  
![InBlock.gif][]         break;  
![InBlock.gif][]     case WM\_DESTROY:  
![InBlock.gif][]         // Close the socket   
![InBlock.gif][]        closesocket(theSocket);  
![InBlock.gif][]         // The WSACleanup function initiates no action    
![InBlock.gif][]        WSACleanup();  
![InBlock.gif][]        PostQuitMessage( 0);  
![InBlock.gif][]         break;  
![InBlock.gif][]     default:  
![InBlock.gif][]         return DefWindowProc(hWnd, message, wParam, lParam);  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]     return  0;  
![ExpandedBlockEnd.gif][]\}  
![None.gif][]

[![复制代码][copycode.gif]][copycode.gif 1]

服务器端：

[![复制代码][copycode.gif]][copycode.gif 1]

![None.gif][] //  Server.cpp : Defines the entry point for the application.  
![None.gif][] //  
![None.gif][]  
![None.gif][]\#include  " stdafx.h "  
![None.gif][]\#include  " resource.h "  
![None.gif][]\#include <winsock.h>  
![None.gif][]  
![None.gif][] // function declaration   
![None.gif][]DWORD WINAPI ValidateData(LPVOID Parameter);  
![None.gif][]  
![None.gif][] int APIENTRY WinMain(HINSTANCE hInstance,  
![None.gif][]                     HINSTANCE hPrevInstance,  
![None.gif][]                     LPSTR     lpCmdLine,  
![None.gif][]                      int       nCmdShow)  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]    WORD sockVersion;     // Used to store socket version information   
![InBlock.gif][]    WSADATA wsaData;     // used to store info about socket   
![InBlock.gif][]    SOCKET s,client;     // used to create client and server socket   
![InBlock.gif][]    SOCKADDR\_IN sin;     // used to specify a local or remote endpoint address to which to connect a socket   
![InBlock.gif][]     int rVal;     // used to store return value   
![InBlock.gif][]  
![InBlock.gif][]    HANDLE hThread;     // Handle to thread   
![InBlock.gif][]    DWORD ThreadId;     // used to store the thread id  
![InBlock.gif][]  
![InBlock.gif][]     // Get the current socket version   
![InBlock.gif][]    sockVersion = MAKEWORD( 1, 1);  
![InBlock.gif][]     // 初始化Socket库  
![InBlock.gif][]     // The Windows Sockets WSAStartup function initiates use of WS2\_32.DLL by a process   
![InBlock.gif][]    WSAStartup(sockVersion, &wsaData);  
![InBlock.gif][]     // here we are creating the socket   
![InBlock.gif][]    s = socket(PF\_INET, SOCK\_STREAM, IPPROTO\_TCP);  
![InBlock.gif][]     if(s == INVALID\_SOCKET)  
![ExpandedSubBlockStart.gif][]     \{  
![InBlock.gif][]        MessageBox( 0, " Invalid socket ", " Socket Error ",MB\_OK);  
![InBlock.gif][]        WSACleanup();  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]     // fill in sockaddr\_in struct    
![InBlock.gif][]    sin.sin\_family = PF\_INET;  
![InBlock.gif][]    sin.sin\_port = htons( 8888); // 监听端口为   
![InBlock.gif][]    sin.sin\_addr.s\_addr = INADDR\_ANY;  
![InBlock.gif][]  
![InBlock.gif][]     // bind to the socket   
![InBlock.gif][]    rVal = bind(s, (LPSOCKADDR)&sin,  sizeof(sin));  
![InBlock.gif][]     if(rVal == SOCKET\_ERROR)  
![ExpandedSubBlockStart.gif][]     \{  
![InBlock.gif][]        MessageBox( 0, " Failed in bind API ", " Bind Error ",MB\_OK);  
![InBlock.gif][]        WSACleanup();  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]  
![InBlock.gif][]     // Listen to the desire port on which client suppose to connect   
![InBlock.gif][]    rVal = listen(s,  2); // 最大客户数目为   
![InBlock.gif][]     if(rVal == SOCKET\_ERROR)  
![ExpandedSubBlockStart.gif][]     \{  
![InBlock.gif][]        MessageBox( 0, " Failed in listen API ", " Listen Error ",MB\_OK);  
![InBlock.gif][]        WSACleanup();  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]     // infinite loop to serve all the clients which want service   
![InBlock.gif][]     while( 1)  
![ExpandedSubBlockStart.gif][]     \{  
![InBlock.gif][]         // Accept the data from the client   
![InBlock.gif][]        client = accept(s, NULL, NULL); // 接受来自客户端的连接  
![InBlock.gif][]  
![InBlock.gif][]         // Once the new client come up create a new thread t serve the client   
![InBlock.gif][]         if(client)  
![ExpandedSubBlockStart.gif][]         \{  // 创建线程去处理此请求,将此连接作为参数传给处理线程   
![InBlock.gif][]            hThread = CreateThread(NULL,  
![InBlock.gif][]                 0,  
![InBlock.gif][]                ValidateData,  
![InBlock.gif][]                (LPVOID)client,  
![InBlock.gif][]                 0,  
![InBlock.gif][]                &ThreadId);  
![ExpandedSubBlockEnd.gif][]        \}  
![InBlock.gif][]         else  
![InBlock.gif][]             return  0;  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]     return  0;  
![ExpandedBlockEnd.gif][]\}  
![None.gif][]  
![None.gif][]DWORD WINAPI ValidateData(LPVOID Parameter)  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]     // Get the information about client entity   
![InBlock.gif][]    SOCKET client = (SOCKET)Parameter;  
![InBlock.gif][]     int rVal;     // Return val  
![InBlock.gif][]     // 数据缓冲区   
![InBlock.gif][]     char buf\[ 11\];     // used to send the validated data to client  
![InBlock.gif][]  
![InBlock.gif][]     // Get the data form client  
![InBlock.gif][]     // 接收数据   
![InBlock.gif][]    rVal = recv(client,buf, 11, 0);  
![InBlock.gif][]     // here we are performing simple check, the data came form client  
![InBlock.gif][]     // is valid or not  
![InBlock.gif][]     // at this point you can check your own data also, which needs some modification  
![InBlock.gif][]     // 回传数据给客户端   
![InBlock.gif][]     if(strcmp(buf, " Data On Socket "))  
![ExpandedSubBlockStart.gif][]     \{  
![InBlock.gif][]         // Send back the data to the client   
![InBlock.gif][]        rVal = send(client, " YES ", 3, 0);  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]     else  
![ExpandedSubBlockStart.gif][]     \{  
![InBlock.gif][]         // Send back the data to the client   
![InBlock.gif][]        rVal = send(client, " NO ", 2, 0);  
![ExpandedSubBlockEnd.gif][]    \}  
![InBlock.gif][]     return  0;  
![ExpandedBlockEnd.gif][]\}  
![None.gif][]

[![复制代码][copycode.gif]][copycode.gif 1]

[copycode.gif]: http://common.cnblogs.com/images/copycode.gif
[copycode.gif 1]: /images/20220828/cc36269c8df34fefb1f16e7f52f527ad.png
[None.gif]: /images/20220828/d10a846278a247d6b00c3da3ad17eb36.png
[ExpandedBlockStart.gif]: /images/20220828/bca51fc97c584c47a0b773d35ffdada9.png
[InBlock.gif]: /images/20220828/60e97309e4124553a8bb3fe0c3a97d1b.png
[ExpandedSubBlockStart.gif]: /images/20220828/02e0fe42d8504dd49ab7a2bc35196c72.png
[ExpandedSubBlockEnd.gif]: /images/20220828/de0394fceb5b43209ae4443858154653.png
[ExpandedBlockEnd.gif]: /images/20220828/1f1bc109092c420384f8cbd4c358bec8.png
[dot.gif]: /images/20220828/220f4cea51cd4b9b851a744f32718ede.png