WebSocket 使用 Python 向所有客户端广播

Question

我正在使用一个简单的基于Python的Web套接字应用程序：

from SimpleWebSocketServer import WebSocket, SimpleWebSocketServer
class SimpleEcho(WebSocket):
    def handleMessage(self):
        if self.data is None:
            self.data = ''
        # echo message back to client
        self.sendMessage(str(self.data))
    def handleConnected(self):
        print self.address, 'connected'
    def handleClose(self):
        print self.address, 'closed'
server = SimpleWebSocketServer('', 8000, SimpleEcho)
server.serveforever()

它

回显每个客户端发送到同一个客户端的消息，但我正在尝试将ws服务器收到的任何消息发送到连接到它的所有客户端。有人可以帮我吗？

Answer 1

或者

你可以这样做：

class SimpleEcho(WebSocket):
    def handleMessage(self):
        if self.data is None:
            self.data = ''
        for client in self.server.connections.itervalues():
            client.sendMessage(str(self.address[0]) + ' - ' + str(self.data))
        #echo message back to client
        #self.sendMessage(str(self.data))
    def handleConnected(self):
        print self.address, 'connected'
    def handleClose(self):
        print self.address, 'closed'

Answer 2

我认为您想创建一个列表客户端，然后按程序向每个客户端发送消息。

因此，当新客户端连接时，将它们添加到数组中：

wss = [] # Should be globally scoped
def handleConnected(self):
    print self.address, 'connected'
    if self not in wss:
        wss.append(self)

然后，当您收到新请求时，将消息发送到存储的每个客户端：

def handleMessage(self):
    if self.data is None:
        self.data = ''
    for ws in wss:
        ws.sendMessage(str(self.data))

希望对您有所帮助！

Answer 3

添加此内容以在客户端断开连接时删除，以便阵列中没有未连接的人员

def handleClose(self):
    wss.remove(self)