Witam, tworzę prosty czat w pythonie. Czat dzieli się na dwa pliki server.py i client.py. Na razie napisałem tylko część servera, która powinna akceptować połączenia z klientami(wątek pierwszy) i nasłuchiwać czy klient czegoś nie wysyła (każde połączenie z klientem jest obsługiwane przez oddzielny wątek nasłuchujący) i jeśli coś wyśle to wypisuje to na ekranie aby było wiadomo, że coś odebrał. Niestety problem polega na tym, że gdy tworzę nowy wątek poprzedni przestaje działać. Tylko najnowszy wątek jest wykonywany a reszta jakby nie istniała.
Klient jest na razie tymczasowy i pozwala jedynie na nawiązanie połączenia i wysyłania wiadomości do servera.
Oto kod:
server.py
import socket
import threading
from queue import Queue
import time
import sys
HOST = ''
PORT = 9999
connections = []
addresses = []
queue = Queue()
def setup_socket():
try:
global s
s=socket.socket()
s.bind((HOST, PORT))
s.listen(5)
print("Socket has been set up")
except socket.error as msg:
print("Error while setting up socket: " + str(msg))
print("Retrying: \n")
setup_socket()
def accept_connections():
while True:
try:
conn, addr = s.accept()
s.setblocking(1) #preventing timeout
connections.append(conn)
addresses.append(addr)
create_thread()
number_of_connections = len(connections)-1
add_to_queue(number_of_connections)
print("Connection has been established" + str(addr))
except:
print("Error while accepting connections")
def receive_from_connections(conn_num):
while True:
msg = str(connections[conn_num].recv(20480), "utf-8")
print(msg)
def create_thread():
t = threading.Thread(target=threads_work)
t.daemon = True
t.start()
def threads_work():
while True:
x = queue.get()
if x == -1:
setup_socket()
accept_connections()
if x is not None:
print("Thread "+str(x)+" is running")
receive_from_connections(x)
queue.task_done()
def add_to_queue(job):
queue.put(job)
queue.join()
def main():
create_thread()
add_to_queue(-1)
if __name__ == '__main__':
main()
client.py
import socket
HOST = '...' # tu trzeba wpisać IP swojego komputera
PORT = 9999
def connect_to_server():
global s
s = socket.socket()
s.connect((HOST, PORT))
def send_message():
while True:
msg = input('>')
s.send(str.encode(msg))
def main():
connect_to_server()
send_message()
if __name__ == '__main__':
main()
Z góry dziękuję za pomoc.
