blocks|key|1986456|text|您可以调用套接字上的setblocking(0)方法，使其成为非阻塞的。看看asyncore+module或者像Twisted这样的框架。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1986457|entityMap|0|LINK|mutability|MUTABLE|url|http://docs.python.org/library/asyncore.html|1|http://twistedmatrix.com/trac/^0|A|E|12|F|0|1K|7|1|0^^$0|@$1|2|3|4|5|6|7|P|8|@$9|Q|A|R|B|C]]|D|@$9|S|A|T|1|U]|$9|V|A|W|1|X]]|E|$]]|$1|F|3|-4|5|6|7|Y|8|@]|D|@]|E|$]]]|G|$H|$5|I|J|K|E|$L|M]]|N|$5|I|J|K|E|$L|O]]]]

You can invoke the <code>setblocking(0)</code> method on the Socket to make it non-blocking. Look into the <a href="http://docs.python.org/library/asyncore.html" rel="nofollow">asyncore module</a> or a framework like <a href="http://twistedmatrix.com/trac/" rel="nofollow">Twisted</a>.

blocks|key|1773193|text|你可能想要像select.select()这样的东西(参见documentation)。您为select()提供了三个套接字列表:要监视其可读性、可写性和错误状态的套接字。当新的客户端在等待时，服务器套接字将是可读的。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1773194|select()函数将一直阻塞，直到其中一个套接字状态发生更改。如果不想永远阻塞，可以指定一个可选的第四个参数timeout。|1773195|下面是一个哑巴回显服务器示例：|1773196|import+select
import+socket

server_socket+=+socket.socket(socket.AF_INET,+socket.SOCK_STREAM)
server_socket.setsockopt(socket.SOL_SOCKET,+socket.SO_REUSEADDR,+1)
server_socket.bind(('',+8888))
server_socket.listen(5)
print+"Listening+on+port+8888"

read_list+=+[server_socket]
while+True:
++++readable,+writable,+errored+=+select.select(read_list,+[],+[])
++++for+s+in+readable:
++++++++if+s+is+server_socket:
++++++++++++client_socket,+address+=+server_socket.accept()
++++++++++++read_list.append(client_socket)
++++++++++++print+"Connection+from",+address
++++++++else:
++++++++++++data+=+s.recv(1024)
++++++++++++if+data:
++++++++++++++++s.send(data)
++++++++++++else:
++++++++++++++++s.close()
++++++++++++++++read_list.remove(s)|code-block|syntax|javascript|1773197|Python还为支持它们的平台提供了epoll、poll和kqueue实现。它们是更高效的select版本。|1773198|entityMap|0|LINK|mutability|MUTABLE|url|http://docs.python.org/library/select.html#select.select^0|6|F|1A|8|T|D|0|0|0|8|1J|7|0|0|0|I|5|O|4|T|6|19|6|0^^$0|@$1|2|3|4|5|6|7|Y|8|@$9|Z|A|10|B|C]|$9|11|A|12|B|C]]|D|@$9|13|A|14|1|15]]|E|$]]|$1|F|3|G|5|6|7|16|8|@$9|17|A|18|B|C]|$9|19|A|1A|B|C]]|D|@]|E|$]]|$1|H|3|I|5|6|7|1B|8|@]|D|@]|E|$]]|$1|J|3|K|5|L|7|1C|8|@]|D|@]|E|$M|N]]|$1|O|3|P|5|6|7|1D|8|@$9|1E|A|1F|B|C]|$9|1G|A|1H|B|C]|$9|1I|A|1J|B|C]|$9|1K|A|1L|B|C]]|D|@]|E|$]]|$1|Q|3|-4|5|6|7|1M|8|@]|D|@]|E|$]]]|R|$S|$5|T|U|V|E|$W|X]]]]

You probably want something like <code>select.select()</code> (see <a href="http://docs.python.org/library/select.html#select.select" rel="nofollow noreferrer">documentation</a>). You supply <code>select()</code> with three lists of sockets: sockets you want to monitor for readability, writability, and error states. The server socket will be readable when a new client is waiting.

The <code>select()</code> function will block until one of the socket states has changed. You can specify an optional fourth parameter, <code>timeout</code>, if you don't want to block forever.

Here is a dumb echo server example:

<pre><code>import select
import socket

server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
server_socket.bind(('', 8888))
server_socket.listen(5)
print "Listening on port 8888"

read_list = [server_socket]
while True:
 readable, writable, errored = select.select(read_list, [], [])
 for s in readable:
 if s is server_socket:
 client_socket, address = server_socket.accept()
 read_list.append(client_socket)
 print "Connection from", address
 else:
 data = s.recv(1024)
 if data:
 s.send(data)
 else:
 s.close()
 read_list.remove(s)
</code></pre>

Python also has <code>epoll</code>, <code>poll</code>, and <code>kqueue</code> implementations for platforms that support them. They are more efficient versions of <code>select</code>.

Is there a way I can use python's socket.accept() in a non-blocking way that simply runs it and lets me just check if it got any new connections? I really don't want to use threading.
Thanks.

Python socket.accept nonblocking?

服务器

Python

有没有一种方法可以让我以一种非阻塞的方式使用python的socket.accept()，让我简单地运行它，并让我检查它是否获得了任何新的连接？我真的不想使用线程。谢谢。

问Python socket.accept无阻塞？
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Python socket.accept无阻塞？EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Python socket.accept无阻塞？
EN