高并發(fā)網(wǎng)絡(luò)編程開發(fā)10-linux系統(tǒng)第13天epoll udp和

1、學(xué)習(xí)目標(biāo)1.2.3.4.了解poll操作函數(shù)熟練使用epoll多路IO模型了解epoll ET/LT觸發(fā)模式說出UDP的通信流程分區(qū) 13-epoll和udp 的第 1 頁(yè)復(fù)習(xí)1.2.tcp狀態(tài)轉(zhuǎn)換selectfd_set - 1024select(maxfd+1, timeout)sizeof(fd_set) = 128&reads, &write, &expt,NULL -阻塞timeval val = 1,0;structreads-傳入傳出參數(shù)FD_ZERO(fd_set*);FD_SET(fd, fd_set*); FD_ISSET(fd, fd_set*); FD_CLR(fd,

2、fd_set*);思路/將待檢測(cè)的數(shù)據(jù)初始化到fd_set集合中/select();/ 判讀fd是否是的/ 已經(jīng)連接的客戶端發(fā)送來的數(shù)據(jù)for();fd_isset(i, &reads);分區(qū) 13-epoll和udp 的第 2 頁(yè)while(1)循環(huán)的委托內(nèi)核檢測(cè)1 - epoll三個(gè)函數(shù):-該函數(shù)生成一個(gè)epoll的文件描述符size);typedef union epoll_data epoll_creae(void*ptr; fd; u32; u64;size: epoll上能關(guān)注的最大描述符數(shù)用于控制某個(gè)epoll文件描述符事件，可以注冊(cè)、修改、刪除-uu32_t64_tepoll_

3、ctl(epfd,op,fd, epoll_data_t;struct epoll_event *event);參數(shù):struct epoll_event epfd: epoll_create生成的epollop:描述符u32_tevents;epoll_data_t data;EPOLL_CTL_ADDEPOLL_CTL_MODEPOLL_CTL_DELfd: 關(guān)聯(lián)的文件描述符event: 告訴內(nèi)核要-;修改刪除events:-EPOLLIN - 讀EPOLLOUT - 寫EPOLLERR - 異常什么事件-等待IO事件發(fā)生 - 可以設(shè)置阻塞的函數(shù)epoll_wait( epfd,struc

4、t epoll_event* events, / 數(shù)組maxevents,timeout);對(duì)應(yīng)select和poll函數(shù)參數(shù):epfd: 要檢測(cè)的句柄 events：用于回傳待處理事件的數(shù)組 maxevents：告訴內(nèi)核這個(gè)events的大小timeout：為超時(shí)時(shí)間 -1:阻塞 0: 立即返回 0:分區(qū) 13-epoll和udp 的第 3 頁(yè)- 1-1- epoll樹structepoll_eventepoll_createepfdepoll_ctl(epfd, EPOLL_CTL_ADD,cfd,&ev)epoll_ctl(epfd, EPOLL_CTL_ADD,lfd,&ev)u32_

5、t eventsu32_t eventsepoll_data_t dataepoll_data_t datatypedef union epoll_data void*ptr; fd; u32; u64;uu32_t64_t epoll_data_t;分區(qū) 13-epoll和udp 的第 4 頁(yè)- 1-2epoll模型10:27main()/ 創(chuàng)建lfd/ 綁定bind();/ listen();的套接字socket();=/ epoll樹根節(jié)點(diǎn)epfd = epoll_create(3000);發(fā)送變化的fd對(duì)應(yīng)信息/struct epoll_event all3000;/ init的lfd

6、掛到epoll樹上/struct epoll_event ev;/ 在ev中init lfd信息 ev.events = EPOLLIN ; ev.data.fd = lfd; epoll_ctl(epfd, EPOLL_CTL_ADD, while(1)/ 委托內(nèi)核檢測(cè)事件&ev);lfd,ret = epoll_wait(epfd, all, 3000, -1);/ 根據(jù)ret遍歷all數(shù)組i=0; i客戶端/客戶端-服務(wù)器發(fā)送一個(gè)數(shù)據(jù)包心跳包看成一個(gè)協(xié)議應(yīng)用層協(xié)議判斷網(wǎng)絡(luò)是否斷開有多個(gè)連續(xù)的心跳包沒收到/沒有回復(fù)關(guān)閉通信的套接字重連重新初始套接字繼續(xù)發(fā)送心跳包2客戶端-乒乓包-比心跳包攜

7、帶的數(shù)據(jù)多一些除了知道連接是否存在, 還能獲取一些信息分區(qū) 13-epoll和udp 的第 10 頁(yè)5 - UDP通信1.tcp - 面向連接的安全的數(shù)據(jù)包通信a. 基于流 sock_streamudp - 面向無連接不安全報(bào)文傳輸2.3.通信流程服務(wù)器端:創(chuàng)建套接字- socket第二個(gè)參數(shù): SOCK_DGRAM綁定IP和端口: bindfdstruct sockaddr - 服務(wù)器通信接收數(shù)據(jù): recvfromssize_t recvfrom(*buf, size_t len,sockfd, voidflags,structsockaddr *src_addr, socklen_t*a

8、ddrlen);fd - 文件描述符buf: 接收數(shù)據(jù)緩沖區(qū) len: buf的最大容量 flags: 0src_addr: 另一端的IP和端口, 傳出參數(shù)addrlen: 傳入傳出參數(shù) 發(fā)送數(shù)據(jù): sendtossize_dto(sockfd, const void分區(qū) 13-epoll和udp 的第 11 頁(yè)*buf, size_t len,flags, const structsockaddr *dest_addr, socklen_taddrlen);sockfd: socket函數(shù)創(chuàng)建出來的發(fā)送的數(shù)據(jù)buf:len: 發(fā)送的數(shù)據(jù)的長(zhǎng)度flags: 0dest_addr: 另一端的IP和端口addrlen: dest_addr長(zhǎng)度udp服務(wù)器端: 需要一個(gè)套接字, 通信客戶端:創(chuàng)建一個(gè)用于通信的套接字: socket通信發(fā)送數(shù)據(jù): sendto需要先準(zhǔn)備好一個(gè)結(jié)構(gòu)體: structsockaddr_in服務(wù)器的IP和端口 接收數(shù)據(jù): recvformudp的數(shù)據(jù)是不安全的, 容易丟包丟包, 丟全部還