update 增加停止,暂停,重连,报警消除等
This commit is contained in:
@ -8,12 +8,13 @@ class TCPClient:
|
||||
self.error_count=0
|
||||
self.IPAddress = ip
|
||||
self.port = port
|
||||
self.client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
self.client_socket.settimeout(5)
|
||||
|
||||
self.connected = False
|
||||
|
||||
|
||||
def CreatConnect(self):
|
||||
self.client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
self.client_socket.settimeout(5)
|
||||
self.client_socket.connect((self.IPAddress, self.port))
|
||||
|
||||
|
||||
@ -36,7 +37,16 @@ class TCPClient:
|
||||
self.error_count += 1
|
||||
if self.error_count> 5:
|
||||
print("Error: TCPClient is not connected")
|
||||
self.CreatConnect()
|
||||
try:
|
||||
self.CreatConnect()
|
||||
except OSError as e1:
|
||||
if e1.errno == 10056:
|
||||
self.client_socket.close()
|
||||
print("Error: TCPClient is not connected")
|
||||
except Exception as e2:
|
||||
print(e2)
|
||||
|
||||
|
||||
|
||||
def send_Command(self):
|
||||
return False
|
||||
|
||||
Reference in New Issue
Block a user