blocks|key|1051179|text|典型的方法是使用select()等待，直到数据可用或超时。只有在数据实际可用时才调用recv()。为了安全起见，我们还将套接字设置为非阻塞模式，以保证recv()永远不会无限期地阻塞。select()还可用于同时等待多个套接字。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1051180|import+select

mysocket.setblocking(0)

ready+=+select.select([mysocket],+[],+[],+timeout_in_seconds)
if+ready[0]:
++++data+=+mysocket.recv(4096)|code-block|syntax|javascript|1051181|如果您有很多打开的文件描述符，那么poll()是比select()更有效的替代方案。|1051182|另一种选择是使用socket.settimeout()为套接字上的所有操作设置超时，但我看到您在另一个答案中明确拒绝了该解决方案。|1051183|entityMap|0|LINK|mutability|MUTABLE|url|http://docs.python.org/library/select.html#select.select|1|http://docs.python.org/library/select.html#select.poll^0|16|6|23|6|2K|8|8|8|0|0|0|P|8|H|6|1|0|8|J|0^^$0|@$1|2|3|4|5|6|7|Y|8|@$9|Z|A|10|B|C]|$9|11|A|12|B|C]|$9|13|A|14|B|C]]|D|@$9|15|A|16|1|17]]|E|$]]|$1|F|3|G|5|H|7|18|8|@]|D|@]|E|$I|J]]|$1|K|3|L|5|6|7|19|8|@$9|1A|A|1B|B|C]]|D|@$9|1C|A|1D|1|1E]]|E|$]]|$1|M|3|N|5|6|7|1F|8|@$9|1G|A|1H|B|C]]|D|@]|E|$]]|$1|O|3|-4|5|6|7|1I|8|@]|D|@]|E|$]]]|P|$Q|$5|R|S|T|E|$U|V]]|W|$5|R|S|T|E|$U|X]]]]

The typical approach is to use <a href="http://docs.python.org/library/select.html#select.select" rel="noreferrer">select()</a> to wait until data is available or until the timeout occurs. Only call <code>recv()</code> when data is actually available. To be safe, we also set the socket to non-blocking mode to guarantee that <code>recv()</code> will never block indefinitely. <code>select()</code> can also be used to wait on more than one socket at a time.

<pre><code>import select

mysocket.setblocking(0)

ready = select.select([mysocket], [], [], timeout_in_seconds)
if ready[0]:
 data = mysocket.recv(4096)
</code></pre>

If you have a lot of open file descriptors, <a href="http://docs.python.org/library/select.html#select.poll" rel="noreferrer">poll()</a> is a more efficient alternative to <code>select()</code>.

Another option is to set a timeout for all operations on the socket using <code>socket.settimeout()</code>, but I see that you've explicitly rejected that solution in another answer.

blocks|key|1051094|text|这是socket.settimeout()|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1051095|entityMap|0|LINK|mutability|MUTABLE|url|http://docs.python.org/library/socket#socket.socket.settimeout^0|2|J|2|J|0|0^^$0|@$1|2|3|4|5|6|7|N|8|@$9|O|A|P|B|C]]|D|@$9|Q|A|R|1|S]]|E|$]]|$1|F|3|-4|5|6|7|T|8|@]|D|@]|E|$]]]|G|$H|$5|I|J|K|E|$L|M]]]]

there's <a href="http://docs.python.org/library/socket#socket.socket.settimeout" rel="noreferrer"><code>socket.settimeout()</code></a>

blocks|key|1265891|text|如前所述，select.select()和socket.settimeout()都可以工作。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1265892|注您可能需要调用settimeout两次，例如|1265893|sock+=+socket.socket(socket.AF_INET,+socket.SOCK_STREAM)
sock.bind(("",0))
sock.listen(1)
#+accept+can+throw+socket.timeout
sock.settimeout(5.0)
conn,+addr+=+sock.accept()

#+recv+can+throw+socket.timeout
conn.settimeout(5.0)
conn.recv(1024)|code-block|syntax|javascript|1265894|entityMap|0|LINK|mutability|MUTABLE|url|https://docs.python.org/library/select.html#select.select|1|http://docs.python.org/library/socket#socket.socket.settimeout^0|5|F|L|J|5|F|0|L|J|1|0|8|A|0|0^^$0|@$1|2|3|4|5|6|7|W|8|@$9|X|A|Y|B|C]|$9|Z|A|10|B|C]]|D|@$9|11|A|12|1|13]|$9|14|A|15|1|16]]|E|$]]|$1|F|3|G|5|6|7|17|8|@$9|18|A|19|B|C]]|D|@]|E|$]]|$1|H|3|I|5|J|7|1A|8|@]|D|@]|E|$K|L]]|$1|M|3|-4|5|6|7|1B|8|@]|D|@]|E|$]]]|N|$O|$5|P|Q|R|E|$S|T]]|U|$5|P|Q|R|E|$S|V]]]]

As mentioned both <a href="https://docs.python.org/library/select.html#select.select" rel="noreferrer"><code>select.select()</code></a> and <a href="http://docs.python.org/library/socket#socket.socket.settimeout" rel="noreferrer"><code>socket.settimeout()</code></a> will work.

Note you might need to call <code>settimeout</code> twice for your needs, e.g.

<pre><code>sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.bind(("",0))
sock.listen(1)
# accept can throw socket.timeout
sock.settimeout(5.0)
conn, addr = sock.accept()

# recv can throw socket.timeout
conn.settimeout(5.0)
conn.recv(1024)
</code></pre>

blocks|key|1051239|text|您可以在接收响应之前设置超时，并在接收到响应后将其设置回无：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1051240|sock+=+socket.socket(socket.AF_INET,+socket.SOCK_STREAM)

sock.settimeout(5.0)
data+=+sock.recv(1024)
sock.settimeout(None)|code-block|syntax|javascript|1051241|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

You could set timeout before receiving the response and after having received the response set it back to None:

<pre><code>sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

sock.settimeout(5.0)
data = sock.recv(1024)
sock.settimeout(None)
</code></pre>

blocks|key|1265989|text|如果您实现了服务器端，那么您要查找的超时是连接套接字的超时，而不是主套接字的超时。换句话说，连接套接字对象还有另一个超时，它是socket.accept()方法的输出。因此：|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1265990|sock.listen(1)
connection,+client_address+=+sock.accept()
connection.settimeout(5)++++#+This+is+the+one+that+affects+recv()+method.
connection.gettimeout()+++++#+This+should+result+5
sock.gettimeout()+++++++++++#+This+outputs+None+when+not+set+previously,+if+I+remember+correctly.|code-block|syntax|javascript|1265991|如果你实现了客户端，那就很简单了。|1265992|sock.connect(server_address)
sock.settimeout(3)|1265993|entityMap^0|1R|F|0|0|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@$9|R|A|S|B|C]]|D|@]|E|$]]|$1|F|3|G|5|H|7|T|8|@]|D|@]|E|$I|J]]|$1|K|3|L|5|6|7|U|8|@]|D|@]|E|$]]|$1|M|3|N|5|H|7|V|8|@]|D|@]|E|$I|J]]|$1|O|3|-4|5|6|7|W|8|@]|D|@]|E|$]]]|P|$]]

The timeout that you are looking for is the connection socket's timeout not the primary socket's, if you implement the server side. In other words, there is another timeout for the connection socket object, which is the output of <code>socket.accept()</code> method. Therefore:

<pre><code>sock.listen(1)
connection, client_address = sock.accept()
connection.settimeout(5) # This is the one that affects recv() method.
connection.gettimeout() # This should result 5
sock.gettimeout() # This outputs None when not set previously, if I remember correctly.
</code></pre>

If you implement the client side, it would be simple.

<pre><code>sock.connect(server_address)
sock.settimeout(3)
</code></pre>

blocks|key|1051263|text|试试这个，它使用底层的C。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1051264|timeval+=+struct.pack('ll',+2,+100)
s.setsockopt(socket.SOL_SOCKET,+socket.SO_RCVTIMEO,+timeval)|code-block|syntax|javascript|1051265|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

try this it uses the underlying C.

<pre><code>timeval = struct.pack('ll', 2, 100)
s.setsockopt(socket.SOL_SOCKET, socket.SO_RCVTIMEO, timeval)
</code></pre>

blocks|key|1051363|text|您可以使用socket.settimeout()，它接受表示秒数的整数参数。例如，socket.settimeout(1)会将超时设置为1秒|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1051364|entityMap^0|5|J|15|K|0^^$0|@$1|2|3|4|5|6|7|H|8|@$9|I|A|J|B|C]|$9|K|A|L|B|C]]|D|@]|E|$]]|$1|F|3|-4|5|6|7|M|8|@]|D|@]|E|$]]]|G|$]]

You can use <code>socket.settimeout()</code> which accepts a integer argument representing number of seconds. For example, <code>socket.settimeout(1)</code> will set the timeout to 1 second

blocks|key|1051342|text|正如在前面的回复中所提到的，您可以使用以下内容：.settimeout()例如：|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1051343|import+socket

s+=+socket.socket()

s.settimeout(1)+#+Sets+the+socket+to+timeout+after+1+second+of+no+activity

host,+port+=+"somehost",+4444
s.connect((host,+port))

s.send("Hello+World!\r\n")

try:
++++rec+=+s.recv(100)+#+try+to+receive+100+bytes
except+socket.timeout:+#+fail+after+1+second+of+no+activity
++++print("Didn't+receive+data!+[Timeout]")
finally:
++++s.close()|code-block|syntax|javascript|1051344|我希望这对你有帮助！|1051345|entityMap^0|O|D|0|0|0^^$0|@$1|2|3|4|5|6|7|O|8|@$9|P|A|Q|B|C]]|D|@]|E|$]]|$1|F|3|G|5|H|7|R|8|@]|D|@]|E|$I|J]]|$1|K|3|L|5|6|7|S|8|@]|D|@]|E|$]]|$1|M|3|-4|5|6|7|T|8|@]|D|@]|E|$]]]|N|$]]

As mentioned in previous replies, you can use something like: <code>.settimeout()</code>
For example:

<pre><code>import socket

s = socket.socket()

s.settimeout(1) # Sets the socket to timeout after 1 second of no activity

host, port = "somehost", 4444
s.connect((host, port))

s.send("Hello World!\r\n")

try:
 rec = s.recv(100) # try to receive 100 bytes
except socket.timeout: # fail after 1 second of no activity
 print("Didn't receive data! [Timeout]")
finally:
 s.close()
</code></pre>

I hope this helps!!

blocks|key|1051381|text|#!+/usr/bin/python3.6

#+-*-+coding:+utf-8+-*-
import+socket
import+time
s+=+socket.socket(socket.AF_INET,+socket.SOCK_DGRAM)
s.setsockopt(socket.SOL_SOCKET,+socket.SO_BROADCAST,+1)
s.settimeout(5)
PORT+=+10801

s.bind(('',+PORT))
print('Listening+for+broadcast+at+',+s.getsockname())
BUFFER_SIZE+=+4096
while+True:
++++try:
++++++++data,+address+=+s.recvfrom(BUFFER_SIZE)
++++except+socket.timeout:
++++++++print("Didn't+receive+data!+[Timeout+5s]")
++++++++continue|type|code-block|depth|inlineStyleRanges|entityRanges|data|syntax|javascript|1051382|unstyled|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|G|8|@]|9|@]|A|$B|C]]|$1|D|3|-4|5|E|7|H|8|@]|9|@]|A|$]]]|F|$]]

<pre><code>#! /usr/bin/python3.6

# -*- coding: utf-8 -*-
import socket
import time
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
s.settimeout(5)
PORT = 10801

s.bind(('', PORT))
print('Listening for broadcast at ', s.getsockname())
BUFFER_SIZE = 4096
while True:
 try:
 data, address = s.recvfrom(BUFFER_SIZE)
 except socket.timeout:
 print("Didn't receive data! [Timeout 5s]")
 continue
</code></pre>

blocks|key|1266213|text|大声呼喊：https://boltons.readthedocs.io/en/latest/socketutils.html|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|1266214|它提供了一个缓冲套接字，这提供了很多非常有用的功能，例如：|1266215|.recv_until()++++#recv+until+occurrence+of+bytes
.recv_closed()+++#recv+until+close
.peek()++++++++++#peek+at+buffer+but+don't+pop+values
.settimeout()++++#configure+timeout+(including+recv+timeout)|code-block|syntax|javascript|1266216|entityMap|0|LINK|mutability|MUTABLE|url|https://boltons.readthedocs.io/en/latest/socketutils.html^0|5|1L|0|0|0|0^^$0|@$1|2|3|4|5|6|7|S|8|@]|9|@$A|T|B|U|1|V]]|C|$]]|$1|D|3|E|5|6|7|W|8|@]|9|@]|C|$]]|$1|F|3|G|5|H|7|X|8|@]|9|@]|C|$I|J]]|$1|K|3|-4|5|6|7|Y|8|@]|9|@]|C|$]]]|L|$M|$5|N|O|P|C|$Q|R]]]]

Shout out to: <a href="https://boltons.readthedocs.io/en/latest/socketutils.html" rel="nofollow noreferrer">https://boltons.readthedocs.io/en/latest/socketutils.html</a>
It provides a buffered socket, this provides a lot of very useful functionality such as:
<pre><code>.recv_until() #recv until occurrence of bytes
.recv_closed() #recv until close
.peek() #peek at buffer but don't pop values
.settimeout() #configure timeout (including recv timeout)
</code></pre>

I need to set timeout on python's socket recv method. How to do it?

How to set timeout on python's socket recv method?

我需要在python的socket recv方法上设置超时。该怎么做呢？

问如何在python的socket recv方法上设置超时？
EN

回答 10

Stack Overflow用户

Stack Overflow用户

Stack Overflow用户

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何在python的socket recv方法上设置超时？EN

回答 10

Stack Overflow用户

Stack Overflow用户

Stack Overflow用户

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何在python的socket recv方法上设置超时？
EN