Доброе утром всем товарищем программистам. Я написал программу для одногруппников, чтобы вместо денег использовать валюту в Python. Однако, возникла проблема с подключением к серверу, поскольку только один клиент может подключиться, хотя в программе установлено значение "2" для serversocket.listen(2)
. Знакомый мне посоветовал попробовать библиотеку threading
, так что я попробую сейчас использовать этот модуль.
Как работает мой сервер: Когда клиент подключается, сервер генерирует уникальный идентификатор для клиента и сохраняет начальное значение счета в словаре. Затем сервер ожидает сообщения от клиента с указанием суммы и идентификатора получателя. После получения сообщения сервер проверяет, существует ли получатель в словаре клиентов. Если да, то сервер обновляет счета отправителя и получателя, и отправляет клиенту информацию о новых счетах. Если получатель не существует, сервер отправляет сообщение об ошибке.
Код клиента:
Этот код представляет собой клиентскую часть программы, которая подключается к серверу по сокету, взаимодействуя с ним через TCP-соединение. Клиент получает уникальный идентификатор от сервера при подключении, после чего вы можете отправлять запросы серверу, указывая количество очков и идентификатор получателя. В ответ на запрос, сервер обрабатывает данные, меняя количество очков у отправителя и получателя, затем отправляет ответ обновленный баланс отправителя и получателя.
Когда вы вводите quit
, клиент отправляет это сообщение серверу и закрывает соединение.
Цель: Сделать так, чтобы к серверу смогли одновременно смогли подключиться хотя бы на данный момент всего два клиента. Также, следует внести изменения в программу для оптимизации её производительности и устойчивости, так чтобы серверы не "падал" и не завершал работу слишком часто. Но приоритетной для меня целью является разобраться с подключением клиентом! Заранее спасибо человеку, который поможет мне!
Код сервера:
import socket
import random
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
host = "localhost"
port = 12345
server_socket.bind((host, port))
server_socket.listen(2)
print("Сервер запущен на порту", port)
clients = {}
def handle_client(client_socket, client_address):
id_value = str(random.randint(100000, 999999))
clients[id_value] = 100
client_socket.send(id_value.encode())
while True:
data = client_socket.recv(1024).decode()
print("Получено от клиента:", data)
if data == "quit":
break
amount, recipient_id = data.split(",")
amount = int(amount)
if recipient_id in clients:
sender_score = clients[id_value]
sender_score -= amount
clients[id_value] = sender_score
recipient_score = clients[recipient_id]
recipient_score += amount
clients[recipient_id] = recipient_score
response = "Ваши очки: {}\nСчет получателя: {}".format(sender_score, recipient_score)
client_socket.send(response.encode())
else:
error_msg = "Неверный идентификатор получателя"
client_socket.send(error_msg.encode())
del clients[id_value]
client_socket.close()
while True:
client_socket, client_address = server_socket.accept()
print("Установлено соединение с клиентом", client_address)
handle_client(client_socket, client_address)
Код клиента:
import socket
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# Подключение к серверу
host = "localhost"
port = 12345
client_socket.connect((host, port))
client_id = client_socket.recv(1024).decode()
print("Ваш id:", client_id)
while True:
amount = input("Введите количество очков для отправки ('quit' для выхода): ")
if amount == "quit":
client_socket.send(amount.encode())
break
recipient_id = input("Введите id получателя: ")
data = "{},{}".format(amount, recipient_id)
client_socket.send(data.encode())
response = client_socket.recv(1024).decode()
print(response)
client_socket.close()
asyncio
будет избыточным и не приведет к улучшению производительности.