??IO多路復用通過某種機制使進程監(jiān)聽某些文件描述符，當文件描述符中有讀或?qū)懢途w時，進程能夠收到系統(tǒng)內(nèi)核發(fā)送的相應通知從而進行相應的IO操作；IO多路復用有：select、poll、epoll等模式，這里主要介紹select；select本質(zhì)上也是同步IO，調(diào)用時阻塞自己，IO事件就緒后被喚醒返回負責讀寫操作；

站在用戶的角度思考問題，與客戶深入溝通，找到米易網(wǎng)站設計與米易網(wǎng)站推廣的解決方案，憑借多年的經(jīng)驗，讓設計與互聯(lián)網(wǎng)技術(shù)結(jié)合，創(chuàng)造個性化、用戶體驗好的作品，建站類型包括：成都網(wǎng)站設計、成都網(wǎng)站建設、企業(yè)官網(wǎng)、英文網(wǎng)站、手機端網(wǎng)站、網(wǎng)站推廣、空間域名、網(wǎng)站空間、企業(yè)郵箱。業(yè)務覆蓋米易地區(qū)。

在Go中其函數(shù)定義如下：

func Select(nfd int, r *FdSet, w *FdSet, e *FdSet, timeout 
*Timeval) (n int, err error)

FdSet定義：

type FdSet struct {
  Bits [16]int64
}

select函數(shù)實現(xiàn)IO多路復用，通過其參數(shù)通知內(nèi)核：

?? 1、關(guān)注的文件描述符
?? 2、關(guān)心的文件描述符的哪種狀態(tài)：可讀、可寫還是異常
?? 3、等待時間，無限等待阻塞或是固定超時時間

函數(shù)參數(shù)

??通過上面的介紹可以知道我們需要有這么幾種參數(shù)傳遞給select函數(shù)，所關(guān)注的描述符，所關(guān)注的狀態(tài)、等待時間；

函數(shù)參數(shù)具體含義：

??nfd(maxfd): 文件描述符集合中要監(jiān)聽的文件描述符個數(shù)，0-(maxfd-1)為需要檢測的文件描述符;
??r(readfds)： 讀監(jiān)控文件描述符集，監(jiān)控文件描述符集的讀變化，如文件描述符集中有文件可讀即通過該參數(shù)回傳有變化的描述符，清空無變化的描述符；
??w(writefds): 寫監(jiān)控文件描述符集，監(jiān)控文件描述符集的寫變化，如文件描述符集中有文件可寫即通過該參數(shù)回傳有變化的描述符，清空無變化的描述符；
??e(exceptfds)： 異常監(jiān)控文件描述符集，監(jiān)控文件描述符集的異常，如文件描述符集中有文件異常即通過該參數(shù)回傳有變化的描述符，清空無變化的描述符；
??timeout參數(shù)： 傳入nil時函數(shù)無限阻塞等待，整數(shù)值為超時時間；

??上面三個文件描述符集合如無需關(guān)注某一類狀態(tài)可傳入nil，則select將不監(jiān)控文件描述符的讀、寫或異常；
??tcp連接中可只需關(guān)注是否可讀即可；

函數(shù)返回：

??通過函數(shù)返回可知這么兩類信息：
??1、準備好的文件描述符個數(shù)
??2、具體哪些文件描述符處于就緒可讀、可寫或異常狀態(tài)

函數(shù)值：

??-1 發(fā)生錯誤
??0 函數(shù)超時，當設置了超時時間，該時間內(nèi)未有狀態(tài)變化時
??大于0 有滿足讀、寫、異常的文件描述符，需檢查文件描述符集

特別關(guān)注

??每次函數(shù)返回時都會將文件描述符集FdSet中未發(fā)生任何事件的fd清空，每次調(diào)用select時都需將所關(guān)注的fd重新加入FdSet中；
??可監(jiān)控文件描述符個數(shù)取決于 FdSet中Bits的位長度，每個bit代表一個文件描述符，默認情況下Go中的定義為：Bits [16]int64，也就是一個8字節(jié)整數(shù)數(shù)組，數(shù)組長度為16，第一個數(shù)組元素可存儲的文件描述符為：0-63，第二個為：64-127依次類推；此時最多可以監(jiān)聽的文件描述符數(shù)為1024個；

Select的相關(guān)問題：

??1、內(nèi)核將消息傳遞到用戶空間需要執(zhí)行系統(tǒng)拷貝，如監(jiān)聽了大量fd會導致性能下降
??2、每次調(diào)用select都需要從用戶態(tài)拷貝fd集合到內(nèi)核態(tài)
??3、每次調(diào)用select內(nèi)核態(tài)都需要遍歷傳進來的所有fd集合
??4、默認select支持的fd集合過小，只有1024；
??5、輪詢效率低，每次調(diào)用select、內(nèi)核通知都需要輪詢整個fd集合

Go中的代碼實現(xiàn)：

func SelectIO(fd int) {
//讀文件描述符集
fdReadSet := &syscall.FdSet{}
connect = &Connect{maxFd: fd, childsMap: map[string]int{}}
for {
	FD_ZERO(fdReadSet)
	FD_SET(fd, fdReadSet) //socket文件描述符
	for _, child := range connect.childsMap {
		FD_SET(child, fdReadSet) //連接監(jiān)聽
		if child > connect.maxFd {
			connect.maxFd = child
		} else {

		}
	}
	n, err := syscall.Select(connect.maxFd+1, fdReadSet, nil, nil, nil)
	if err != nil {
		log.Println(err)
		if err == syscall.EAGAIN { //非阻塞模型下資源限制或不滿足條件返回eagain 異常 Resource temporarily unavailable
			continue
		}
	}
	log.Printf("n:%v,fdReadSet:%v", n, FD_ISSET(fd, fdReadSet))
	//-1 出錯  >0就緒的文件描述符數(shù)  0 超時
	if n > 0 && FD_ISSET(fd, fdReadSet) {
		//接受連接
		nfd, naddr, err := syscall.Accept(fd) //阻塞模式下在此方法會阻塞
		if err != nil {
			log.Printf("接受連接出錯：%v,%v", fd, err)
			continue
		}
		//設置非阻塞
		if err := syscall.SetNonblock(nfd, true); err != nil {
			log.Fatal(err)
		}
		var addr = naddr.(*syscall.SockaddrInet4)
		var ip = fmt.Sprintf("%d.%d.%d.%d:%d", addr.Addr[0], addr.Addr[1],
			addr.Addr[2], addr.Addr[3], addr.Port)
		log.Printf("新連接：%v", ip)
		processConn(nfd, ip)
	} else {
		readMsg(fdReadSet)
		}
	}
}

文章首發(fā)地址：https://mp.weixin.qq.com/s/1co33_BaJEwqrSX4GxkYEA

分享標題：從Go編程看IO多路復用Select
標題來源：http://chinadenli.net/article38/dsoissp.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供用戶體驗、網(wǎng)站內(nèi)鏈、虛擬主機、App設計、網(wǎng)站設計、全網(wǎng)營銷推廣

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)