[學(xué)習(xí)]網(wǎng)絡(luò)編程5-多線程服務(wù)器

1、多線程服務(wù)器,,大綱,多線程服務(wù)器模型多線程例程代碼講解作業(yè)講解,循環(huán)服務(wù)器:UDP服務(wù)器,UDP循環(huán)服務(wù)器的實現(xiàn)非常簡單:UDP服務(wù)器每次從套接字上讀取一個客戶端的請求,處理, 然后將結(jié)果返回給客戶機(jī).,算法,socket(...);   bind(...);   while(1)    {     &#

2、160;   recvfrom(...);         process(...);         sendto(...);   },,因為UDP是非面向連接的,沒有一個客戶端可以一直占住服務(wù)端. 只要處理過程不是死循環(huán), 服務(wù)器

3、對于每一個客戶機(jī)的請求總是能夠滿足.,循環(huán)服務(wù)器:TCP服務(wù)器,TCP循環(huán)服務(wù)器的實現(xiàn)也不難:TCP服務(wù)器接受一個客戶端的連接,然后處理,完成了這個客戶的所有請求后,斷開連接.,算法,socket(...); bind(...); listen(...); while(1) {            accept(...);&

4、#160;            while(1) {                        rea

5、d(...);                        process(...);          

6、;              write(...);             }         

7、;    closesocket(...); },UDP和TCP循環(huán)式服務(wù)器對比,socket(...);bind(...);while(1){         recvfrom(...);         process(...

8、);         sendto(...);},socket(...); bind(...); listen(...); while(1) {            accept(...);     &

9、#160;       while(1) {                        read(...);   

10、;                     process(...);              

11、          write(...);             }             close

12、socket(...); },,TCP循環(huán)服務(wù)器一次只能處理一個客戶端的請求.只有在這個客戶的所有請求都滿足后, 服務(wù)器才可以繼續(xù)后面的請求.這樣如果有一個客戶端占住服務(wù)器不放時,其它的客戶機(jī)都不能工作了.因此,TCP服務(wù)器一般很少用簡單的循環(huán)服務(wù)器模型。,,為了彌補(bǔ)循環(huán)TCP服務(wù)器的缺陷,人們提出了多路復(fù)用和并發(fā)服務(wù)器的模型.,并發(fā)服務(wù)器:多路復(fù)用I/O,初始化(socket,bind,listen); 

13、0;  while(1)        {        設(shè)置要監(jiān)聽讀寫文件描述符(FD_*);              

14、60;    調(diào)用select;                if(監(jiān)聽套接字就緒)//說明一個新的連接請求建立 {         

15、       建立連接(accept);                加入到監(jiān)聽文件描述符中去;         

16、 } else //有已經(jīng)連接過的文件描述符有數(shù)據(jù)響應(yīng) {                    對相應(yīng)的文件描述符進(jìn)行操作(read或者write);      &

17、#160;  }                                },,多路復(fù)用I/O可以解決資源限制的

18、問題.該模型實際上是將UDP循環(huán)模型用在了TCP上面.由于服務(wù)器依次處理客戶的請求,所以可能會導(dǎo)致有的客戶會等待很久.,,并發(fā)服務(wù)器的思想是每一個客戶機(jī)的請求并不由服務(wù)器直接處理,而是服務(wù)器創(chuàng)建一個子線程來處理.,,算法(監(jiān)聽線程),socket(...);bind(...);listen(...);while(1){        accept(...);

19、 _beginthread(workthread,…);},算法(工作子線程),workthread() {              while(1)           

20、    {                        read(...);        &

21、#160;  process(...);           write(...);               } closesocket(...);&

22、#160; },CreateThread,HANDLE WINAPI CreateThread(_In_opt_ LPSECURITY_ATTRIBUTES lpThreadAttributes,_In_ SIZE_T dwStackSize,_In_ LPTHREAD_START_ROUTINE lpStartAddress, _In_opt_ LPVOID lpParamete

23、r,_In_ DWORD dwCreationFlags,_Out_opt_ LPDWORD lpThreadId);,beginthread,uintptr_t _beginthread( // NATIVE CODEvoid( __cdecl *start_address )( void * ),unsigned stack_size,void *arglist );,beginthr

24、eadex,uintptr_t _beginthreadex( // NATIVE CODEvoid *security,unsigned stack_size,unsigned ( __stdcall *start_address )( void * ),void *arglist,unsigned initflag,unsigned *thrdaddr );,,TCP并發(fā)服務(wù)器可以解決TCP循環(huán)