Http服務器實現(xiàn)文件上傳與下載(二)
一、引言
在上一節(jié)中已經(jīng)講到了請求頭字符串的解析,并且在解析中我我們已經(jīng)獲取了url。就是上節(jié)中提到的/doing。當瀏覽器發(fā)送了/doing請求后,這是的與服務器的連接并沒有中斷,原因無他,就是瀏覽器等待接受服務端發(fā)來的信息,然后他對信息進行解析并顯示在瀏覽器界面上。在編寫Http服務器時的C/S結(jié)構(gòu)時,我只編寫服務端server,客戶端直接用現(xiàn)成的瀏覽器即可。
當服務端找到瀏覽器需要的內(nèi)容的時候,現(xiàn)在服務端就需要把內(nèi)容發(fā)送給瀏覽器即可。但是在HTTP協(xié)議中,發(fā)送具體內(nèi)容之前,服務端還是要發(fā)送一個響應頭,之前瀏覽器發(fā)送的叫做請求頭,那么服務端也要發(fā)送一個響應頭告訴瀏覽器,說你的請求我接受或者拒接。拒絕的話之后就沒有具體實體內(nèi)容發(fā)送,否則再告訴瀏覽器說你請求的內(nèi)容的格式是html或者text,或者是音頻等二進制文件等,并且告訴瀏覽器你請求內(nèi)容的大小(這個非常重要)。當響應頭發(fā)送完畢后,如果是同意瀏覽器的請求的話,那么接著發(fā)送具體的內(nèi)容即可,接著關(guān)閉這個鏈接。
二、HTTP協(xié)議
現(xiàn)在我們來看一下這個響應頭的一個例子,還是只說明一些我們現(xiàn)在需要知道的,其他內(nèi)容讀者可以自己去查找相關(guān)的內(nèi)容。
1 HTTP/1.1 200 OK 2 Server:(Unix) 3 Content-type:application/octet-stream 4 Content-length:65144369 5 Connection:Keep-Alive
在這個例子中的響應頭我們可以看到:
1)在***行就告訴瀏覽器http協(xié)議的版本是1.1,狀態(tài)碼是200,意思是OK,就是說你的請求我同意了。
2)在第二行就是告知瀏覽器我服務器的名字。
3)在第三行就是你請求的內(nèi)容的格式是applicaiton/octet-stream,理解為二進制流即可。
4)在第四行說明你請求內(nèi)容的大小,單位是字節(jié)。
5)第五行告訴瀏覽器是Keep-Alive連接方式。
在這個協(xié)議頭發(fā)送給瀏覽器時,還是每行結(jié)尾都有一個回車換行\(zhòng)r\n。***還是需要一個空行代表本響應頭結(jié)束。還有一些協(xié)議內(nèi)容到用用到時再講,現(xiàn)在提出這幾項即可。當這個協(xié)議頭發(fā)送給瀏覽器后,瀏覽器對其解析。然后等待真正的請求內(nèi)容。當服務端把瀏覽器的請求的具體內(nèi)容發(fā)送完畢就關(guān)閉這個連接。
講到這里基本一個請求響應結(jié)束了。那在這里提一下如何處理大并發(fā)呢。其實在HTTP請求中,在每個URL請求中服務器并不關(guān)心一些請求是否來著同個瀏覽器,服務器做的只是有請求來臨就對其連接發(fā)送數(shù)據(jù),然后關(guān)閉數(shù)據(jù)。盡管可能來著同一客戶端上的請求有數(shù)據(jù)上的關(guān)系,但是服務端只是在發(fā)送數(shù)據(jù)而已。所以對于同一個瀏覽器發(fā)送的多個請求和不同瀏覽器或者不同主機發(fā)送來的請求的對待都是一樣的。就是每個請求都是獨立的,并不關(guān)心這個邏輯關(guān)系。
在這一篇中的主要內(nèi)容也就講完了,好像看起來比較短哦,哈哈。。。。。那么在講一些細節(jié)上的內(nèi)容吧。
現(xiàn)在大并發(fā)的服務器linux中,主要在有線程,進程,select,poll,epoll的方式。這些方式在各個博客上都是有的,所以我并不想在解釋一下,讀者可以自己查詢其中的不同之處。而本文開發(fā)的HTTP服務器采用線程的方式進行。主要是當一個請求來到時,就創(chuàng)建一個線程來處理。采用的linux下POSIX標準pthtread線程。如果其他讀者可以采用其他的幾種方式來處理?;蛘咦约簩憘€線程池來取代每次一個請求來創(chuàng)建一個線程。主要對其包裹在一個命名空間為MultiThread的線程Thread類中,接著是一些代碼段:
頭文件(include/thread.h):
1 /* 2 * include/thread.h 3 */ 4 5 #ifndef THREAD_H_ 6 #define THREAD_H_ 7 #include8 #include 9 namespace MultiThread { 10 11 class Thread { 12 public: 13 Thread(); 14 ~Thread(); 15 static int create_thread(pthread_t &pid,void* (*pFunc)(void *),void *arg); 16 int stop_thread(); 17 18 }; 19 20 } /* namespace MultiThread */ 21 22 #endif /* THREAD_H_ */
cpp文件(src/thread.cpp)
1 /** 2 * 3 * src/thread.cpp 4 **/ 5 #include "thread.h" 6 namespace MultiThread { 7 8 Thread::Thread() { 9 } 10 11 Thread::~Thread() { 12 } 13 14 int Thread::create_thread(pthread_t &pid,void* (*pFunc)(void *),void *arg) { 15 int ret=pthread_create(&pid,NULL,pFunc,arg); 16 if(ret==0) 17 std::cout<<"create_thread() ...succeed"< 18 else 19 std::cout<<"create_thread() ...failed"< 20 return ret; 21 } 22 23 int Thread::stop_thread() { 24 return 0; 25 } 26 27 } /* namespace MultiThread */
看到現(xiàn)在,大家一定發(fā)現(xiàn)stop_thread()為空,應為我到現(xiàn)在還沒用這個函數(shù)。并且到現(xiàn)在只用到create_thread函數(shù),之后如果用到,接著在之后的文章中提出吧。