3

我写了一个非常简单的基于终端的扑克游戏（ascii art ftw），现在它是多人游戏，但你基本上必须通过一台计算机。有没有一种简单的（ish）方法可以让两个人从不同的机器连接并访问同一个游戏同时一起玩？它不必花哨，也不必是图形的，只要我们有终端访问权限。

我不确定如何做到这一点或者它是否实用，但只是想学习和探索一些选择。

4

2 回答 2

12

这是一个非常模糊的问题，但我可以给你一些模糊的答案。

首先，您需要设计一个简单的协议。一个非常简单的基于行的协议应该可以正常工作：UTF-8 文本、分隔消息的换行符、分隔参数的空格。例如，您可以有这些客户端->服务器消息：

JOIN name
SAY message with spaces
FOLD
RAISE amount
# ...

…以及这些服务器->客户端消息：

OK
ERROR error message
JOINED player name with spaces
LEFT player
SAID player message with spaces
NEWHAND player player player player…
DEALT player face suit
ANTED player amount
CHECKED player
# ...

像这样的协议的好处是您可以使用telnetor手动键入它nc，因此您甚至不需要客户端进行测试。

现在您需要构建一个实现该协议的服务器，并将游戏逻辑构建到服务器中。

线程服务器可能是这里最简单的东西。然后主线程启动一个游戏线程，该线程大部分时间都在Condition等待玩家行动。它还阻塞accept，为每个连接启动一个新的客户端线程，该线程大部分时间都阻塞在for line in self.sock.makefile():. 在客户端对象内部添加一个Lock以允许其他线程安全地发送消息。然后，您只需要一组带有锁的客户端对象，就完成了。

由于我有一个类似设计的聊天服务器，让我对其进行一些调整，为您提供一个框架。

首先，这是整个主线程：

lock = threading.Lock()
clients = []
game = Game()

ssock = socket.socket()
ssock.bind(('', 12345))
ssock.listen(5)
while True:
    sock, addr = ssock.accept()
    with lock:
        clients.append(Client(addr, sock, len(clients))

该Client对象是标准调度程序：

class Client(object):
    def __init__(self, addr, sock, number):
        self.sock = sock
        self.name = '<{}> (not logged in)'.format(addr)
        self.number = number
        self.lock = threading.Lock()
        self.thread = threading.Thread(target=self.serve)
        self.thread.start()

    def send(self, msg):
        with self.lock:
            self.sock.send(msg)

    def run(self):
        for line in self.sock.makefile():
            args = line.rstrip().split()
            cmd = args.pop().upper()
            method = getattr(self, 'do_{}'.format(cmd), None)
            if method is none:
                self.write('ERROR unknown command {}\n'.format(cmd))
            else:
                try:
                    method(*args)
                except Exception as e:
                    self.send('ERROR in {}: {}\n'.format(cmd, e))
                else:
                    self.send('OK\n')

您可能还需要一个broadcast功能：

def broadcast(msg):
    with lock:
        for client in clients:
            client.send(msg)

Client然后为每个命令编写方法。基本上，elif response == 'FOO'你在菜单代码中的每一个都变成了一个do_FOO方法，每一个都print变成了一个broadcast，并且……就是这样。稍后我会展示一个更复杂的，但大多数都是这样的：

def do_SAY(self, *msg):
    broadcast('SAID {} {}'.format(self.number, ' '.join(msg)))

最后就是Game对象了。它运行在自己的线程上，就像 each 一样Client。在大多数情况下，它的run方法与您的顺序、非网络游戏中的逻辑相同。当然你必须打电话broadcast而不是打电话print，但这很容易。唯一棘手的一点是您需要一些同步。

例如，在开始新手之前，您必须复制玩家列表（可能还有其他一些相关的游戏状态），以便其他线程可以修改它而不影响当前游戏，并且您还需要等到有足够的玩家你不会和 1 个人玩自己的起手牌。所以：

def new_hand(self):
    with self.condition:
        while len(self.players) < 2:
            self.condition.wait()
        players = self.players
    # all your existing sequential logic

并且您需要添加一个join方法让客户端从他们自己的线程中调用：

def join(self, player):
    with self.condition:
        self.players.append(self)
        self.condition.notify()

因此，在Client对象中：

def do_JOIN(self, name):
    self.name = name
    game.join(self)
    broadcast('JOINED {} {}'.format(self.number, self.name)

让我们让等待下注变得尽可能复杂，看看即使在最坏的情况下它是多么容易。如果你想下注，你可以。每个人都可以看到你的下注，如果情况发生变化，你就会下注（例如，如果你跟注，那么你前面的人加注，你跟注他的新下注）。所以，这就是我们要做的：

def wait_for_bets(self, bettor):
    with self.condition:
        while self.bets[self.bettor] is None:
            self.condition.wait()
        bettor, bet = self.bettor, self.bets[self.bettor]
        self.bets[self.bettor] = None
    # handle the bet

以下是 aClient提交投注的方式：

def bet(self, player, bet):
    with self.condition:
        self.bets[player] = bet
        self.condition.notify()

例如，在Client：

def do_FOLD(self):
    game.bet(self, 'fold')

显然有一堆代码要写。但关键是，除了上面已经显示的或您现有的游戏中已经显示的内容之外，没有什么复杂的。

于 2013-06-19T01:53:11.683 回答
0

您将需要托管某种类型的服务器，并编写一个程序来处理包含某些类型数据的请求，并将其传回给客户端。由于这不是实时游戏，因此您不需要过多地使用 TC/IP、UDP 或任何东西，简单的 HTTP 请求可能就可以了。

事实上，您甚至可以使用名为Scoreoid的免费服务。我将它用于我的游戏。它专为高分排行榜而设计，但它可能会满足您的需求。它非常易于使用。由于 API 完全由 URL 工作，因此您可以只使用标准库的urllib模块。这可能是开始这类事情的一个很好的方法。

于 2013-06-19T00:12:57.160 回答