3

組み込みの SocketServer の TCPServer と ThreadingMixIn を使用して、Python でマルチプレイヤー ゲーム サーバーとクライアントを作成しています。これは、ソケットとスレッド モジュールを手動で管理するよりも簡単に思えるためです。(これには組み込みモジュールを使い続けたいと思います。) 通信には HTTP に似たプロトコル (GTP) を使用します。

1 つのクライアントのみを含む要求は、既に機能しています。クライアントがリクエスト " GET /index.html GTP/0.2" を送信した場合、サーバーはそのクライアントに " " 応答するだけGTP/0.2 200 OKです。しかし、(サーバーの状態に記録されているように) クライアント A と B の間でゲームが行われており、クライアント A が要求 " " を送信した場合、プレーヤー A の順番を取得した後、サーバーはプレーヤー A と B の両方TURN <my turn info> GTP/0.2に変更をどのように通知しますか?

これまでの私のコードの要点は次のとおりです。

import SocketServer
import socket, threading # not yet used

class ThreadingGameServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
    def __init__(self, server_address, RequestHandlerClass):
        SocketServer.TCPServer.__init__(self, server_address, RequestHandlerClass)
        self.players = []
        self.games = []

class GameRequestHandler(SocketServer.BaseRequestHandler):
    def setup(self):
        self.request_data = None
        self.response_data = None

    def handle(self):
        while True:
            self.request_data = self.request.recv(4096)
            if not self.request_data:
                break # Client disconnected
            # delegate handling to do_GET, do_POST, etc
            do_method = 'do_' + self.request_data.split()[0]
            if not hasattr(self, do_method):
                self.request.sendall("GTP/0.2 501 Not Implemented\r\n\r\n")
                continue
            try:
                do = getattr(self, do_method)
                do()
            except Exception as e:
                break

    def do_GET(self):
        body = '<contents of {}>'.format(self.my_request.param)
        data = "GTP/0.2 200 OK\r\nContent-Length: {}\r\n\r\n{}".format(len(body), body)
        self.request.sendall(data)

    def do_LOGIN(self):
        """
        Create a player with the requested username and this handler.
        Add the player to self.server.players.
        Respond with 200 OK, body "Welcome!, <username>".
        """

    def do_PLAY(self):
        """
        If the requested opponent is not logged in and ready to play, respond with 403 Forbidden.
        Create a game with this player and the requested opponent.
        Remove the two players from self.server.players.
        Add the game to self.server.games.
        Respond with 200 OK, body "Begin game with <opponent>".
        How do I send "Begin game with <this player>" to the opponent as well?
        """

    def do_TURN(self):
        """
        If it is not this player's turn, respond with 403 Forbidden.
        Modify the game's state in self.server.games, including making it be the opponent's turn.
        Respond with 200 OK, body "<new game state>".
        How do I send the response to the opponent as well?
        """

    def do_EXIT(self):
        """
        If this player is logged in, log them out.
        If they are in a game, respond to their opponent with 200 OK, body "Game over" (how?).
        End their request handler.
        """

class GameClient(object):
    def __init__(self, server_address):
        self.socket = socket.create_connection(server_address)

    def run(self):
        """
        Read user input, e.g. "> login foobar".
        Send request to server, e.g. self.socket.sendall("LOGIN foobar GTP/0.2\r\n\r\n")
        Get server's reply via self.socket.recv(4096)
        Print the reply body, e.g. "Welcome, foobar!"
        """

# On the server machine
server = ThreadingGameServer((socket.gethostname(), 4242), GameRequestHandler)
server.serve_forever()

# On each client machine
client = GameClient(('server.mygame.com', 4242))
client.run()
4

1 に答える 1

1

これを行うにはおそらくもっと良い方法がありますが、私が何年も前に（Pythonを初めて使用したときに！）自分で考案した方法は、クライアントごとに一種の受信トレイを用意することでした。次に、各クライアントは定期的にサーバーに受信トレイの内容を要求し、それに応じてそれらのコマンドを解析します。

私はこの質問に目を光らせていきます、私は私よりも良い方法を見たいと思っています。また、これを試す前に回答を待つことをお勧めします。

于 2012-11-03T17:19:18.037 に答える