Question

C++的socket方法

我现在想要实现在客户端生成的一个结构体通过TCP协议传输给服务器端应该怎么实现啊，有代码就太感谢了

Answer 1

C++中Socket方法主要用于网络通信，常用到的函数如下：

CSocket::Socket初始化
CSocket::SetSockOpt 设置socket选项
CSocket::Bind 绑定地址端口
CSocket::Connect 连接
CSocket::Listen  监听
CSocket::Accept 接收外部连接的socket
CSocket::Send 发送内容
CSocket::Receive 接收内容
CSocket::Close 关闭(不等于delete)

下面是C++编程下用Socket方法做一个客服端和服务端通信的案例：

1、服务端代码

 //初始化Winscok
 if (!AfxSocketInit())
 {
  AfxMessageBox(IDP_SOCKETS_INIT_FAILED);
  return 1;
 }

 m_exit = false;

 CServerDlg *aDlg = (CServerDlg *)lParam;

 //获取端口
 CString strPort;
 aDlg->GetDlgItemText(IDC_EDIT_PORT, strPort);
 UINT nPort = atoi(strPort);
 
 //socket----创建2个socket--------------------------------------------
 CSocket aSocket, serverSocket;
 //最好不要使用aSocket.Create创建，因为容易会出现10048错误
 if (!aSocket.Socket())
 {
  char szError[256] = {0};
  sprintf(szError, "Create Faild: %d", GetLastError());
  AfxMessageBox(szError);
  return 1; 
 }

 BOOL bOptVal = TRUE;
 int bOptLen = sizeof(BOOL);
 //设置Socket的选项, 解决10048错误必须的步骤
 aSocket.SetSockOpt(SO_REUSEADDR, (void *)&bOptVal, bOptLen, SOL_SOCKET);
 
  //绑定
 if (!aSocket.Bind(nPort))
 {
  char szError[256] = {0};
  sprintf(szError, "Bind Faild: %d", GetLastError());
  AfxMessageBox(szError); 
  return 1; 
 }

 //监听
 if(!aSocket.Listen(10))
 { 
  char szError[256] = {0};
  sprintf(szError, "Listen Faild: %d", GetLastError());
  AfxMessageBox(szError);
  return 1;
 }
 
 CString strText;
 aDlg->GetDlgItemText(IDC_EDIT_LOG, strText);
 strText += "服务已经开启! \r\n";
 aDlg->SetDlgItemText(IDC_EDIT_LOG, strText);
 while(!m_exit)
 {
  //接收外部连接
  if(!aSocket.Accept(serverSocket))
  {
   continue;
  }
  else
  {
   char szRecvMsg[256] = {0};
   char szOutMsg[256] = {0}; 
   serverSocket.Receive(szRecvMsg, 256); //接收客户端内容:阻塞
   sprintf(szOutMsg, "接受到的参数是: %s \r\n", szRecvMsg);
   aDlg->GetDlgItemText(IDC_EDIT_LOG, strText);
   strText += szOutMsg;
   aDlg->SetDlgItemText(IDC_EDIT_LOG, strText);
   serverSocket.Send("服务器已经收到，已经做出操作！", 50);//发送内容给客户端
   serverSocket.Close();//关闭
  }
  
 }
 
 aSocket.Close();
 serverSocket.Close();
 aDlg->GetDlgItemText(IDC_EDIT_LOG, strText);
 strText += "Have Close!";
 aDlg->SetDlgItemText(IDC_EDIT_LOG, strText);
 return 0;

2、客户端代码

//初始化 CSocket 对象,客户端可以是用Create 因为客户端不需要绑定任何端口和地址, 所以用默认参数即可
//连接指定的地址和端口是用函数Connect函数
//发送内容给服务器是用send函数
//接收服务端发送的内容使用Receive函数
 AfxSocketInit();
 CSocket aSocket;
 CString strIP;
 CString strPort;
 CString strText;
 this->GetDlgItem(IDC_EDIT_IP)->GetWindowText(strIP);
 this->GetDlgItem(IDC_EDIT_PORT)->GetWindowText(strPort);
 this->GetDlgItem(IDC_EDIT_TEXT)->GetWindowText(strText);
  //初始化 CSocket 对象, 因为客户端不需要绑定任何端口和地址, 所以用默认参数即可
 if(!aSocket.Create())
 {
  char szMsg[1024] = {0};

  sprintf(szMsg, "create faild: %d", aSocket.GetLastError());

  AfxMessageBox(szMsg);
  return;
 }
 //转换需要连接的端口内容类型
 int nPort = atoi(strPort);
 //连接指定的地址和端口
 if(aSocket.Connect(strIP, nPort))
 {
  char szRecValue[1024] = {0};
  aSocket.Send(strText, strText.GetLength()); //发送内容给服务器
  aSocket.Receive((void *)szRecValue, 1024); //接收服务器发送回来的内容(该方法会阻塞, 在此等待有内容接收到才继续向下执行)
  AfxMessageBox(szRecValue);
 }
 else
 {
  char szMsg[1024] = {0};
  sprintf(szMsg, "create faild: %d", aSocket.GetLastError());
  AfxMessageBox(szMsg);
 }
 aSocket.Close();

Answer 2

// TCP_Client.cpp : Defines the entry point for the console application.
//
#include "stdafx.h"
#include <stdio.h>
#include <WINSOCK2.H>
#include <iostream.h>
#include <windows.h>
#pragma comment (lib, "ws2_32")

int main(int argc, char* argv[])
{
 char buf[20];
 memset(buf, 0, 20);
 
 WSADATA wsaData;
 int Error = WSAStartup(MAKEWORD(1, 1), &wsaData);                   // 加载套接字库  成功返回 0 
 if (Error != 0)
 {
  cout<<"Initializes the WSAStartup Function failure"<<endl;
  return -1;
 }
 if (LOBYTE(wsaData.wVersion) != 1 || HIBYTE(wsaData.wVersion) != 1) // 判断版本是否正确
 {
  
  cout<<"Initializes the WSAStartup Version failure"<<endl;
  WSACleanup();                                                   // 释放 WinSock库 占用的资源
  return -2;
 }
 
 SOCKET sock_Client = socket(AF_INET, SOCK_STREAM, 0);               // 创建套接字    Socket类型可以是 SOCK_STREAM(TCP)  SOCK_DGREAM(UDP)
 if (sock_Client == INVALID_SOCKET)
 {
  itoa(WSAGetLastError(), buf, 20);                               // 获得错误码
  cout<<"Failed to initiate the Socket, Error Code is "<<buf<<endl;
  return -3;
 }
 
 
 SOCKADDR_IN addr_in;
 addr_in.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");              // 绑定指定的IP地址
 // buf = inet_ntoa(addr_in.sin_addr.S_un.S_addr);                   // 把IP地址转换为字符串
 
 addr_in.sin_family = AF_INET;
 addr_in.sin_port = htons(2345);
 connect(sock_Client,(SOCKADDR *)&addr_in, sizeof(SOCKADDR));        // 与特定的套接字建立连接
                                                                     // 参数1    要绑定的套接字
                                                                        // 参数2    指向 该套接字的本地地址信息结构
                                                                        // 参数3    该套接字的本地地址信息结构的长度
 char RecvBuf[256];
 memset(RecvBuf, 0, 256);
 recv(sock_Client, RecvBuf, 256, 0);                                 // 从一个已连接的套接字接收数据
                                                                        // 参数1       已建立连接的套接字
                                                                        // 参数2       保存数据的缓冲区指针
                                                                        // 参数3       保存数据的缓冲区的长度
                                                                        // 参数4       一般设为 0 
 
 printf("%s\n", RecvBuf);
 send(sock_Client, "This is lisi", strlen("This is lisi") + 1, 0);   // 通过一个已建立连接的套接字发送数据
 
 closesocket(sock_Client);                                           // 关闭套接字
 WSACleanup();                                                       // 释放 WinSock库 占用的资源
 return 0;
}