DragonOS-Community
/
DragonOS
şunun yansıması https://github.com/DragonOS-Community/DragonOS.git


			
				
					
						
						
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215
							#include <arpa/inet.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <unistd.h>

#define PORT 12580
#define MAX_REQUEST_SIZE 1500
#define MAX_RESPONSE_SIZE 1500
// 网页根目录
#define WEB_ROOT "/var/www/html/"
#define EXIT_CODE 1
#define min(a, b) ((a) < (b) ? (a) : (b))

#define DEFAULT_PAGE "/index.html"

static int request_counter = 0;

int security_check(char *path) {
  // 检查路径是否包含 ..
  if (strstr(path, "..")) {
    return 0;
  }
  return 1;
}

ssize_t send_response(int sockfd, char *response) {
  return write(sockfd, response, strlen(response));
}

void send_header(int sockfd, int content_length, char *path) {
  char buffer[MAX_RESPONSE_SIZE];
  // 获取文件类型
  char *content_type;
  if (strstr(path, ".html")) {
    content_type = "text/html";
  } else if (strstr(path, ".css")) {
    content_type = "text/css";
  } else if (strstr(path, ".js")) {
    content_type = "application/javascript";
  } else if (strstr(path, ".png")) {
    content_type = "image/png";
  } else if (strstr(path, ".jpg")) {
    content_type = "image/jpeg";
  } else if (strstr(path, ".gif")) {
    content_type = "image/gif";
  } else {
    content_type = "text/plain;charset=utf-8";
  }
  sprintf(buffer, "HTTP/1.1 200 OK\nContent-Type: %s\nContent-Length: %d\n\n",
          content_type, content_length);
  send_response(sockfd, buffer);
}

void send_file(int sockfd, char *path) {
  printf("send_file: path: %s\n", path);

  int fd = open(path, 0);
  if (fd == -1) {
    send_response(sockfd,
                  "HTTP/1.1 404 Not Found\nContent-Type: "
                  "text/html\n\n<html><body><h1>404 Not Found</h1><p>DragonOS "
                  "Http Server</p></body></html>");
    return;
  }

  int content_length = lseek(fd, 0, SEEK_END);
  int remaining = content_length;
  printf("send_file: content_length: %d\n", content_length);
  lseek(fd, 0, SEEK_SET);
  send_header(sockfd, content_length, path);

  char buffer[1048576];
  int readSize;
  while (remaining) {
    // 由于磁盘IO耗时较长，所以每次读取1MB，然后再分批发送
    int to_read = min(1048576, remaining);
    readSize = read(fd, &buffer, to_read);

    remaining -= readSize;
    void *p = buffer;
    while (readSize > 0) {
      int wsize = write(sockfd, p, min(readSize, MAX_RESPONSE_SIZE));
      if (wsize <= 0) {
        printf("send_file failed: wsize: %d\n", wsize);
        close(fd);
        return;
      }
      p += wsize;
      readSize -= wsize;
    }
  }

  close(fd);
}

void handle_request(int sockfd, char *request) {
  char *method, *url, *http_version;
  char path[MAX_REQUEST_SIZE];

  method = strtok(request, " ");
  url = strtok(NULL, " ");
  http_version = strtok(NULL, "\r\n");

  printf("handle_request: method: %s, url: %s, http_version: %s\n", method, url,
         http_version);
  // 检查空指针等异常情况
  if (method == NULL || url == NULL || http_version == NULL) {
    send_response(sockfd,
                  "HTTP/1.1 400 Bad Request\nContent-Type: "
                  "text/html\n\n<html><body><h1>400 Bad "
                  "Request</h1><p>DragonOS Http Server</p></body></html>");
    return;
  }
  // 检查url是否为空
  if (strlen(url) == 0) {
    send_response(sockfd,
                  "HTTP/1.1 400 Bad Request\nContent-Type: "
                  "text/html\n\n<html><body><h1>400 Bad "
                  "Request</h1><p>DragonOS Http Server</p></body></html>");
    return;
  }
  int default_page = 0;
  if (url[strlen(url) - 1] == '/') {
    default_page = 1;
  }

  if (strcmp(method, "GET") == 0) {
    if (default_page) {
      sprintf(path, "%s%s%s", WEB_ROOT, url, DEFAULT_PAGE);
    } else {
      sprintf(path, "%s%s", WEB_ROOT, url);
    }
    if (!security_check(path)) {
      send_response(sockfd,
                    "HTTP/1.1 403 Forbidden\nContent-Type: "
                    "text/html\n\n<html><body><h1>403 "
                    "Forbidden</h1><p>DragonOS Http Server</p></body></html>");
      return;
    }
    send_file(sockfd, path);
  } else {
    send_response(sockfd,
                  "HTTP/1.1 501 Not Implemented\nContent-Type: "
                  "text/html\n\n<html><body><h1>501 Not "
                  "Implemented</h1><p>DragonOS Http Server</p></body></html>");
  }
}

int main(int argc, char const *argv[]) {
  int server_fd, new_socket, valread;
  struct sockaddr_in address;
  int addrlen = sizeof(address);
  char buffer[MAX_REQUEST_SIZE] = {0};
  int opt = 1;

  // 创建socket
  if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
    perror("socket failed");
    exit(EXIT_CODE);
  }

  // 设置socket选项，允许地址重用
  // if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt,
  // sizeof(opt)))
  // {
  //     perror("setsockopt failed");
  //     exit(EXIT_CODE);
  // }

  // 设置地址和端口
  address.sin_family = AF_INET;
  address.sin_addr.s_addr = INADDR_ANY;
  address.sin_port = htons(PORT);

  // 把socket绑定到地址和端口上
  if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
    perror("bind failed");
    exit(EXIT_CODE);
  }

  // 监听socket
  if (listen(server_fd, 3) < 0) {
    perror("listen failed");
    exit(EXIT_CODE);
  }

  while (1) {
    printf("[#%d] Waiting for a client...\n", request_counter++);

    // 等待并接受客户端连接
    if ((new_socket = accept(server_fd, (struct sockaddr *)&address,
                             (socklen_t *)&addrlen)) < 0) {
      perror("accept failed");
      exit(EXIT_CODE);
    }

    // 接收客户端消息
    valread = read(new_socket, buffer, MAX_REQUEST_SIZE);
    printf("%s\n", buffer);

    // 处理请求
    handle_request(new_socket, buffer);

    // 关闭客户端连接
    close(new_socket);
  }
  // 关闭tcp socket
  close(server_fd);

  return 0;
}