pythonrecv阻塞

❶ python socket 阻塞模式怎么确保数据recv

可以通过setsockopt，或者更简单的setblocking, settimeout设置。阻塞式的socket的recv服从这样的规则：
当缓冲区内有数据时，立即返回所有的数据；当缓冲区内无数据时，阻塞直到缓冲区中有数据。非阻塞式的socket的recv服从的规则则是：
当缓冲区内有数据时，立即返回所有的数据；当缓冲区内无数据时，产生EAGAIN的错误并返回（在Python中会抛出一个异常）。两种情况都不会返回空字符串，返回空数据的结果是对方关闭了连接之后才会出现的。

❷ 如何解决winsock中recv函数的阻塞问题，最好有代码

Private Sub wskPb_DataArrival(ByVal bytesTotal As Long)
On Error Resume Next
Dim cData As String

wskPb.GetData cData
End Sub

一般VB的Socket数据接收在这里做操作,DataArrival事件前亩,相当于稿返一个回调函数,有收到数据就会触发这个事件.
当然你也可键悔饥以开辟线程来避免阻塞问题.微软都已经封装好了,没必要再自己做.

❸ 如何用Python实现实时的网络连接检测

如果你用的socket包里的那些阻塞接口，当然写个线程循环监测时间也没啥，只不过记得在循环内加上个sleep，哪怕是1ms甚至1us的sleep都可以避免CPU被消耗干净。

如果你所说的接收是死循环式里跑socket.recv，它会在recv里阻塞，按你的说法3分钟一个心跳包，时间检测就成了3分钟一次，不太合适。

更好的办法自然是通过epoll/poll之类的方式或者asyncio/twisted/tornado之类的异步回调/协程加时间事件甚至是各种GUI框架的事件循环来启动你的发送和接收。考虑到以后可能有多设备，显然利用这些成型的玩意更合理。

❹ Python的多进程模块multiprocessing

众所周知，Python中不存在真正的多线程，Python中的多线程是一个并发过程。如果想要并行的执行程序，充分的利用cpu资源(cpu核心)，还是需要使用多进程解决的。其中multiprocessing模块应该是Python中最常用的多进程模块了。

基本上multiprocessing这个模块和threading这个模块用法是相同的，也是可以通过函数和类创建进程。

上述案例基本上就是笔者搬用了上篇文章多线程的案例，可见其使用的相似之处。导入multiprocessing后实例化Process就可以创建一个进程，参数的话也是和多线程一样，target放置进程执行函数，args存放该函数的参数。

使用类来创建进程也是需要先继承multiprocessing.Process并且实现其init方法。

Pool可以提供指定数量的进程，供用户调用，当有新的请求提交到pool中时，如果池还没有满，那么就会创建一个新的进程用来执行该请求。

但如果池中的进程数已经达到规定最大值，那么该请求就会等待，直到池中有进程结束，才会创建新的进程。

需要注意的是，在调用join方法阻塞进程前，需要先调用close方法，，否则程序会出错。

在上述案例中，提到了非阻塞，当把创建进程的方法换为pool.apply(func, (msg,))时，就会阻塞进程，出现下面的状况。

在multiprocessing模块中还存在Queue对象，这是一个进程的安全队列，近似queue.Queue。队列一般也是需要配合多线程或者多进程使用。

下列案例是一个使用进程队列实现的生产者消费者模式。

multiprocessing支持两种进程间的通信，其中一种便是上述案例的队列，另一种则称作管道。在官方文档的描述中，multiprocessing中的队列是基于管道实现的，并且拥有更高的读写效率。

管道可以理解为进程间的通道，使用Pipe([plex])创建，并返回一个元组(conn1,conn2)。如果plex被置为True(默认值)，那么该管道是双向的，如果plex被置为False，那么该管道是单向的，即conn1只能用于接收消息，而conn2仅能用于发送消息。

其中conn1、conn2表示管道两端的连接对象，每个连接对象都有send()和recv()方法。send和recv方法分别是发送和接受消息的方法。例如，可以调用conn1.send发送消息，conn1.recv接收消息。如果没有消息可接收，recv方法会一直阻塞。如果管道已经被关闭，那么recv方法会抛出EOFError。

关于multiprocessing模块其实还有很多实用的类和方法，由于篇幅有限(懒),笔者就先写到这里。该模块其实用起来很像threading模块，像锁对象和守护线程(进程)等multiprocessing模块也是有的，使用方法也近乎相同。

如果想要更加详细的了解multiprocessing模块，请参考官方文档。

❺ Python网络编程 -- TCP/IP

首先放出一个 TCP/IP 的程序，这里是单线程服务器与客户端，在多线程一节会放上多线程的TCP/IP服务程序冲戚拍。

这里将服务端和客户端放到同一个程序当中，方便对比服务端与客户端的不同。

TCP/IP是因特网的通信协议，其参考OSI模型，也采用了分层的方式，对每一层制定了相应的标准。

网际协议（IP）是为全世界通过互联网连接的计算机赋予统一地址系统的机制，它使得数据包能够从互联网的一端发送至另一端，如 130.207.244.244，为了便于记忆，常用主机名代替IP地址，例如 .com。

UDP (User Datagram Protocol，用户数据报协议) 解决了上述第一个问题，通过端口号来实现了多路复用（用不同的端口区分不同的应用程序）但是使用UDP协议的网络程序需要自己处理丢包、重包和包的乱序问题。

TCP (Transmission Control Protocol，传输控制协议) 解决了上述两个问题，同样使用端口号实现了复用。

TCP 实现可靠连接的方法：

socket通信模型及 TCP 通信过程如下两张图。

[图片上传失败...(image-6d947d-1610703914730)]

[图片上传失败...(image-30b472-1610703914730)]

socket.getaddrinfo(host, port, family, socktype, proto, flags)
返回： [(family, socktype, proto, cannonname, sockaddr), ] 由元组组成的列表散羡。
family：表示socket使用的协议簇， AF_UNIX : 1, AF_INET: 2, AF_INET6 : 10。 0 表示不指定。
socktype: socket 的类型， SOCK_STREAM : 1, SOCK_DGRAM : 2, SOCK_RAW : 3
proto: 协议， 套接字所用的协议，如果不指定， 则为 0。 IPPROTO_TCP : 6, IPPRTOTO_UDP : 17
flags：标记，限制返回内容。 AI_ADDRCONFIG 把计算机无法连接的所有地址都过滤掉（如果一个机构既有IPv4，又有IPv6，而主机只有IPv4，则会把 IPv6过滤掉）
AI _V4MAPPED, 如果本机只有IPv6，服务却只有IPv4，这个标记会将 IPv4地址重新编码为可实际使用的IPv6地址。
AI_CANONNAME，返回规范主机名：cannonname。
getaddrinfo(None, 'smtp', 0, socket.SOCK_STREAM, 0, socket.AP_PASSIVE)
getaddrinfo('ftp.kernel.org', 'ftp', 0, 'socket.SOCK_STREAM, 0, socket.AI_ADDRCONFIG | socket.AI_V4MAPPED)
利用已经通信的套接字名提供给getaddrinfo
mysock = server_sock.accept()
addr, port = mysock.getpeername()
getaddrinfo(addr, port, mysock.family, mysock.type, mysock.proto, socket.AI_CANONNAME)

TCP 数据发送模式：

由于 TCP 是发送流式数据，并且会自动分割发送的数据包，而仔槐且在 recv 的时候会阻塞进程，直到接收到数据为止，因此会出现死锁现象，及通信双方都在等待接收数据导致无法响应，或者都在发送数据导致缓存区溢出。所以就有了封帧(framing)的问题，即如何分割消息，使得接收方能够识别消息的开始与结束。

关于封帧，需要考虑的问题是， 接收方何时最终停止调用recv才是安全的？整个消息或数据何时才能完整无缺的传达？何时才能将接收到的消息作为一个整体来解析或处理。

适用UDP的场景：

由于TCP每次连接与断开都需要有三次握手，若有大量连接，则会产生大量的开销，在客户端与服务器之间不存在长时间连接的情况下，适用UDP更为合适，尤其是客户端太多的时候。

第二种情况： 当丢包现象发生时，如果应用程序有比简单地重传数据聪明得多的方法的话，那么就不适用TCP了。例如，如果正在进行音频通话，如果有1s的数据由于丢包而丢失了，那么只是简单地不断重新发送这1s的数据直至其成功传达是无济于事的。反之，客户端应该从传达的数据包中任意选择一些组合成一段音频（为了解决这一问题，一个智能的音频协议会用前一段音频的高度压缩版本作为数据包的开始部分，同样将其后继音频压缩，作为数据包的结束部分），然后继续进行后续操作，就好像没有发生丢包一样。如果使用TCP，那么这是不可能的，因为TCP会固执地重传丢失的信息，即使这些信息早已过时无用也不例外。UDP数据报通常是互联网实时多媒体流的基础。

参考资料：

❻ recv是阻塞还是非阻塞的

网络编程函数如recv是阻塞（同步）还是非阻塞（异步）取决于在调用recv函数前创建的套接字socket是阻塞还是非阻塞。socket默认创建时设定为阻塞模式；若要将socket设定为非阻塞模式，可以在socket创建时设定为非阻塞模式，那么函数recv就是非阻塞的。
可以通过一下几种方法设定socket为非阻塞：
1.linux平台可以在利用socket()函数创建socket时指定socket是异步（非阻塞）的：
int socket(int domain, int type, int protocol);
在参数type中设置SOCK_NONBLOCK标志即可，例如：
int s = socket(AF_INET, SOCK_STREAM | SOCK_NONBLOCK, IPPROTO_TCP);
2.windows和linux平台accept()函数返回的socekt也是阻塞的，linux另外提供了一个accept4()函数，可以直接将socket设置为非阻塞模式：
int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);
int accept4(int sockfd, struct sockaddr *addr, socklen_t *addrlen, int flags);
只要将accept4()最后一个参数flags设置成SOCK_NONBLOCK即可。

3.除了在创建socket时，将socket设置为非阻塞模式，还可以通过以下函数来设置：

linux平台可以调用fcntl()或ioctl()函数，例如：
fcntl(sockfd, F_SETFL, fcntl(sockfd, F_GETFL, 0) | O_NONBLOCK);
ioctl(sockfd, FIONBIO, 1); //1:非阻塞 0:阻塞
windows平台可调用ioctlsocket函数：

int ioctlsocket(
_In_ SOCKET s,
_In_ long cmd,
_Inout_ u_long *argp
);
将cmd参数设置为FIONBIO，*argp=0即设置成阻塞模式，而*argp非0即可设置成非阻塞模式。但windows平台一个地方需要注意，如果对一个socket调用了WSAAsyncSelect()或WSAEventSelect()函数后，你再调用ioctlsocket()函数将该socket设置为阻塞模式，则会失败，必须先调用WSAAsyncSelect()设置lEvent参数为0或调用WSAEventSelect()设置lNetworkEvents参数为0来分别禁用WSAAsyncSelect()或WSAEventSelect()，再次调用ioctlsocket()将该socket设置成阻塞模式才会成功。因为调用WSAAsyncSelect()或WSAEventSelect()函数会自动将socket设置成非阻塞模式。

❼ 为什么我的socket recv（）一直等待，接收不到东西

recv本身就是阻塞函数，必须在收到乎消消息之后才能岁返知返回，你没收到消息，说明对方没有给你发过来，或者网络故障等等都可能。

不知道你怎么判断服务器有返回数据的，我觉得你需要判断服务器发世哗送是否成功

❽ 多线程下recv为什么不阻塞

1、有没有把SOCKET设置成了非阻塞余清
2、_recv怎么实现的，你给一个自己写的竖岁前接收函数，雀或谁知道你在里面搞了什么鬼

❾ python serversocket 是非阻塞的吗

Python 利用SocketServer模块
实现网络客户端与服务器并发连接非阻塞通信
MyTCPServer.py
import SocketServer
from SocketServer import StreamRequestHandlerfrom time import ctime
host = '127.0.0.1'
port = 8001
addr = (host,port)
BUF_SIZE = 1024
class Servers(StreamRequestHandler):
def handle(self):
print 'connection from %s'%str(self.client_address)#self.wfile.write('connection %s:%s at %s succeed!' % (host,port,ctime()))while True:
try:
data = self.request.recv(1024)
if not data:
break
print "----\n%s\n[Recv]%s"%(str(self.client_address), data)self.request.send(data)
except:
break
print "disconnect %s"%str(self.client_address)print 'server is running....'
server = SocketServer.ThreadingTCPServer(addr,Servers)server.serve_forever()
MyTCPClient.py
from socket import *
host = '127.0.0.1'
port = 8001
addr = (host,port)
BUF_SIZE = 1024
client = socket(AF_INET,SOCK_STREAM)
client.connect(addr)
while True:
data = raw_input()
if data.strip() == 'exit':
break
if not data:
continue
client.send('%s\r\n'%data)
print "send:%s"%data
dataRecv = client.recv(BUF_SIZE)
print "recv:%s"%dataRecv
client.close()