網(wǎng)絡(luò)編程5-多線程服務(wù)器

1、多線程服務(wù)器大綱 多線程服務(wù)器模型 多線程例程代碼講解 作業(yè)講解循環(huán)服務(wù)器:udp服務(wù)器 udp循環(huán)服務(wù)器的實(shí)現(xiàn)非常簡(jiǎn)單:udp服務(wù)器每次從套接字上讀取一個(gè)客戶端的請(qǐng)求,處理, 然后將結(jié)果返回給客戶機(jī).算法 socket(.); bind(.); while(1) recvfrom(.); process(.); sendto(.); 因?yàn)閡dp是非面向連接的,沒有一個(gè)客戶端可以一直占住服務(wù)端. 只要處理過程不是死循環(huán), 服務(wù)器對(duì)于每一個(gè)客戶機(jī)的請(qǐng)求總是能夠滿足.循環(huán)服務(wù)器:tcp服務(wù)器 tcp循環(huán)服務(wù)器的實(shí)現(xiàn)也不難:tcp服務(wù)器接受一個(gè)客戶端的連接,然后處理,完成了這個(gè)客戶的所有請(qǐng)求后,斷開

2、連接.算法 socket(.); bind(.); listen(.); while(1) accept(.); while(1) read(.); process(.); write(.); closesocket(.); udp和tcp循環(huán)式服務(wù)器對(duì)比socket(.);bind(.);while(1) recvfrom(.); process(.); sendto(.); socket(.); bind(.); listen(.); while(1) accept(.); while(1) read(.); process(.); write(.); closesocket(.); tc

3、p循環(huán)服務(wù)器一次只能處理一個(gè)客戶端的請(qǐng)求.只有在這個(gè)客戶的所有請(qǐng)求都滿足后, 服務(wù)器才可以繼續(xù)后面的請(qǐng)求.這樣如果有一個(gè)客戶端占住服務(wù)器不放時(shí),其它的客戶機(jī)都不能工作了.因此,tcp服務(wù)器一般很少用簡(jiǎn)單的循環(huán)服務(wù)器模型。 為了彌補(bǔ)循環(huán)tcp服務(wù)器的缺陷,人們提出了多路復(fù)用和并發(fā)服務(wù)器的模型. 并發(fā)服務(wù)器:多路復(fù)用i/o 初始化(socket,bind,listen); while(1) 設(shè)置要監(jiān)聽讀寫文件描述符(fd_*); 調(diào)用select; if(監(jiān)聽套接字就緒)/說明一個(gè)新的連接請(qǐng)求建立 建立連接(accept); 加入到監(jiān)聽文件描述符中去; else /有已經(jīng)連接過的文件描述符有數(shù)據(jù)響

4、應(yīng) 對(duì)相應(yīng)的文件描述符進(jìn)行操作(read或者write); 多路復(fù)用i/o可以解決資源限制的問題.該模型實(shí)際上是將udp循環(huán)模型用在了tcp上面.由于服務(wù)器依次處理客戶的請(qǐng)求,所以可能會(huì)導(dǎo)致有的客戶會(huì)等待很久. 并發(fā)服務(wù)器的思想是每一個(gè)客戶機(jī)的請(qǐng)求并不由服務(wù)器直接處理,而是服務(wù)器創(chuàng)建一個(gè)子線程來處理.算法(監(jiān)聽線程)socket(.);bind(.);listen(.);while(1) accept(.); _beginthread(workthread,); 算法(工作子線程) workthread() while(1) read(.); process(.); write(.); clo

5、sesocket(.); createthread handle winapi createthread(_in_opt_ lpsecurity_attributes lpthreadattributes,_in_ size_t dwstacksize,_in_ lpthread_start_routine lpstartaddress, _in_opt_ lpvoid lpparameter,_in_ dword dwcreationflags,_out_opt_ lpdword lpthreadid);beginthread uintptr_t _beginthread( / native

6、 codevoid( _cdecl *start_address )( void * ),unsigned stack_size,void *arglist );beginthreadex 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)服務(wù)器客戶機(jī)獨(dú)占服務(wù)器的情況. 不過也同時(shí)帶來了一個(gè)不小的問題