WebServer构建相应 && 发送相应

1.构建相应

• 构建相应流程如下
  
  
  
  • 确认方法
    
  • 根据不同方法，以不同方法提参
    
  • 确认访问资源
    
  
  
• 如果用户的URL没有指明要访问的某种资源(路径)，虽然浏览器默认会添加/，但是依旧没有告知服务器，要访问什么资源
  
  
  
  • 此时，默认返回对应服务的首页
    
  • 这里的/不是Linux服务器的根目次，通常是http服务器设置的自己的WEB根目次
    
  
  
• 关于stat
  
  
  
  • stat()返回一个文件的信息，信息都存在一个struct stat结构体变量中
    
    
    
    • 细节可以：man 2 stat
      
    
    
  • struct stat可以判断
    
    
    
    • 是否是一个可实验程序
      
    • 该文件的巨细
      
    • …
      
    
    
  
  
• 判断文件是否是可实验程序
  
  
  
  • 若不是，则走ProcessNonCgi逻辑，返回静态网页
    
  • 如果，则走ProcessCgi逻辑，将参数传递给子程序处置惩罚
    
  
  
• 请求资源是什么范例，取决于资源的后缀
  
• 为什么要利用goto？
  
  
  
  • 分析协议的每一步，都有大概堕落
    
  • 所以在做堕落处置惩罚的时候，如果没有goto，会导致利用大量的if判断
    
  
  

1. void BuildResponse()
2. {
3.     size_t pos = 0;
4.     if (_request.method != "GET" && _request.method != "POST")
5.     {
6.         // 非法请求
7.         _response.status_code = BAD_REQUEST; // TODO
8.         LOG(WARNING, "Method is not right");
9.         goto END;
10.     }
12.     if (_request.method == "GET")
13.     {
14.         // GET可能带参数，也可能不带参数，要区分出来
15.         if (_request.uri.find('?') != std::string::npos)
16.         {
17.             Util::CutString(_request.uri, _request.path, _request.arg, "?");
18.             _request.cgi = true;
19.         }
20.         else
21.         {
22.             _request.path = _request.uri;
23.         }
24.     }
25.     else if(_request.method == "POST")
26.     {
27.         _request.cgi = true;
28.         _request.path = _request.uri;
29.     }
30.     else
31.     {
32.         // Do Nothing
33.     }
35.     _request.path.insert(0, WEB_ROOT); // 从根目录开始
37.     // 如果访问的是根目录，则默认访问主页
38.     if(_request.path[_request.path.size() - 1] == '/')
39.     {
40.         _request.path += HOME_PAGE;
41.     }
43.     // 确认访问资源是否存在
44.     struct stat st;
45.     if(stat(_request.path.c_str(), &st) == 0) // TODO  待整理stat()
46.     {
47.         // 访问的是否是一个具体资源？
48.         if(S_ISDIR(st.st_mode))
49.         {
50.             // 请求的是一个目录，需要特殊处理 -- 改为访问该目录下主页
51.             // 虽然是目录，但是绝对不会以/结尾
52.             _request.path += "/";
53.             _request.path += HOME_PAGE;
55.             // 上面更改了path指向，所以重新获取文件状态
56.             stat(_request.path.c_str(), &st);
57.         }
59.         // 是否是一个可程序程序？
60.         if (st.st_mode & S_IXUSR || st.st_mode & S_IXGRP || st.st_mode & S_IXOTH)
61.         {
62.             _request.cgi = true; // TODO CGI标志位感觉有多余
63.         }
65.         _response.fSize = st.st_size;
66.     }
67.     else
68.     {
69.         // 资源不存在
70.         LOG(WARNING, _request.path + " Not Found");
71.         _response.status_code = NOT_FOUND;
72.         goto END;
73.     }
75.     // 读取文件后缀
76.     pos = _request.path.rfind('.');
77.     if (pos== std::string::npos)
78.     {
79.         _request.suffix = ".html"; // 没找到就默认设置为html
80.     }
81.     else
82.     {
83.         _request.suffix = _request.path.substr(pos);
84.     }
86.     if(_request.cgi)
87.     {
88.         _response.status_code = ProcessCgi(); // 执行目标程序，拿到结果到_response.response_body
89.     }
90.     else
91.     {
92.         // 1.至此，目标网页一定是存在的
93.         // 2.返回并不是单单返回网页，而是要构建HTTP响应
94.         _response.status_code = ProcessNonCgi(); // 简单的网页返回，返回静态网页，只需要打开即可
95.     }
97.     END:
98.     // 最后统一构建响应
99.     BuildResponseHelper();
101.     return;
102. }
104. void BuildResponseHelper()
105. {
106.     // 此处status_line是干净的，没有内容的
107.     // 构建状态行
108.     _response.status_line += HTTP_VERSION;
109.     _response.status_line += " ";
110.     _response.status_line += std::to_string(_response.status_code);
111.     _response.status_line += " ";
112.     _response.status_line += Util::Code2Desc(_response.status_code);
113.     _response.status_line += LINE_END;
115.     // 构建响应正文，可能包括响应报头
116.     std::string path = WEB_ROOT;
117.     path += '/';
119.     switch (_response.status_code)
120.     {
121.         case OK:
122.             BuildOKResponse();
123.             break;
124.         case NOT_FOUND:
125.             path += PAGE_404;
126.             HandlerError(path);
127.             break;
128.         case BAD_REQUEST:  // 暂时先404处理，后面有需要再改
129.             path += PAGE_404;
130.             HandlerError(path);
131.             break;
132.         case SERVER_ERROR:
133.             path += PAGE_404;
134.             HandlerError(path);
135.             break;
136.         default:
137.             break;
138.     }
139. }
141. void BuildOKResponse()
142. {
143.     // Header
144.     std::string header_line = "Content-Type: ";
145.     header_line += Util::Suffix2Desc(_request.suffix);
146.     header_line += LINE_END;
147.     _response.response_header.push_back(header_line);
149.     header_line = "Content-Length: ";
150.     if(_request.cgi)
151.     {
152.         header_line += std::to_string(_response.response_body.size());
153.     }
154.     else
155.     {
156.         header_line += std::to_string(_response.fSize);
157.     }
158.     header_line += LINE_END;
159.     _response.response_header.push_back(header_line);
160. }

复制代码

2.发送相应

• 注意：
  
  
  
  • 分多次发和把所有内容合成一个字符串一次性发送是没区别的
    
  • send只是把内容拷贝到发送缓冲区中
    
  • 具体什么时候发，一次性发多少，是由TCP决定的
    
  
  
• 此处_response.response_body发送逻辑确保了_response.response_body能全部发完
  
• 此次请求为ProcessNonCgi时，必要从磁盘读取文件内容，再把内容拷贝到发送缓冲区中，这样是效率低下的
  
  
  
  • sendfile()可以在两个文件形貌符之间拷贝数据
    
    
    
    • 即：sendfile()可以把文件内容，直接拷贝到Tcp的发送缓冲区中，进步了效率
      
    
    
  • 这个拷贝着实内核态完成的，所以比read() / write()高效的多
    
  
  

1. void SendResponse()
2. {
3.     send(_sock, _response.status_line.c_str(), _response.status_line.size(), 0);
4.     for(auto& str : _response.response_header)
5.     {
6.         send(_sock, str.c_str(), str.size(), 0);
7.     }
8.     send(_sock, _response.blank.c_str(), _response.blank.size(), 0);
10.     if(_request.cgi)
11.     {
12.         const char *start = _response.response_body.c_str();
13.         size_t size = 0, total = 0;
15.         while (total < _response.response_body.size() &&
16.                (size = send(_sock, start + total, _response.response_body.size() - total, 0) > 0))
17.         {
18.             total += size;
19.         }
20.     }
21.     else
22.     {
23.         sendfile(_sock, _response.fd, nullptr, _response.fSize);
24.         close(_response.fd);
25.     }
26. }

复制代码

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