創(chuàng)新互聯(lián)www.cdcxhl.cn八線動(dòng)態(tài)BGP香港云服務(wù)器提供商，新人活動(dòng)買(mǎi)多久送多久，劃算不套路！
這篇文章主要介紹python中select的使用方法，文中介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們一定要看完！
Python的select()方法直接調(diào)用操作系統(tǒng)的IO接口，它監(jiān)控sockets,open files, and pipes(所有帶fileno()方法的文件句柄)何時(shí)變成readable 和writeable, 或者通信錯(cuò)誤，select()使得同時(shí)監(jiān)控多個(gè)連接變的簡(jiǎn)單，并且這比寫(xiě)一個(gè)長(zhǎng)循環(huán)來(lái)等待和監(jiān)控多客戶(hù)端連接要高效，因?yàn)閟elect直接通過(guò)操作系統(tǒng)提供的C的網(wǎng)絡(luò)接口進(jìn)行操作，而不是通過(guò)Python的解釋器。
注意：Python的select()方法適用于UNIX操作系統(tǒng)，不支持Windows操作系統(tǒng)
接下來(lái)通過(guò)echo server例子要以了解select 是如何通過(guò)單進(jìn)程實(shí)現(xiàn)同時(shí)處理多個(gè)非阻塞的socket連接的。
重慶分公司
重慶分公司
import select
import socket
import sys
import Queue
# Create a TCP/IP socket
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.setblocking(0)
# Bind the socket to the port
server_address = ('localhost', 10000)
print >>sys.stderr, 'starting up on %s port %s' % server_address
server.bind(server_address)
# Listen for incoming connections
server.listen(5)select()方法接收并監(jiān)控3個(gè)通信列表， 第一個(gè)是所有的輸入的data,就是指外部發(fā)過(guò)來(lái)的數(shù)據(jù)，第2個(gè)是監(jiān)控和接收所有要發(fā)出去的data(outgoing data),第3個(gè)監(jiān)控錯(cuò)誤信息，接下來(lái)我們需要?jiǎng)?chuàng)建2個(gè)列表來(lái)包含輸入和輸出信息來(lái)傳給select()。
# Sockets from which we expect to read inputs = [ server ] # Sockets to which we expect to write outputs = [ ]
所有客戶(hù)端的進(jìn)來(lái)的連接和數(shù)據(jù)將會(huì)被server的主循環(huán)程序放在上面的list中處理，我們現(xiàn)在的server端需要等待連接可寫(xiě)(writable)之后才能過(guò)來(lái)，然后接收數(shù)據(jù)并返回(因此不是在接收到數(shù)據(jù)之后就立刻返回)，因?yàn)槊總€(gè)連接要把輸入或輸出的數(shù)據(jù)先緩存到queue里，然后再由select取出來(lái)再發(fā)。
# Outgoing message queues (socket:Queue)
message_queues = {}通過(guò)服務(wù)器主循環(huán)將連接添加到這些列表并從這些列表中移除。由于服務(wù)器的這個(gè)版本在發(fā)送任何數(shù)據(jù)之前將等待套接字變得可寫(xiě)(而不是立即發(fā)送應(yīng)答)，所以每個(gè)輸出連接都需要一個(gè)隊(duì)列作為要通過(guò)它發(fā)送的數(shù)據(jù)的緩沖區(qū)。
下面是此程序的主循環(huán)，調(diào)用select()時(shí)會(huì)阻塞和等待直到新的連接和數(shù)據(jù)進(jìn)來(lái)。
# Wait for at least one of the sockets to be ready for processing print >>sys.stderr, '\nwaiting for the next event' readable, writable, exceptional = select.select(inputs, outputs, inputs)
當(dāng)你把inputs,outputs,exceptional(這里跟inputs共用)傳給select()后，它返回3個(gè)新的list，我們上面將他們分別賦值為readable,
writable,exceptional, 所有在readable list中的socket連接代表有數(shù)據(jù)可接收(recv),所有在writable list中的存放著你可以對(duì)其進(jìn)行發(fā)送(send)操作的socket連接，當(dāng)連接通信出現(xiàn)error時(shí)會(huì)把error寫(xiě)到exceptional列表中。
Readable list 中的socket 可以有3種可能狀態(tài)，第一種是如果這個(gè)socket是main "server" socket,它負(fù)責(zé)監(jiān)聽(tīng)客戶(hù)端的連接，如果這個(gè)main server socket出現(xiàn)在readable里，那代表這是server端已經(jīng)ready來(lái)接收一個(gè)新的連接進(jìn)來(lái)了，為了讓這個(gè)main server能同時(shí)處理多個(gè)連接，在下面的代碼里，我們把這個(gè)main server的socket設(shè)置為非阻塞模式。
# Handle inputs for s in readable: if s is server: # A "readable" server socket is ready to accept a connection connection, client_address = s.accept() print >>sys.stderr, 'new connection from', client_address connection.setblocking(0) inputs.append(connection) # Give the connection a queue for data we want to send message_queues[connection] = Queue.Queue()
第二種情況是這個(gè)socket是已經(jīng)建立了的連接，它把數(shù)據(jù)發(fā)了過(guò)來(lái)，這個(gè)時(shí)候你就可以通過(guò)recv()來(lái)接收它發(fā)過(guò)來(lái)的數(shù)據(jù)，然后把接收到的數(shù)據(jù)放到queue里，這樣你就可以把接收到的數(shù)據(jù)再傳回給客戶(hù)端了。
else: data = s.recv(1024) if data: # A readable client socket has data print >>sys.stderr, 'received "%s" from %s' % (data, s.getpeername()) message_queues[s].put(data) # Add output channel for response if s not in outputs: outputs.append(s)
第三種情況就是這個(gè)客戶(hù)端已經(jīng)斷開(kāi)了，所以你再通過(guò)recv()接收到的數(shù)據(jù)就為空了，所以這個(gè)時(shí)候你就可以把這個(gè)跟客戶(hù)端的連接關(guān)閉了。
else: # Interpret empty result as closed connection print >>sys.stderr, 'closing', client_address, 'after reading no data' # Stop listening for input on the connection if s in outputs:
outputs.remove(s) #既然客戶(hù)端都斷開(kāi)了，我就不用再給它返回?cái)?shù)據(jù)了，所以這時(shí)候如果這個(gè)客戶(hù)端的連接對(duì)象還在outputs列表中，就把它刪掉。
inputs.remove(s) #inputs中也刪除掉 s.close() #把這個(gè)連接關(guān)閉掉 # Remove message queue del message_queues[s]
對(duì)于writable list中的socket，也有幾種狀態(tài)，如果這個(gè)客戶(hù)端連接在跟它對(duì)應(yīng)的queue里有數(shù)據(jù)，就把這個(gè)數(shù)據(jù)取出來(lái)再發(fā)回給這個(gè)客戶(hù)端，否則就把這個(gè)連接從output list中移除，這樣下一次循環(huán)select()調(diào)用時(shí)檢測(cè)到outputs list中沒(méi)有這個(gè)連接，那就會(huì)認(rèn)為這個(gè)連接還處于非活動(dòng)狀態(tài)。
# Handle outputs for s in writable: try: next_msg = message_queues[s].get_nowait() except Queue.Empty: # No messages waiting so stop checking for writability. print >>sys.stderr, 'output queue for', s.getpeername(), 'is empty' outputs.remove(s) else: print >>sys.stderr, 'sending "%s" to %s' % (next_msg, s.getpeername()) s.send(next_msg)
最后，如果在跟某個(gè)socket連接通信過(guò)程中出了錯(cuò)誤，就把這個(gè)連接對(duì)象在inputs\outputs\message_queue中都刪除，再把連接關(guān)閉掉。
# Handle "exceptional conditions" for s in exceptional: print >>sys.stderr, 'handling exceptional condition for', s.getpeername() # Stop listening for input on the connection inputs.remove(s) if s in outputs: outputs.remove(s) s.close() # Remove message queue del message_queues[s]
以上是python中select的使用方法的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對(duì)大家有幫助，更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)-成都網(wǎng)站建設(shè)公司行業(yè)資訊頻道！
