murmur/tt-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新部分提示算法

Browse Source 
临时关闭主动切断客户端的功能
This commit is contained in:
murmur 2023-03-21 15:14:32 +08:00
parent e6026ac646
commit 02a4d37cc3
1 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
server.py
View File

@ -100,18 +100,21 @@ def update_pairs(addr, ccid, clear=0):
ccid:终端号 ccid:终端号
clear:清空掉线终端""" clear:清空掉线终端"""
if ccid and not clear: if not clear:
# 添加或更新客户端 # 添加或更新客户端
pp[addr] = ccid
p.clear
if ccid not in p: if ccid not in p:
t = f"""*信息:* t = f"""*信息:*
天通终端上线。 天通终端上线。
CCID:{ccid.decode()} CCID:{ccid.decode()}
地址:{str(addr.getpeername())} 地址:{str(addr.getpeername())}
""" """
print(t)
s2wx("","天通终端上线",t) s2wx("","天通终端上线",t)
# p[ccid] = addr # p[ccid] = addr
pp[addr] = ccid
p.clear
else: else:
del p[ccid] del p[ccid]
del pp[addr] del pp[addr]
@ -343,23 +346,25 @@ class MyServer(socketserver.BaseRequestHandler):
) )
s2wx("","",f"接收到新数据，长度{len(data)}字节。") s2wx("","",f"接收到新数据，长度{len(data)}字节。")
if tt_decode(conn, data): if tt_decode(conn, data):
conn.close() self.err= "切断。"
print(self.client_address, "疑是非法连接，已切断。") print(self.client_address, "疑是非法连接")
break # conn.close()
# break
def finish(self): def finish(self):
if self.request in pp: if self.request in pp:
t = f"""终端下线了。{self.err} t = f"""终端下线了。{self.err}
CCID:{pp[self.request].decode()} CCID:{pp[self.request].decode()}
地址:{str(self.client_address)} 地址:{str(self.client_address)}"""
""" print(t)
s2wx("","天通终端下线了",t) s2wx("","天通终端下线了",t)
print("终端",self.client_address,"下线了。") # print("终端",self.client_address,"下线了。",self.err)
update_pairs(self.request,get_ccid(self.request),1) update_pairs(self.request,get_ccid(self.request),1)
else: else:
print("客户端",self.client_address,"已断开。") t= f"TCP客户端{str(self.client_address)}已断开连接。{self.err}"
s2wx("天通消息","TCP客户端断开",f"TCP客户端{str(self.client_address)}已断开连接。{self.err}") print(t)
s2wx("天通消息","TCP客户端断开",t)