C++HTTP简易留言板

科技颠覆者  论坛元老 | 2024-7-28 23:47:56 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 1023|帖子 1023|积分 3069

Windows

  1. #include <iostream>
  2. #include <fstream>
  3. #include <string>
  4. #include <winsock2.h>
  5. #include <windows.h>
  6. #include <vector>
  7. #include <Ws2tcpip.h>
  8. #include <sstream>
  9. #include <iomanip>
  10. #include <cctype>
  11. #include <ctime>
  12. #include <regex>
  14. #pragma comment(lib, "ws2_32.lib")
  16. const char* commonResponseHeaders = "Content-Type: text/html\r\n";
  18. // URL 解码函数
  19. #include <iostream>
  20. #include <string>
  22. std::string urlDecode(const std::string& str) {
  23.     std::string result;
  24.     for (size_t i = 0; i < str.size(); ++i) {
  25.         if (str[i] == '%' && i + 2 < str.size() && std::isxdigit(str[i + 1]) && std::isxdigit(str[i + 2])) {
  26.             std::string hexCode = str.substr(i + 1, 2);
  27.             char decodedChar = static_cast<char>(std::stoi(hexCode, 0, 16));
  28.             result += decodedChar;
  29.             i += 2;
  30.         }
  31.         else if (str[i] == '+') {
  32.             result += ' ';  // 这里应该是添加空格
  33.         }
  34.         else {
  35.             result += str[i];
  36.         }
  37.     }
  38.     return result;
  39. }
  41. // 过滤 HTML 符号的函数
  42. std::string filterHtmlTags(const std::string& message) {
  43.     std::regex htmlTagsRegex("<[^>]*>");
  44.     return std::regex_replace(message, htmlTagsRegex, "");
  45. }
  47. void handleRequest(SOCKET clientSocket) {
  48.     char buffer[1024];
  49.     int bytesRead = recv(clientSocket, buffer, sizeof(buffer) - 1, 0);  // 确保不会超出缓冲区
  50.     if (bytesRead <= 0) {
  51.         std::cerr << "Error receiving data from client" << std::endl;
  52.         return;
  53.     }
  54.     buffer[bytesRead] = '\0';  // 确保字符串以 null 结尾
  56.     std::string request(buffer);
  58.     // 获取当前日期并构建文件路径
  59.     time_t t = time(NULL);
  60.     std::tm localTime;
  61.     localtime_s(&localTime, &t);
  62.     std::string folderName = "rec_request";
  63.     CreateDirectoryA(folderName.c_str(), NULL);
  64.     std::string fileName = folderName + "/" + std::to_string(1900 + localTime.tm_year) + "-" + std::to_string(1 + localTime.tm_mon) + "-" + std::to_string(localTime.tm_mday) + ".log";
  66.     // 获取当前时间并格式化
  67.     char timeBuffer[26];
  68.     ctime_s(timeBuffer, sizeof(timeBuffer), &t);
  69.     std::string timeStr(timeBuffer);
  70.     timeStr.pop_back();  // 去除换行符
  72.     // 打开或创建文件并写入时间和请求
  73.     std::ofstream file(fileName, std::ios::app);
  74.     file << timeStr << std::endl;
  75.     file << std::string(64, '=') << std::endl;
  76.     file << request << std::endl;
  77.     file.close();
  79.     std::cout << "Received request:\n" << request << std::endl;
  81.     std::string method, uri, version;
  82.     size_t firstSpace = request.find(' ');
  83.     size_t secondSpace = request.find(' ', firstSpace + 1);
  85.     if (firstSpace != std::string::npos && secondSpace != std::string::npos) {
  86.         method = request.substr(0, firstSpace);
  87.         uri = request.substr(firstSpace + 1, secondSpace - firstSpace - 1);
  88.         version = request.substr(secondSpace + 1, request.find("\r\n") - secondSpace - 1);
  89.     }
  90.     else {
  91.         std::cerr << "Invalid request" << std::endl;
  92.         return;
  93.     }
  95.     std::cout << "Method: " << method << ", URI: " << uri << ", Version: " << version << std::endl;
  97.     // 处理根路径和 /message_board
  98.     if (uri == "/" || uri == "/message_board") {
  99.         std::string response = "HTTP/1.1 200 OK\r\n";
  100.         response += commonResponseHeaders;
  101.         response += "\r\n";
  102.         response += "<html><style>";
  103.         response += "body { font-family: Arial, sans-serif; background-color: #f0f0f0; }";
  104.         response += "h2 { color: #333; }";
  105.         response += ".container { max-width: 800px; margin: 0 auto; padding: 20px; background-color: #fff; border-radius: 8px; box-shadow: 0 0 10px rgba(0, 0, 0, 0.1); }";
  106.         response += ".message-form { margin-bottom: 20px; }";
  107.         response += ".message { border: 1px solid #ccc; padding: 10px; margin: 10px 0; background-color: #fff; word-wrap: break-word; }";
  108.         response += "input[type='text'] { width: 100%; height: 200px; }";  // 设置输入框高度为 200 像素
  109.         response += "input[type='submit'] { width: 100%; padding: 10px; font-size: 16px; background-color: #4CAF50; color: white; border: none; border-radius: 4px; cursor: pointer; }";
  110.         response += "input[type='submit']:hover { background-color: #45a049; }";
  111.         response += "</style></head><body>";
  112.         response += "<div class='container'>";
  113.         response += "<h2>留言板</h2>";
  114.         response += "<div class='message-form'><form action='/submit_message' method='post'>";
  115.         response += "留言: <input type='text' name='message' required><br>";
  116.         response += "<input type='submit' value='提交'>";
  117.         response += "</form></div>";
  119.         // 读取并显示留言内容
  120.         std::ifstream logFile("message.txt");  // 更改文件名
  121.         if (logFile.is_open()) {
  122.             std::string line;
  123.             while (std::getline(logFile, line)) {
  124.                 response += "<div class='message'>" + line + "</div>";
  125.             }
  126.             logFile.close();
  127.         }
  129.         response += "<div style='font-size:12px; color:#999; text-align:center;'>Power by Hank Q:1101773014</div>";  // 添加版权信息
  131.         response += "</div></body></html>";
  133.         send(clientSocket, response.c_str(), response.size(), 0);
  134.     }
  135.     else if (uri == "/submit_message" && method == "POST") {
  136.         size_t contentLengthStart = request.find("Content-Length: ");
  137.         if (contentLengthStart == std::string::npos) {
  138.             std::cerr << "Invalid submit message request" << std::endl;
  139.             return;
  140.         }
  142.         size_t contentLengthEnd = request.find("\r\n", contentLengthStart);
  143.         size_t contentLength = std::stoi(request.substr(contentLengthStart + 16, contentLengthEnd - contentLengthStart - 16));
  145.         size_t bodyStart = request.find("\r\n\r\n") + 4;
  146.         std::string body = request.substr(bodyStart, contentLength);
  147.         size_t messageStart = body.find("message=") + 8;
  148.         std::string submittedMessage = urlDecode(body.substr(messageStart));
  150.         // 过滤 HTML 符号
  151.         submittedMessage = filterHtmlTags(submittedMessage);
  153.         // 获取当前时间
  154.         std::time_t t = std::time(nullptr);
  155.         std::tm localTime;
  156.         localtime_s(&localTime, &t);
  157.         std::ostringstream oss;
  158.         oss << std::put_time(&localTime, "%Y-%m-%d %H:%M:%S");
  160.         SOCKADDR_IN clientAddress;
  161.         int clientAddressLength = sizeof(clientAddress);
  162.         if (getpeername(clientSocket, (SOCKADDR*)&clientAddress, &clientAddressLength) == SOCKET_ERROR) {
  163.             std::cerr << "Error getting client IP address" << std::endl;
  164.             return;
  165.         }
  167.         char ipAddressBuffer[INET_ADDRSTRLEN];
  168.         if (inet_ntop(AF_INET, &clientAddress.sin_addr, ipAddressBuffer, INET_ADDRSTRLEN) == NULL) {
  169.             std::cerr << "Error converting IP address" << std::endl;
  170.             return;
  171.         }
  172.         std::string clientIP = std::string(ipAddressBuffer);
  174.         std::ofstream logFile("message.txt", std::ios::app);  // 更改文件名
  175.         logFile << oss.str() << " " << clientIP << ": " << submittedMessage << std::endl;
  176.         logFile.close();
  178.         // 重定向回主页
  179.         std::string response = "HTTP/1.1 303 See Other\r\n";
  180.         response += "Location: /\r\n";
  181.         response += "\r\n";
  183.         send(clientSocket, response.c_str(), response.size(), 0);
  184.     }
  185.     else {
  186.         std::string response = "HTTP/1.1 404 Not Found\r\n";
  187.         response += commonResponseHeaders;
  188.         response += "\r\n";
  189.         response += "<html><body>";
  190.         response += "<h2>404 Not Found</h2>";
  191.         response += "</body></html>";
  193.         send(clientSocket, response.c_str(), response.size(), 0);
  194.     }
  196.     closesocket(clientSocket);
  197. }
  199. int main() {
  200.     WSADATA wsaData;
  201.     if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {
  202.         std::cerr << "WSAStartup failed" << std::endl;
  203.         return 1;
  204.     }
  206.     SOCKET serverSocket = socket(AF_INET, SOCK_STREAM, 0);
  207.     if (serverSocket == INVALID_SOCKET) {
  208.         std::cerr << "Error creating socket" << std::endl;
  209.         WSACleanup();
  210.         return 1;
  211.     }
  213.     SOCKADDR_IN serverAddress;
  214.     memset(&serverAddress, 0, sizeof(serverAddress));
  215.     serverAddress.sin_family = AF_INET;
  216.     serverAddress.sin_addr.s_addr = INADDR_ANY;
  217.     serverAddress.sin_port = htons(80);
  219.     if (bind(serverSocket, (SOCKADDR*)&serverAddress, sizeof(serverAddress)) == SOCKET_ERROR) {
  220.         std::cerr << "Error binding socket" << std::endl;
  221.         closesocket(serverSocket);
  222.         WSACleanup();
  223.         return 1;
  224.     }
  226.     if (listen(serverSocket, 5) == SOCKET_ERROR) {
  227.         std::cerr << "Error listening on socket" << std::endl;
  228.         closesocket(serverSocket);
  229.         WSACleanup();
  230.         return 1;
  231.     }
  233.     std::cout << "Server is listening on port 80..." << std::endl;
  235.     while (true) {
  236.         SOCKADDR_IN clientAddress;
  237.         int clientAddressLength = sizeof(clientAddress);
  238.         SOCKET clientSocket = accept(serverSocket, (SOCKADDR*)&clientAddress, &clientAddressLength);
  239.         if (clientSocket == INVALID_SOCKET) {
  240.             std::cerr << "Error accepting client connection" << std::endl;
  241.             continue;
  242.         }
  244.         handleRequest(clientSocket);
  245.     }
  247.     closesocket(serverSocket);
  248.     WSACleanup();
  250.     return 0;
  251. }
复制代码
Linux

  1. #include <iostream>
  2. #include <fstream>
  3. #include <string>
  4. #include <unistd.h>
  5. #include <sys/socket.h>
  6. #include <sys/stat.h>
  7. #include <netinet/in.h>
  8. #include <arpa/inet.h>
  9. #include <vector>
  10. #include <sstream>
  11. #include <iomanip>
  12. #include <cctype>
  13. #include <ctime>
  14. #include <regex>
  15. #include <codecvt>
  17. // URL 解码函数
  18. std::string urlDecode(const std::string& str) {
  19.     std::string result;
  20.     for (size_t i = 0; i < str.size(); ++i) {
  21.         if (str[i] == '%' && i + 2 < str.size() && std::isxdigit(str[i + 1]) && std::isxdigit(str[i + 2])) {
  22.             std::string hexCode = str.substr(i + 1, 2);
  23.             char decodedChar = static_cast<char>(std::stoi(hexCode, 0, 16));
  24.             result += decodedChar;
  25.             i += 2;
  26.         }
  27.         else if (str[i] == '+') {
  28.             result += ' ';
  29.         }
  30.         else {
  31.             result += str[i];
  32.         }
  33.     }
  34.     return result;
  35. }
  37. // 过滤 HTML 符号的函数
  38. std::string filterHtmlTags(const std::string& message) {
  39.     std::regex htmlTagsRegex("<[^>]*>");
  40.     return std::regex_replace(message, htmlTagsRegex, "");
  41. }
  43. void handleRequest(int clientSocket) {
  44.     char buffer[1024];
  45.     int bytesRead = recv(clientSocket, buffer, sizeof(buffer) - 1, 0);  // 确保不会超出缓冲区
  46.     if (bytesRead <= 0) {
  47.         std::cerr << "Error receiving data from client" << std::endl;
  48.         return;
  49.     }
  50.     buffer[bytesRead] = '\0';  // 确保字符串以 null 结尾
  52.     std::string request(buffer);
  54.     // 获取当前日期并构建文件路径
  55.     time_t t = time(NULL);
  56.     struct tm localTime;
  57.     localtime_r(&t, &localTime);
  58.     std::string folderName = "rec_request";
  59.     mkdir(folderName.c_str(), 0777);
  60.     std::string fileName = folderName + "/" + std::to_string(1900 + localTime.tm_year) + "-" + std::to_string(1 + localTime.tm_mon) + "-" + std::to_string(localTime.tm_mday) + ".log";
  62.     // 获取当前时间并格式化
  63.     char timeBuffer[26];
  64.     ctime_r(&t, timeBuffer);
  65.     std::string timeStr(timeBuffer);
  66.     timeStr.pop_back();  // 去除换行符
  68.     // 打开或创建文件并写入时间和请求
  69.     std::ofstream file(fileName, std::ios::app);
  70.     file << timeStr << std::endl;
  71.     file << std::string(64, '=') << std::endl;
  73.     struct sockaddr_in clientAddress;
  74.     socklen_t clientAddressLength = sizeof(clientAddress);
  75.     if (getpeername(clientSocket, (struct sockaddr*)&clientAddress, &clientAddressLength) == -1) {
  76.         std::cerr << "Error getting client IP address" << std::endl;
  77.         return;
  78.     }
  80.     char ipAddressBuffer[INET_ADDRSTRLEN];
  81.     if (inet_ntop(AF_INET, &clientAddress.sin_addr, ipAddressBuffer, INET_ADDRSTRLEN) == NULL) {
  82.         std::cerr << "Error converting IP address" << std::endl;
  83.         return;
  84.     }
  85.     std::string clientIP = std::string(ipAddressBuffer);
  87.     file << "Client IP: " << clientIP << std::endl;
  88.     file << "Request Headers:\n" << request << std::endl;  // 写入请求头
  90.     std::cout << "Received request:\n" << request << std::endl;
  92.     std::string method, uri, version;
  93.     size_t firstSpace = request.find(' ');
  94.     size_t secondSpace = request.find(' ', firstSpace + 1);
  96.     if (firstSpace != std::string::npos && secondSpace != std::string::npos) {
  97.         method = request.substr(0, firstSpace);
  98.         uri = request.substr(firstSpace + 1, secondSpace - firstSpace - 1);
  99.         version = request.substr(secondSpace + 1, request.find("\r\n") - secondSpace - 1);
  100.     }
  101.     else {
  102.         std::cerr << "Invalid request" << std::endl;
  103.         return;
  104.     }
  106.     std::cout << "Method: " << method << ", URI: " << uri << ", Version: " << version << std::endl;
  108.     // 处理根路径和 /message_board
  109.     if (uri == "/" || uri == "/message_board") {
  110.         std::string response = "HTTP/1.1 200 OK\r\n";
  111.         response += "Content-Type: text/html; charset=utf-8\r\n";
  112.         response += "\r\n";
  113.         response += "<html><style>";
  114.         response += "body { font-family: Arial, sans-serif; background-color: #f0f0f0; }";
  115.         response += "h2 { color: #333; }";
  116.         response += ".container { max-width: 800px; margin: 0 auto; padding: 20px; background-color: #fff; border-radius: 8px; box-shadow: 0 0 10px rgba(0, 0, 0, 0.1); }";
  117.         response += ".message-form { margin-bottom: 20px; }";
  118.         response += ".message { border: 1px solid #ccc; padding: 10px; margin: 10px 0; background-color: #fff; word-wrap: break-word; }";
  119.         response += "input[type='text'] { width: 100%; height: 200px; }";
  120.         response += "input[type='submit'] { width: 100%; padding: 10px; font-size: 16px; background-color: #4CAF50; color: white; border: none; border-radius: 4px; cursor: pointer; }";
  121.         response += "input[type='submit']:hover { background-color: #45a049; }";
  122.         response += "</style></head><body>";
  123.         response += "<div class='container'>";
  124.         response += "<h2>留言板</h2>";
  125.         response += "<div class='message-form'><form action='/submit_message' method='post'>";
  126.         response += "留言: <input type='text' name='message' required><br>";
  127.         response += "<input type='submit' value='提交'>";
  128.         response += "</form></div>";
  130.         // 读取并显示留言内容
  131.         std::ifstream logFile("message.txt");
  132.         if (logFile.is_open()) {
  133.             std::string line;
  134.             while (std::getline(logFile, line)) {
  135.                 response += "<div class='message'>" + line + "</div>";
  136.             }
  137.             logFile.close();
  138.         }
  140.         response += "<div style='font-size:12px; color:#999; text-align:center;'>Power by Hank Q:1101773014</div>";
  141.         response += "</div></body></html>";
  143.         send(clientSocket, response.c_str(), response.size(), 0);
  144.     }
  145.     else if (uri == "/submit_message" && method == "POST") {
  146.         size_t contentLengthStart = request.find("Content-Length: ");
  147.         if (contentLengthStart == std::string::npos) {
  148.             std::cerr << "Invalid submit message request" << std::endl;
  149.             return;
  150.         }
  152.         size_t contentLengthEnd = request.find("\r\n", contentLengthStart);
  153.         size_t contentLength = std::stoi(request.substr(contentLengthStart + 16, contentLengthEnd - contentLengthStart - 16));
  155.         size_t bodyStart = request.find("\r\n\r\n") + 4;
  156.         std::string body = request.substr(bodyStart, contentLength);
  157.         size_t messageStart = body.find("message=") + 8;
  158.         std::string submittedMessage = urlDecode(body.substr(messageStart));
  160.         // 过滤 HTML 符号
  161.         submittedMessage = filterHtmlTags(submittedMessage);
  163.         // 获取当前时间
  164.         std::time_t t = std::time(nullptr);
  165.         struct tm localTime;
  166.         localtime_r(&t, &localTime);
  167.         std::ostringstream oss;
  168.         oss << std::put_time(&localTime, "%Y-%m-%d %H:%M:%S");
  170.         // 在写入文件的地方进行修改
  171.         std::ofstream logFile("message.txt", std::ios::app);
  172.         std::wstring_convert<std::codecvt_utf8<wchar_t>> conv;  // 创建编码转换器
  174.         // 假设要写入的字符串是 submittedMessage
  175.         std::wstring wideMessage = conv.from_bytes(submittedMessage);  // 转换为宽字符字符串
  176.         logFile << oss.str() << " " << clientIP << ": " << conv.to_bytes(wideMessage) << std::endl;  // 以 utf-8 编码写入
  177.         logFile.close();
  179.         // 重定向回主页
  180.         std::string response = "HTTP/1.1 303 See Other\r\n";
  181.         response += "Location: /\r\n";
  182.         response += "\r\n";
  184.         send(clientSocket, response.c_str(), response.size(), 0);
  185.     }
  186.     else {
  187.         std::string response = "HTTP/1.1 404 Not Found\r\n";
  188.         response += "Content-Type: text/html\r\n";
  189.         response += "\r\n";
  190.         response += "<html><body>";
  191.         response += "<h2>404 Not Found</h2>";
  192.         response += "</body></html>";
  194.         send(clientSocket, response.c_str(), response.size(), 0);
  195.     }
  197.     close(clientSocket);
  198. }
  200. int main() {
  201.     int serverSocket = socket(AF_INET, SOCK_STREAM, 0);
  202.     if (serverSocket == -1) {
  203.         std::cerr << "Error creating socket" << std::endl;
  204.         return 1;
  205.     }
  207.     struct sockaddr_in serverAddress;
  208.     memset(&serverAddress, 0, sizeof(serverAddress));
  209.     serverAddress.sin_family = AF_INET;
  210.     serverAddress.sin_addr.s_addr = INADDR_ANY;
  211.     serverAddress.sin_port = htons(80);
  213.     if (bind(serverSocket, (struct sockaddr*)&serverAddress, sizeof(serverAddress)) == -1) {
  214.         std::cerr << "Error binding socket" << std::endl;
  215.         close(serverSocket);
  216.         return 1;
  217.     }
  219.     if (listen(serverSocket, 5) == -1) {
  220.         std::cerr << "Error listening on socket" << std::endl;
  221.         close(serverSocket);
  222.         return 1;
  223.     }
  225.     std::cout << "Server is listening on port 80..." << std::endl;
  227.     while (true) {
  228.         struct sockaddr_in clientAddress;
  229.         socklen_t clientAddressLength = sizeof(clientAddress);
  230.         int clientSocket = accept(serverSocket, (struct sockaddr*)&clientAddress, &clientAddressLength);
  231.         if (clientSocket == -1) {
  232.             std::cerr << "Error accepting client connection" << std::endl;
  233.             continue;
  234.         }
  236.         handleRequest(clientSocket);
  237.     }
  239.     close(serverSocket);
  241.     return 0;
  242. }
复制代码
Linux开机启动配置文件
  1. # /etc/systemd/system vi http-server.service
  2. [Unit]
  3. Description=My HTTP Server
  4. After=network.target
  6. [Service]
  7. ExecStart=/root/projects/留言板Linux/bin/x64/Release/留言板Linux.out
  8. WorkingDirectory=/root/projects/留言板Linux/bin/x64/Release
  9. User=root
  10. Group=root
  11. Restart=always
  13. [Install]
  14. WantedBy=multi-user.target
复制代码
启动代码
  1. sudo systemctl daemon-reload
  2. sudo systemctl enable http-server.service
  3. sudo systemctl start http-server.service
  4. systemctl status http-server.service # 看到 active (running) 就成功了
复制代码

http://1.92.93.88/

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

科技颠覆者

论坛元老
这个人很懒什么都没写!

楼主热帖

标签云

AI 运维 CIO 存储 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表