關(guān)于Socket中的Select使用理解

以下是代碼和中文注釋的個人理解

import socket, select, Queueserver=('192.168.2.100',10086)#創(chuàng)建TCP/TP Socket sock_ser=socket.socket(socket.AF_INET,socket.SOCK_STREAM) #設(shè)置不阻塞監(jiān)聽 sock_ser.setblocking(False) sock_ser.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1) #綁定IP地址 sock_ser.bind(server) #監(jiān)聽連接 sock_ser.listen(10)#準(zhǔn)備用來讀取數(shù)據(jù)的Socket,客戶端向服務(wù)端的讀端口寫 incomes=[sock_ser] #準(zhǔn)備用來寫的Socket，客戶端從寫Socket讀 outputs=[]""" 寫出消息的隊列，由于select是循環(huán)機制，所以每個獨立的outputs都需要一個隊列來保存待寫出的數(shù)據(jù)， 等到輪回到自己的時候?qū)懗?""" msg_que={}#超時時間。 timeout=20#服務(wù)端的Socket用來接受服務(wù)端的連接，并用作與循環(huán)。 while incomes:"""先等待至少一個Socket的數(shù)據(jù)處理，Select返回當(dāng)前三個列表。這三個數(shù)據(jù)來自于可讀，可寫，返回的錯誤。Select監(jiān)聽并等待網(wǎng)絡(luò)活動。如果有網(wǎng)絡(luò)活動則開始執(zhí)行"""rs,ws,es=select.select(incomes,outputs,incomes,timeout)if not(rs or ws or es):print "error: timeout...."breakfor s in rs:"""此處的rs存儲很多Socket，開始存儲只有服務(wù)端本身的Socket，用于與客戶端建立新的連接。并將客戶端建立好的連接存儲在incomes中,incomes會返回給rs。存儲的的客戶端，會被用于收發(fā)數(shù)據(jù)。"""#rs隊列中按個讀取，如果是服務(wù)端的socket就用那個與建立新的連接。if s is sock_ser:conn,addr=s.accept()print "connect by ",addrconn.setblocking(False)incomes.append(conn)#為接入的客戶端提供一個隊列來發(fā)送回復(fù)給客戶端的數(shù)據(jù)msg_que[conn]=Queue.Queue()#如果不是服務(wù)端的socket，是客戶端建立連接的Socket，就收數(shù)據(jù)，并判斷是否斷開。else:data=s.recv(1024)#有數(shù)據(jù)就收數(shù)據(jù)if data:print "receive client ",datamsg_que[s].put(data)if s not in outputs:outputs.append(s)#可讀的socket沒有數(shù)據(jù)發(fā)送，則說明客戶端斷開連接，我們刪除這個客戶端。else:if s in outputs:outputs.remove(s)incomes.remove(s)s.close()del msg_que[s]#寫操作，查看隊列里面是否有東西，并發(fā)送到對應(yīng)的Socket.for s in ws:try:msg = msg_que[s].get_nowait()except Queue.Empty:#因為是輪回的，當(dāng)前面連接斷開后，寫的socket尚未刪除，這一步還是要執(zhí)行的，所以最后輸出了幾個EMPTY。print 'msg empty'outputs.remove(s)else:s.send("from server :"+msg)for s in es:print "except",s.getpeername()if s in incomes:incomes.remove(s)if s in outputs:outputs.remove(s)s.close()del msg_que[s]

　　

轉(zhuǎn)載于:https://www.cnblogs.com/freeideas/archive/2013/04/29/3050255.html

總結(jié)

以上是生活随笔為你收集整理的PYTHON__关于Socket中的Select使用理解的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。