我写了一个socket类，recv返回两次第一次200OK第二次就Bad Request了有点迷惑阿
代码：#pragma once
#include"EspString.hpp"
#pragma comment(lib,"ws2_32.lib")
#include<iostream>
class EspHttp
{
private:
unsigned int HSocket = INVALID_SOCKET;
bool IsPost = false;
bool IsHttps = false;
unsigned int ErrorCode;
unsigned short nPort;
EspString lpszScheme;//http or https
EspString lpszEntireURL;
EspString lpszHostName;//www.baidu.com
EspString lpszURLPath;// ...com/[.....]<-
EspString lpszProtocol;//Submitted/received protocol
EspString lpszAddInfo;//POST method
EspString lpszResult;//recv
EspString lpszStatus;//HTTP/1.1 200 OK HTTP/1.1 400 Bad Request
EspString lpszContent;// Manbody of the Result
bool RequestOK;//Whether is HTTP/1.1 200 OK
bool AnalyzeURL()
{
unsigned long ParsePos = 0; unsigned long TargetPos = 0;
assert(lpszEntireURL.GetBuffer() != NULL && ::IsBadStringPtrA(lpszEntireURL.GetBuffer(), -1) == false);
EspString lpszTempString;
TargetPos = lpszEntireURL.Find(":", 0);
if (TargetPos == -1)
return false;
lpszTempString = lpszEntireURL.GetLeftStr(TargetPos);
if (lpszTempString.CompareNoCase("http"))
lpszScheme = "http";
else if (lpszTempString.CompareNoCase("https"))
{
lpszScheme = "https";
IsHttps = true;
}
else
return false;
ParsePos += (lpszTempString.GetLength() + 3);
TargetPos = lpszEntireURL.Find(":", ParsePos);
if (TargetPos != -1)
{
lpszTempString = lpszEntireURL.GetMidStr(ParsePos, TargetPos - ParsePos);
if (lpszTempString.IsEmpty())return false;
lpszHostName = lpszTempString;
ParsePos += (lpszTempString.GetLength() + 1);
TargetPos = lpszEntireURL.Find("/", ParsePos);
if (TargetPos == -1)
return false;
nPort = ::strtoul(lpszEntireURL.GetMidStr(ParsePos, TargetPos - ParsePos).GetAnsiStr(), 0, 0);
}
else
{
TargetPos = lpszEntireURL.Find("/", ParsePos);
if (TargetPos == -1)
return false;
lpszTempString = lpszEntireURL.GetMidStr(ParsePos, TargetPos - ParsePos);
if (lpszTempString.IsEmpty())return false;
lpszHostName = lpszTempString;
if (IsHttps)
nPort = 443;
else
nPort = 80;
}
lpszURLPath = lpszEntireURL.GetMidStr(TargetPos, lpszEntireURL.GetLength() - TargetPos);
return true;
}
public:
EspHttp()
{
WSADATA SocketData = { 0 };
ErrorCode = ::WSAStartup(MAKEWORD(2, 2), &SocketData);
if (ErrorCode == 0)
{
HSocket = ::socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (HSocket == INVALID_SOCKET)
ErrorCode = ::WSAGetLastError();
}
}
~EspHttp()
{
if (ErrorCode == 0)
{
if (HSocket != INVALID_SOCKET)
::closesocket(HSocket);
::WSACleanup();
}
}
unsigned int GetLastError() { return ErrorCode; }
bool ConnectTo(const char* lpszURL, bool IsPOST = false, const char* lpszAddInfo = NULL)
{
assert(lpszURL != NULL && ::IsBadStringPtrA(lpszURL, -1) == false);
lpszEntireURL = lpszURL;
if (lpszEntireURL.IsEmpty())
return false;
if (!AnalyzeURL())
return false;
SOCKADDR_IN SocketAddr = { AF_INET,::htons(nPort),*((LPIN_ADDR) * ::gethostbyname(lpszHostName.GetAnsiStr())->h_addr_list) };
if (::connect(HSocket, (LPSOCKADDR)&SocketAddr, sizeof(SOCKADDR_IN)) == SOCKET_ERROR)
{
ErrorCode = ::WSAGetLastError();
::closesocket(HSocket);
return false;
}
IsPost = IsPOST;
if (IsPost)
{
lpszProtocol.Append("POST ");
if (lpszAddInfo != NULL)
this->lpszAddInfo = lpszAddInfo;
}
else
lpszProtocol.Append("GET ");
lpszProtocol.Append(lpszURLPath.GetAnsiStr());
lpszProtocol.Append(" HTTP/1.1\r\n");
lpszProtocol.Append("Host: "); lpszProtocol.Append(lpszHostName.GetAnsiStr()); lpszProtocol.Append("\r\n");
}
void AddToProtocol(const char* lpszName, const char* lpszValue)
{
assert(lpszName != NULL && ::IsBadStringPtrA(lpszName, -1) == false);
assert(lpszValue != NULL && ::IsBadStringPtrA(lpszValue, -1) == false);
lpszProtocol.Append(lpszName);
lpszProtocol.Append(": ");
lpszProtocol.Append(lpszValue);
lpszProtocol.Append("\r\n");
}
bool SendRequest()
{
lpszProtocol.Append("\r\n");
if (IsPost)
lpszProtocol.Append(lpszAddInfo);
if (::send(HSocket, lpszProtocol.GetAnsiStr(), lpszProtocol.GetLength() + 1, 0) == SOCKET_ERROR)
{
ErrorCode = ::WSAGetLastError();
return false;
}
char* Buffer = (char*)::malloc(1025);
if (Buffer == NULL)
throw("Allocate Buffer Unsuccessfully");
unsigned long BufferSize = 0;
lpszResult.Empty();
do
{
BufferSize = ::recv(HSocket, Buffer, 1024, 0);
if (BufferSize > 0)
{
::memset(Buffer + BufferSize, 0, (1025 - BufferSize) * sizeof(char));
lpszResult.Append(Buffer);
}
else if (BufferSize == 0)
break;
else if (BufferSize == SOCKET_ERROR)
{
ErrorCode = ::WSAGetLastError();
return false;
}
} while (BufferSize != 0);
if (!lpszResult.IsEmpty())
{
unsigned long Pos1 = lpszResult.Find("\r\n");
if (Pos1 == -1)return false;
lpszStatus = lpszResult.GetLeftStr(Pos1);
unsigned long Pos2 = lpszResult.Find("\r\n\r\n");
if (Pos2 == -1)return false;
lpszProtocol = lpszResult.GetMidStr(Pos1, Pos2);
lpszContent = lpszResult.GetMidStr(Pos2+1, lpszResult.GetLength() - Pos2);
return true;
}
else
return false;
}
EspString GetResponce()
{
return lpszContent;
}
};
| 
[复制链接]
( 粤ICP备18085999号-1 | 粤公网安备 44051102000585号)
狗仔卡
发表于 2020-12-10 16:47:53
显身卡
发表于 2021-2-23 16:49:52
