一个对等对象处理多个客户端

Question

我有一个使用 TCP 和 Twisted 的服务器-客户端代码。我希望创建的第一个对等对象（按第一个连接的客户端的顺序）服务（ 发送消息）未来即将到来的客户。所以我保存了第一个对等点（全局列表），并将它用于所有即将到来的连接，但它只服务于第一个客户端（它连接到），而忽略其他客户端。

我怎样才能让对等体同时为所有连接的客户端提供服务？（我将测试不超过 3 个客户端）。

def connectionMade(self):
            global connectedList
    if self.pt == 'client':
        self.connected = True
    else:                 
        print "Connected from", self.transport.client
        try:
            self.transport.write('<connection up>')
        except Exception, e:
            print e.args[0]
        self.ts = time.time()
        reactor.callLater(5, self.sendUpdate)

    connectedList.append(self.transport) # add peer object




def sendUpdate(self):
            global updateCounter, connectedList
    print "Sending update"
    try:
                    updateCounter += 1
                    print(connectedList[0])
                    # Send updates through first connected peer
                    connectedList[0].write('<update ' + str(updateCounter) + '>')
    except Exception, ex1:
        print "Exception trying to send: ", ex1.args[0]
    if self.connected == True:
        reactor.callLater(5, self.sendUpdate)

Answer 1

也为未来即将到来的客户提供服务（发送消息）

这句话很难理解。我的解释是，您希望sendUpdate 向除第一个客户端（按连接时排序）之外的所有客户端发送消息。

但它只服务于第一个客户

这同样困难。我的解释是，您观察到只有第一个客户端（按连接时排序）从服务器接收任何消息的行为。

这是您向客户发送消息的代码：

connectedList[0].write('<update ' + str(updateCounter) + '>')

请注意，此代码始终向connectedList[0] 发送消息。也就是说，它只向 one 客户端发送消息——不管有多少——它总是选择 connectedList 中的 first 客户端（对应于第一个客户端连接到服务器）。

你可能想要更多这样的东西：

for c in connectedList[1:]:
    c.write('<update ' + str(updateCounter) + '>')

注意这是如何向多个客户端发送消息的。

此外，与您的问题无关，您应该避免使用全局变量，并且应该避免使用裸露的 ITransport 作为您的协议接口。