大家好!
我有一段tornado异步tcp服务器的代码,tcp服务器向客户端发送命令,遇到一些问题.

#! /usr/bin/env python #coding=utf-8 from tornado.tcpserver import TCPServer from tornado.ioloop import IOLoop from ctypes import * import struct from const import * from systemModel import * class TcpConnection(object): def __init__(self,stream,address): self._stream=stream self._address=address self._stream.set_close_callback(self.on_close) self.getSystemInfo() self.getSystemInfo() def on_close(self): print("the monitored %d has left",self._address) def getSystemInfo(self): commandType=Command.SYSTEMINFO commandInfo=Command.NOCOMMANDINFO data=struct.pack(FormatStr.COMMANDINFO,commandType,commandInfo.encode('utf-8')) self._stream.write(data) self._stream.read_bytes(SystemInfo.len_whole,setSystemInfo) class MonitorServer(TCPServer): def handle_stream(self,stream,address): print("new connection",address,stream) TcpConnection(stream,address) if __name__=='__main__': print('server start .....') server=MonitorServer() server.listen(20000) IOLoop.instance().start()

上面有2个self.getSystemInfo(),我的意思是想,能否一下丢出几个命令,比如传文件,传信息等.但是上面的代码会报错.错误信息如下:

ERROR:tornado.application:Error in connection callback Traceback (most recent call last): File "/usr/local/lib/python3.4/dist-packages/tornado/tcpserver.py", line 269, in _handle_connection future = self.handle_stream(stream, address) File "/home/zz/PycharmProjects/monitor/server.py", line 64, in handle_stream TcpConnection(stream,address) File "/home/zz/PycharmProjects/monitor/server.py", line 18, in __init__ self.getSystemInfo() File "/home/zz/PycharmProjects/monitor/server.py", line 32, in getSystemInfo self._stream.read_bytes(SystemInfo.len_whole,setSystemInfo) File "/usr/local/lib/python3.4/dist-packages/tornado/iostream.py", line 303, in read_bytes future = self._set_read_callback(callback) File "/usr/local/lib/python3.4/dist-packages/tornado/iostream.py", line 658, in _set_read_callback assert self._read_callback is None, "Already reading" AssertionError: Already reading

这个错误信息,是不是前一个self.getSystemInfo()还没读完,后一个self.getSystemInfo()就要开始读了?我要怎样去解决这样的冲突呢