recv.py 657 B

123456789101112131415161718192021222324252627
  1. import threading
  2. import time
  3. class RECVSERVER(threading.Thread):
  4. def __init__(self, sock, config):
  5. threading.Thread.__init__(self)
  6. self.setDaemon(True)
  7. self.sock = sock
  8. def __del__(self):
  9. self.sock.close()
  10. pass
  11. def run(self):
  12. # 接收
  13. while True:
  14. try:
  15. msg = self.sock.recv(1024)
  16. if not msg:
  17. print('无数据')
  18. continue
  19. else:
  20. print('接收数据', msg.decode('utf-8'), time.ctime())
  21. except:
  22. print('服务器断开')
  23. break