server.py 文件源码

def on_message(self, message):
        """Called when a websocket client sends a message."""

        # print the message to the console
        print("client sent: {!r}".format(message))

        # try to parse the message
        try:
            parsed_message = json.loads(message)
        except ValueError:
            print("Failed to parse message: {!r}".format(message))
            return

        # if there's a "message" in the message, echo it to everyone
        if "message" in parsed_message:
            if parsed_message["message"].startswith("/nick "):
                self.nickname = parsed_message["message"].split()[1]
                return
            response = {
                "client" : self.nickname,
                "color" : self.color,
                "message" : parsed_message["message"]
            }
            # respond to the message
            m = json.dumps(response)
            for connection in client_connections:
                connection.write_message(m)
            print("messaged {} clients".format(len(client_connections)))
        else:
            print("message unhandled.")