我在 Linux 中有一个简单的 Asyncore 客户端,它与在 Windows 机器上用 C 开发的服务器进行交互。
该设置适用于大约每秒一次写入异步缓冲区的数据速率,但只要我的数据速率超过该值(我每 0.1 秒测试一次),Asyncore 就不会发送所有写入。一些缓冲区值会丢失,并且永远不会到达服务器。
我怀疑这是因为 asyncore 经历了一个循环,并且只检查缓冲区中是否有数据在每个循环中发送一次,如果数据速率高于循环时间,那么它们就会丢失。这是真的?如果是这样,是否有解决此问题的方法或 Asyncore 以外的其他套接字模块不会造成此问题?
这是我正在使用的代码:
class DETClient(asyncore.dispatcher):
buffer = ""
t = None
def __init__(self, host, port):
asyncore.dispatcher.__init__(self)
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.connect((host,port))
self.host=host
self.port=port
self.t = ReceiverBoard(self)
self.t.start()
def initiate_connection_with_server(self):
print("trying to initialize connection with server...")
asyncore.dispatcher.__init__(self)
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.connect((self.host,self.port))
def sendCommand(self, command):
self.buffer = command +'\0'
def handle_connect(self):
pass
def handle_error(self):
print("problem reaching server.")
self.initiate_connection_with_server()
def handle_close(self):
self.t.stop()
self.close()
def handle_read(self):
message = str(self.recv(20)) #how many bytes should be read?
if (message=="b'system_bias_ON'"):
self.t.enable_sys_bias()
if (message=="b'system_bias_OFF'"):
self.t.disable_sys_bias()
if (message[2:5]=="DET"):
self.t.DET_bias_command_received = True
self.t.DET_bias_command_text = message
if (message[2:7]=="CURVE"):
self.t.DET_bias_command_received = True
self.t.DET_bias_command_text = message
def handle_write(self):
sent=self.send(self.buffer.encode())
self.buffer=""