蟒蛇阻止套接字,立即发送返回
-
19-09-2019 - |
题
我写在Python使用插座模块多线程应用插座。 服务器监听连接和当它到达一个它产生对于插座的螺纹。
服务器线程一些数据发送到客户端。但客户还没有准备好接受它。我认为这会造成服务器等到客户端启动的recv而是立即返回
客户端然后调用的recv其被阻挡并且没有数据永远接收。
客户端套接字的构造
self.__clientSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.__clientSocket.connect((server, port))
服务器插座构造
self.servSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.servSock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
#self.servSock.settimeout(None)
self.servSock.setblocking(1)
self.servSock.bind((self.addr,self.port))
self.servSock.listen(5)
听音接受螺纹
try:
(cs, address) = self.servSock.accept()
except socket.timeout:
return
threadName = '\r\nClient %s:%s\r\n' % (cs, address)
print threadName
clientSocketHandler = ClientSocket()
clientSocketHandler.setClientSocket(cs)
self.clients.newThread(self.clientFunc, {clientSocketHandler : "1"}, threadName).start()
服务器和客户端从内部ClientSocket的发送/ REC方法
receivedData = self.__clientSocket.recv(1024*1024)
self.__clientSocket.send(s)
任何想法,为什么send()方法将返回直线距离?
解决方案
任何想法,为什么send()方法将返回直线距离?
所有的send()的作用是填充网络缓冲器并返回发送的字节ammount的。
如果你想要一个发送块只是RECV来自客户端的确认消息。
其他提示
在客户端没有做好准备接收数据 - 数据将在插座的接收缓冲区排队,直到您准备的recv()它。发送立即返回,因为发送缓冲区未满 - 如果它是满了,send()方法将阻塞,直到有空间,你想发送的数据
大多数时候,你将永远不会填充它 - 你正在经历什么,因此。在一个侧面,你可能不希望用1024 * 1024 recv调用它 - 这是偏高了一点。
对不起我固定的问题询问这个问题后不久的延迟。你的答案@Lee感谢它指出我在正确的方向。 的解决方案是发送4个字节int,指定的数据的尺寸遵循。客户端总是接收这些四个字节,然后将数据的大小。
from commandClass import Command
from commandActionClass import CommandAction
import socket
from time import *
import struct
class ClientSocket():
instance = None
__connected = False
__clientSocket = None
@staticmethod
def getInstance():
if ClientSocket.instance == None:
ClientSocket.instance = ClientSocket()
return ClientSocket.instance
def __init__(self):
self.__connected = False
self.receivedData = ''
self.bufSize = 4096
self.buffer = ''
def connect(self, server, port):
if self.isConnected():
raise Exception('Already connected.')
self.__clientSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.__clientSocket.setsockopt(socket.SOL_TCP, socket.TCP_NODELAY, 1)
self.__clientSocket.connect((server, port))
self.__clientSocket.setblocking(1)
self.__connected = True
def disconnect(self):
try:
self.receivedData = ''
self.buffer = ''
self.__clientSocket.close()
except Exception, e:
print e
finally:
self.__connected = False
def sendString(self,s):
try:
if (self.isConnected()):
self.__clientSocket.send(s)
except Exception, e:
print e
self.disconnect()
def __pop(self, size):
data = self.receivedData[:size]
self.receivedData = self.receivedData[size:]
return data
def __recv(self,toRead):
self.flush()
while ((len(self.receivedData)<toRead)and(self.isConnected())):
data = self.__clientSocket.recv(self.bufSize)
if not data:
self.disconnect()
self.receivedData = self.receivedData + data
return self.__pop(toRead)
def __sendint(self, x):
self.__sendall(struct.pack("i", x))
def __recvint(self):
data = self.__recv(4)
if not data:
raise Exception('Expected to receive buffer size')
return struct.unpack("i", data)[0]
def flush(self):
if len(self.buffer)>0:
self.__clientSocket.sendall(self.buffer)
self.buffer = ''
def __sendall(self, s):
self.buffer = self.buffer + s
def send(self,s):
try:
if (not self.isConnected()):
raise Exception('Socket is not connected')
data = s.pickle()
self.__sendint(len(data))
self.__sendall(data)
except Exception, e:
self.disconnect()
raise e
def sendEOC(self):
self.send(Command(CommandAction.EOC, time()))#send our system time. can be used for ping
def receive(self):
if (not self.isConnected()):
raise Exception('Socket Error. Not Connected')
try:
#first receive the size of packet
buffsize = self.__recvint()
#now receive the actual data
data = self.__recv(buffsize)
if not data:
raise Exception('No data to receive')
command = Command.unpickle(data)
except Exception, e:
self.disconnect()
command = Command(CommandAction.Invalid, None)
raise e
#finally?
return command
def isConnected(self):
return self.__connected
def setClientSocket(self, clientSocket):
self.__clientSocket = clientSocket
self.__connected = True #assume its connected
不隶属于 StackOverflow