C++基础--简单Socket通信实例

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

#include "stdafx.h"
#include <iostream>
#include <Windows.h>
#include <Winsock2.h>

#pragma comment(lib,"Ws2_32.lib")

using namespace std;
#define PORT 8081
#define IP_ADDRESS "172.16.20.181"
DWORD WINAPI ClientThread(LPVOID lpParameter)
  {
     SOCKET ClientSocket = (SOCKET)lpParameter;
      int Ret = 0;
      char RecvBuffer[MAX_PATH];
  
      while ( true )
      {
          memset(RecvBuffer, 0x00, sizeof(RecvBuffer));
          Ret = recv(ClientSocket, RecvBuffer, MAX_PATH, 0);
          if ( Ret == 0 || Ret == SOCKET_ERROR ) 
          {
              cout<<"客户端退出!"<<endl;
              break;
          }
          cout<<"接收到客户信息为:"<<RecvBuffer<<endl;
          // send msg to client
           Ret = send(ClientSocket, RecvBuffer, (int)strlen(RecvBuffer), 0);
             if ( Ret == SOCKET_ERROR )
             {
                 cout<<"Send Info Error::"<<GetLastError()<<endl;
                 break;
             }
             cout<<"After Send Msg:"<<RecvBuffer<<endl;
      }
  
      return 0;
  }
  
  int main(int argc, char* argv[])
  {
      WSADATA  Ws;
      SOCKET ServerSocket, ClientSocket;
      struct sockaddr_in LocalAddr, ClientAddr;
      int Ret = 0;
      int AddrLen = 0;
      HANDLE hThread = NULL;
  
      //Init Windows Socket
      //The WSAStartup function initiates use of WS2_32.DLL by a process.

      if ( WSAStartup(MAKEWORD(2,2), &Ws) != 0 )
      {
          cout<<"Init Windows Socket Failed::"<<GetLastError()<<endl;
          return -1;
      }
      
      //Create Socket
      ServerSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
      if ( ServerSocket == INVALID_SOCKET )
      {
          cout<<"Create Socket Failed::"<<GetLastError()<<endl;
          return -1;
      }
  
      //the address of family specification
      LocalAddr.sin_family = AF_INET;

      //The inet_addr function converts a string containing an (Ipv4) Internet Protocol dotted address into a proper address for the IN_ADDR structure.
      LocalAddr.sin_addr.s_addr = inet_addr(IP_ADDRESS); 

      //The htons function converts a u_short from host to TCP/IP network byte order (which is big-endian).
      LocalAddr.sin_port = htons(PORT);

      //Sets buffers to a specified character.
      memset(LocalAddr.sin_zero, 0x00, 8);
  
      //Bind Socket,The bind function associates a local address with a socket.
      Ret = bind(ServerSocket, (struct sockaddr*)&LocalAddr, sizeof(LocalAddr));
      if ( Ret != 0 )
      {
          cout<<"Bind Socket Failed::"<<GetLastError()<<endl;
          return -1;
      }
    
      //The listen function places a socket in a state in which it is listening for an incoming connection.
      Ret = listen(ServerSocket, 10);
      if ( Ret != 0 )
      {
          cout<<"listen ClientSocket Failed::"<<GetLastError()<<endl;
          return -1;
      }
  
      cout<<"服务端已经启动"<<endl;
  
      while ( true )
      {
          AddrLen = sizeof(ClientAddr);

          //The accept function permits an incoming connection attempt on a socket.
          ClientSocket = accept(ServerSocket, (struct sockaddr*)&ClientAddr, &AddrLen);

          if ( ClientSocket == INVALID_SOCKET )
          {
              cout<<"Accept Failed::"<<GetLastError()<<endl;
              break;
          }
        
          //The inet_ntoa function converts an (Ipv4) Internet network address into a string in Internet standard dotted format.
          cout<<"客户端连接::"<<inet_ntoa(ClientAddr.sin_addr)<<":"<<ClientAddr.sin_port<<endl;
         
          
          //Call this function to create a thread that can use CRT functions.
          hThread = CreateThread(NULL, 0, ClientThread, (LPVOID)ClientSocket, 0, NULL);
          if ( hThread == NULL )
          {
              cout<<"Create Thread Failed!"<<endl;
              break;
          }
  
          CloseHandle(hThread);
      }
 
     closesocket(ServerSocket);
     closesocket(ClientSocket);
     WSACleanup();
 
     return 0;
 }

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

#include "stdafx.h"
#include <iostream>
#include <Windows.h>
#include <Winsock2.h>

#pragma comment(lib,"Ws2_32.lib")

using namespace std;

#define PORT 8081
#define IP_ADDRESS "172.16.20.181"


int _tmain(int argc, _TCHAR* argv[])
{
    WSADATA  Ws;
     SOCKET ClientSocket;
     struct sockaddr_in ServerAddr;
     int Ret = 0;
     int AddrLen = 0;
     HANDLE hThread = NULL;
     char SendBuffer[MAX_PATH];
 
     //Init Windows Socket
     //The WSAStartup function initiates use of WS2_32.DLL by a process.
     if ( WSAStartup(MAKEWORD(2,2), &Ws) != 0 )
     {
         cout<<"Init Windows Socket Failed::"<<GetLastError()<<endl;
         return -1;
     }
 
     //Create Socket
     ClientSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
     if ( ClientSocket == INVALID_SOCKET )
     {
         cout<<"Create Socket Failed::"<<GetLastError()<<endl;
         return -1;
     }
 
     ServerAddr.sin_family = AF_INET;
     ServerAddr.sin_addr.s_addr = inet_addr(IP_ADDRESS);
     ServerAddr.sin_port = htons(PORT);
     memset(ServerAddr.sin_zero, 0x00, 8);
    
     //Bind Socket,The bind function associates a local address with a socket.
      //Ret = bind(ClientSocket, (struct sockaddr*)&ServerAddr, sizeof(ServerAddr));
      //if ( Ret != 0 )
      //{
      //    cout<<"Bind Client Socket Failed::"<<GetLastError()<<endl;
      //    //return -1;
      //}

     Ret = connect(ClientSocket,(struct sockaddr*)&ServerAddr, sizeof(ServerAddr));
    if ( Ret == SOCKET_ERROR )
     {
         cout<<"Connect Error::"<<GetLastError()<<endl;
        // return -1;
     }
     else
     {
         cout<<"连接成功!"<<endl;
     }
    
     while ( true )
     {
         cin.getline(SendBuffer, sizeof(SendBuffer));
         Ret = send(ClientSocket, SendBuffer, (int)strlen(SendBuffer), 0);
         if ( Ret == SOCKET_ERROR )
         {
             cout<<"Send Info Error::"<<GetLastError()<<endl;
             break;
         }
        
         char recvBuf[500];
         int byteRecv = recv(ClientSocket, recvBuf, MAX_PATH, 0);
         if (byteRecv != 0)
         {
             recvBuf[byteRecv] = 0;
             cout << "From server: " << recvBuf << endl;
         }

     }
     
     closesocket(ClientSocket);
     WSACleanup();
    system("pause");
     return 0;
 }