C++的socket方法

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();