Клиент отключается, когда другой клиент подключается к серверу - PullRequest
0 голосов
/ 08 апреля 2020

Я пишу зашифрованную игру RPS (камень, ножницы, бумага) с Python, и она работает следующим образом. Сервер ведет игру, и два клиента просто отправляют свой выбор на сервер.

Сначала сервер ожидает присоединения 2 игроков, когда присоединились 2 игрока, он запускает игру и позволяя обоим клиентам выбирать опцию.

Моя проблема в том, что, когда первый клиент подключается, а затем другой, первый клиент автоматически отключается. Итак, я не знаю, как обращаться с обоими клиентами, и пусть первый клиент выбирает опцию, а затем разрешает второй вариант выбора.

* Примечание: я использую один и тот же файл клиента для обоих клиентов.

Сервер:

import socket
from Crypto.PublicKey import RSA
from Crypto.Cipher import PKCS1_OAEP
from time import sleep

def rules(first_choice, second_choice, mem1, mem2) -> str:
    if (first_choice == 'R' and second_choice == 'P' 
        or first_choice == 'P' and second_choice == 'S'
            or first_choice == 'S' and second_choice == 'R'):
                return f'Result: Player 2 Won\nPlayer 1 Choice - {first_choice}\nPlayer 2 Choice - {second_choice}'
    else:
        return f'Result: Player 1 Won!\nPlayer 1 Choice - {first_choice}\nPlayer 2 Choice - {second_choice}'

class Connect:
    def __init__(self):
        players = 0
        self.prikey = RSA.generate(1024)
        self.pubkey = self.prikey.publickey()
        self.token = PKCS1_OAEP.new(self.prikey)
        with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
            sock.bind(('0.0.0.0', 21523))
            sock.listen(2)
            print('Waiting for at least 2 players, please wait.')
            while True:
                self.conn, self.addr = sock.accept()
                players += 1
                if players == 1:
                    print(f'Player 1 is {self.addr}')
                    self.player1 = self.addr
                elif players == 2:
                    print(f'Player 2 is {self.addr}')
                    self.player2 = self.addr
                    self.connection()

    def connection(self) -> None:
        print('2 Players have joined, starting game in 5 seconds.\n')
        sleep(5)
        self.conn.send('Y'.encode())
        self.game_play()

    def game_play(self) -> None:
        self.conn.send(self.pubkey.exportKey())
        choice_1_cipher = self.conn.recv(1024)
        choice_1_plain = self.token.decrypt(choice_1_cipher)
        print('Got first choice, waiting for another choice..')
        choice_2_cipher = self.conn.recv(1024)
        choice_2_plain = self.token.decrypt(choice_2_cipher)
        print('Got second answer, calculating winner!')
        print(rules(choice_1_plain, choice_2_plain, self.player1, self.player2))

if __name__ == '__main__':
    Connect()

Клиент:

import socket
import random
from Crypto.Cipher import PKCS1_OAEP
from Crypto.PublicKey import RSA

class Client:
    def __init__(self):
        self.prikey = RSA.generate(2048)
        self.pubkey = self.prikey.publickey()
        self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.sock.connect(('10.0.0.42', 21523))
        data = self.sock.recv(1024).decode()
        if data == 'Y':
            self.start_game()

    def start_game(self) -> None:
        print('\n [R]ock | [P]aper | [S]cissors - ')
        while True:
            my_choice = input().upper()
            if my_choice not in ['R', 'P', 'S']:
                print('Invalid Input, input must be one of those R\\P\\S')
            else:
                user_pubkey = RSA.importKey(self.sock.recv(2048))
                token = PKCS1_OAEP.new(user_pubkey)
                cipher_choice = token.encrypt(my_choice.encode())
                self.sock.send(cipher_choice)

if __name__ == '__main__':
    try:
        Client()
    except Exception as e:
        print(f'err: {e}')
    except KeyboardInterrupt:
        print('A player has pressed [Ctrl + C] to quit the game, game ended!')

1 Ответ

0 голосов
/ 10 апреля 2020

self.conn in self.conn, self.addr = sock.accept(), когда подключение 2 клиентов перезаписывается и self.conn player1 теряется. Я полагаю, вам следует присвоить self.conn значение self.player1_conn, прежде чем вернуться к началу, пока l oop ожидает 2 игрока.

Это на самом деле повторяющаяся проблема в вашем сценарии, потому что когда вы говорите self.conn.send('Y'.encode()) self.conn относится только к соединению со вторым игроком (что, я думаю, это не то, что вы намереваетесь делать).

Вы должны отделить conn в player1_conn и player2_conn, а затем вы ' Вы сможете выбрать, кому из игроков отправить то, что вам нужно.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...