网络通信第五课 生产环境下的Post通信

Posted 2020-10-02

说明

封装成一个完整的C++类，对于异常的校验和处理有待在实际的过程中，进一步加强，

目前对于套接字的关闭，释放网络资源应该是没有问题的

#include <iostream>

#include <fstream>

#include <string>

#include <boost/asio.hpp>

using namespace std;

using namespace boost::asio;

class CHttpPost;

unsigned char ToHex(unsigned char x)

{

return  x > 9 ? x + 55 : x + 48;

}

unsigned char FromHex(unsigned char x)

{

unsigned char y;

if (x >= ‘A‘ && x <= ‘Z‘) y = x - ‘A‘ + 10;

else if (x >= ‘a‘ && x <= ‘z‘) y = x - ‘a‘ + 10;

else if (x >= ‘0‘ && x <= ‘9‘) y = x - ‘0‘;

else assert(0);

return y;

}

std::string UrlEncode(const std::string& str)

{

std::string strTemp = "";

size_t length = str.length();

for (size_t i = 0; i < length; i++)

{

if (isalnum((unsigned char)str[i]) ||

(str[i] == ‘-‘) ||

(str[i] == ‘_‘) ||

(str[i] == ‘.‘) ||

(str[i] == ‘~‘) ||

(str[i] == ‘&‘) ||

(str[i] == ‘=‘))

strTemp += str[i];

else if (str[i] == ‘ ‘)

strTemp += "+";

else

{

strTemp += ‘%‘;

strTemp += ToHex((unsigned char)str[i] >> 4);

strTemp += ToHex((unsigned char)str[i] % 16);

}

}

return strTemp;

}

std::string UrlDecode(const std::string& str)

{

std::string strTemp = "";

size_t length = str.length();

for (size_t i = 0; i < length; i++)

{

if (str[i] == ‘+‘) strTemp += ‘ ‘;

else if (str[i] == ‘%‘)

{

assert(i + 2 < length);

unsigned char high = FromHex((unsigned char)str[++i]);

unsigned char low = FromHex((unsigned char)str[++i]);

strTemp += high * 16 + low;

}

else strTemp += str[i];

}

return strTemp;

}

class CHttpPost

{

public:

CHttpPost(std::string strServerIP, int sServerPort)

{

m_sServerPort = sServerPort;

m_strServerIP = strServerIP;

}

int SendPostRequest(std::string strUrl, std::string strPostData, char* pszRecvData)

{

std::string strUrlEnCodedBuffer = UrlEncode(strPostData);

io_service iosev;

ip::tcp::socket socket(iosev);

ip::tcp::endpoint ep(ip::address_v4::from_string(m_strServerIP), m_sServerPort);

boost::system::error_code ec;

do

{

socket.connect(ep, ec);

if (ec) break;

boost::asio::streambuf request;

std::ostream request_stream(&request);

request_stream << "POST " << strUrl << " HTTP/1.1\r\n";

request_stream << "Host: " << m_strServerIP << ":" << m_sServerPort << "\r\n";

request_stream << "Content-Length: " << strUrlEnCodedBuffer.size() << "\r\n";

request_stream << "Content-Type: application/x-www-form-urlencoded; charset=UTF-8\r\n";

request_stream << "\r\n";

request_stream << strUrlEnCodedBuffer;

size_t len = boost::asio::write(socket, request, ec);

if (ec) break;

char szRecvBuf[1024] = { 0 };

int nReadLen = socket.read_some(buffer(szRecvBuf), ec);

std::cout << "Http Response Context:" << std::endl;

std::cout << szRecvBuf << std::endl;

if (ec) break;

strcpy_s(pszRecvData, nReadLen+1, szRecvBuf);

std::string strRecvBuf = szRecvBuf;

int nIndexOfBody = strRecvBuf.find("\r\n\r\n", 0);

if (nIndexOfBody < 0) return -1;

std::string strHttpBody = strRecvBuf.substr(nIndexOfBody + 4);

std::cout << "Http Body Context:" << std::endl;

std::cout << strHttpBody << std::endl;

} while (0);

socket.close();

if (ec) return -1;

return 0;

}

private:

int m_sServerPort;

std::string m_strServerIP;

};

测试代码

  char szSrcBuffer[1024] = { "authorJson={loginAccount:\"admin\"}&parmJson={code:\"SheBeiLiXianGaoJingShangChuan\",params:{id:\"3919123496\",remarks:\"fire alarm\",time_alarm:\"2017-1-1\",alarm_source:\"192.168.1.11\"}}" };

char szUrl[256] = { "/cs/restfull/operationRestfullApi/excuteSqlByCode" };

CHttpPost instance("120.77.55.115", 8089);

char szRecvData[1024] = { 0 };

instance.SendPostRequest(szUrl, szSrcBuffer, szRecvData);

return 0;