python select实现非阻塞socket


#!/usr/bin/env python 
# -*- encoding: utf-8 -*- 
 
import socket 
import select 
 
host = ""  
port = 50000  
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)  
s.bind((host,port))  
s.listen(5) 
print "begin..." 
while 1:  
    infds,outfds,errfds = select.select([s,],[],[],5)  
    # 如果infds状态改变,进行处理,否则不予理会  
    if len(infds) != 0:  
        clientsock,clientaddr = s.accept() 
        infds_c,outfds_c,errfds_c = select.select([clientsock,],[],[],3) 
        if len(infds_c) != 0:  
            buf = clientsock.recv(8196)  
            if len(buf) != 0:  
                print (buf)  
        clientsock.close() 
        print "clientsock closed" 
    print "no data coming"  

在綱絡上看到的一篇文章, 介紹Python的socket非阻塞式

在原來的代碼基礎上改了一下,增加了一個select使用了兩個select,

第一個select充許多個client來connect,如果過了5秒還沒有client來connect顯示 "no data coming"
第二個select是如果client connect過來, 過了3秒還沒有發送message則直接close, 不會造成阻塞

摘自:liukeforever的专栏

相关内容

    暂无相关文章

评论关闭