Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import socket
- class GettingMessages(Thread):
- def __init__(self, conn):
- Thread.__init__(self)
- self.conn = conn
- def run(self):
- try:
- while True:
- print('Жду сообщения...')
- data = self.conn.recv(1024)
- print("Полученное сообщение -", data.decode('utf-8'))
- if not data:
- print('Конец связи')
- self.conn.close()
- break
- except Exception:
- print(''.join(traceback.format_exception(*sys.exc_info())[1:]))
- self.conn.close()
- class FindingConnections(Thread):
- def __init__(self, sock):
- Thread.__init__(self)
- self.sock = sock
- def run(self):
- try:
- while True:
- print('Ожидаю подключение...')
- conn, addr = self.sock.accept()
- print(addr)
- gm = GettingMessages(conn)
- gm.start()
- except Exception:
- print(''.join(traceback.format_exception(*sys.exc_info())[1:]))
- sock = socket.socket()
- sock.bind(('0.0.0.0', 11011))
- sock.listen(1000) # слушаем в 1000 потоков = готовы принимать сообщения от 1000 клиентов
- listener = FindingConnections(sck)
- listener.start()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement