Advertisement
Guest User

Untitled

a guest
Jul 28th, 2018
463
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.39 KB | None | 0 0
  1. import socket
  2.  
  3.  
  4. class GettingMessages(Thread):
  5. def __init__(self, conn):
  6. Thread.__init__(self)
  7. self.conn = conn
  8.  
  9. def run(self):
  10. try:
  11. while True:
  12. print('Жду сообщения...')
  13. data = self.conn.recv(1024)
  14. print("Полученное сообщение -", data.decode('utf-8'))
  15. if not data:
  16. print('Конец связи')
  17. self.conn.close()
  18. break
  19. except Exception:
  20. print(''.join(traceback.format_exception(*sys.exc_info())[1:]))
  21. self.conn.close()
  22.  
  23.  
  24. class FindingConnections(Thread):
  25. def __init__(self, sock):
  26. Thread.__init__(self)
  27. self.sock = sock
  28.  
  29. def run(self):
  30. try:
  31. while True:
  32. print('Ожидаю подключение...')
  33. conn, addr = self.sock.accept()
  34. print(addr)
  35. gm = GettingMessages(conn)
  36. gm.start()
  37. except Exception:
  38. print(''.join(traceback.format_exception(*sys.exc_info())[1:]))
  39.  
  40.  
  41. sock = socket.socket()
  42. sock.bind(('0.0.0.0', 11011))
  43.  
  44. sock.listen(1000) # слушаем в 1000 потоков = готовы принимать сообщения от 1000 клиентов
  45. listener = FindingConnections(sck)
  46. listener.start()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement