C++ TCP winsock 多线程编程

// Thread.cpp : 定义控制台应用程序的入口点。
//
  
#include "stdafx.h"
#include <stdio.h>
#include <stdlib.h>
#include <winsock2.h>
#include <iostream>
#pragma comment(lib, "ws2_32.lib")
using namespace std;
  
  
#define PORT 4000
#define IP_ADDRESS "127.0.0.1"
  
//创建线程
DWORD WINAPI ClientThread (LPVOID ipParameter)
{
    SOCKET ClientScoket  = (SOCKET)ipParameter;
    int RET =  0;
    char RecvBuffer[MAX_PATH];
    //初始化 recvBuffer
    while(true){
    memset(RecvBuffer,0x00,sizeof(RecvBuffer));
    RET  =  recv(ClientScoket,RecvBuffer,MAX_PATH,0);
    if(RET == 0||RET == SOCKET_ERROR)
    {
        cout<<"failed,exit"<<endl;
        break;
    }
    cout<<"接受的消息为"<<RecvBuffer<<endl;
    }
  
    return 0;  
}
int main(void)
{
    WSADATA     WSA;
    SOCKET      severScoket,clientScoket;
    struct      sockaddr_in  LocalAddr,clientAddr;
    int         AddrLen =  0;
    HANDLE      hThread =  NULL;
    int         RET = 0;
    //init windows socket
    if (WSAStartup(MAKEWORD(2,2),&WSA)!= 0 )
    {
        cout<<"init failed"<<endl;
        return -1;
    }
    //creat socket
    severScoket = socket(AF_INET,SOCK_STREAM,0);
    if(severScoket == INVALID_SOCKET)
    {
      cout<<"creat failed"<<GetLastError()<<endl;
      return -1;
    }
    LocalAddr.sin_family = AF_INET;
    LocalAddr.sin_addr.s_addr = inet_addr(IP_ADDRESS);
    LocalAddr.sin_port = htons(PORT);
    memset(LocalAddr.sin_zero,0x00,8);
    //bind socket
    RET = bind(severScoket,(struct sockaddr*)&LocalAddr,sizeof(LocalAddr));
    if (RET != 0)
    {
        cout<<"bind failed";
        return -1;
    }
    RET = listen(severScoket,5);
    if (RET!= 0)
    {
        cout<<"listen failed";
        return -1;
    }
    cout<<"服务器已启动"<<endl;
    while(true)
    {
       AddrLen = sizeof(clientAddr);
       clientScoket = accept(severScoket,(struct sockaddr*)&clientAddr,&AddrLen);
       if (clientScoket ==INVALID_SOCKET)
       {
           cout<<"accept failed";
           break;
       }
       cout<<"客户端连接"<<inet_ntoa(clientAddr.sin_addr)<<"."<<clientAddr.sin_port<<endl;
       hThread  = CreateThread(NULL,0,ClientThread,(LPVOID)clientScoket,0,NULL);
       if(hThread == NULL)
       {
           cout<<"creat thread failed"<<endl;
           break;
       }
       CloseHandle(hThread);
    }
    closesocket(severScoket);
    closesocket(clientScoket);
    WSACleanup();
    return 0;
}
  

// Client.cpp : 定义控制台应用程序的入口点。

#include "stdafx.h"
#include <stdio.h>
#include <stdlib.h>
#include <winsock2.h>
#include <iostream>
#pragma comment(lib, "ws2_32.lib")
using namespace std;
  
  
#define PORT 4000
#define IP_ADDRESS "127.0.0.1"
int main(void)
{
    WSADATA     WSA;
    SOCKET      clientScoket;
    struct      sockaddr_in  serveAddr;
    int         AddrLen =  0;
    HANDLE      hThread =  NULL;
    int         RET = 0;
    char        SendBuffer[MAX_PATH];
    //init windows socket
    if (WSAStartup(MAKEWORD(2,2),&WSA)!= 0 )
    {
        cout<<"init failed"<<endl;
        return -1;
    }
    //creat socket
    clientScoket = socket(AF_INET,SOCK_STREAM,0);
    if(clientScoket == INVALID_SOCKET)
    {
        cout<<"creat failed"<<GetLastError()<<endl;
        return -1;
    }
    serveAddr.sin_family = AF_INET;
    serveAddr.sin_addr.s_addr = inet_addr(IP_ADDRESS);
    serveAddr.sin_port = htons(PORT);
    memset(serveAddr.sin_zero,0x00,8);
  
    RET = connect(clientScoket,(struct sockaddr*)&serveAddr,sizeof(serveAddr));
    if (RET != 0)
    {
        cout<<"connect failed";
        return -1;
    }
    else{ cout<<"链接成攻"<<endl;}
    while(true)
    {
        cin.getline(SendBuffer,sizeof(SendBuffer));
        RET = send(clientScoket,SendBuffer,(int)strlen(SendBuffer),0);
        if (RET == SOCKET_ERROR)
        {
            cout<<"send to error"<<endl;
            break;
        }
    }
    closesocket(clientScoket);
    WSACleanup();
    return 0;
}

标签： 服务器

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点！
本站所提供的图片等素材，版权归原作者所有，如需使用，请与原作者联系。