python twisted autobahn发送消息

在 Autobahn 中，WebSocket 客户端和服务器端都可以通过 send 方法来发送消息，具体方法如下：

class MyServerProtocol(WebSocketServerProtocol):

    def onMessage(self, payload, isBinary):
        if isBinary:
            print("Binary message received: {} bytes".format(len(payload)))
        else:
            print("Text message received: {}".format(payload.decode('utf8')))

        # 发送消息
        self.sendMessage(payload, isBinary=isBinary)

在这个示例中，当服务器收到客户端发送的消息时，会通过 sendMessage 方法将消息发送回客户端。sendMessage 方法的第一个参数是消息的内容，第二个参数指示消息是否是二进制消息。

类似地，WebSocket 客户端也可以通过 send 方法来发送消息，具体方法如下：

from twisted.internet import reactor
from autobahn.twisted.websocket import WebSocketClientFactory, WebSocketClientProtocol

class MyClientProtocol(WebSocketClientProtocol):

    def onOpen(self):
        print("WebSocket connection opened")
        # 发送消息
        self.sendMessage("Hello, world!".encode('utf8'))

    def onMessage(self, payload, isBinary):
        if isBinary:
            print("Binary message received: {} bytes".format(len(payload)))
        else:
            print("Text message received: {}".format(payload.decode('utf8')))

if __name__ == '__main__':
    factory = WebSocketClientFactory()
    factory.protocol = MyClientProtocol

    reactor.connectTCP("localhost", 9000, factory)
    print("WebSocket client connected to server")

    reactor.run()

在这个示例中，当客户端连接到服务器时，会调用 onOpen 方法，在这个方法中可以发送消息。在这个示例中，发送了一个文本消息。在 onMessage 方法中，处理服务器发送的消息，这里只是简单地输出收到的消息。