python twisted autobahn程序举例

下面是一个使用 Twisted 和 Autobahn 实现的简单 WebSocket 服务器程序的示例：

from twisted.internet import reactor
from autobahn.twisted.websocket import WebSocketServerFactory, WebSocketServerProtocol

class MyServerProtocol(WebSocketServerProtocol):

    def onOpen(self):
        print("WebSocket connection opened")

    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 = WebSocketServerFactory()
    factory.protocol = MyServerProtocol

    reactor.listenTCP(9000, factory)
    print("WebSocket server listening on port 9000")

    reactor.run()

这个程序创建了一个 WebSocket 服务器，监听本地的 9000 端口，并通过 Autobahn 提供的 WebSocketServerProtocol 类来实现 WebSocket 协议。当有客户端连接到服务器时，会调用 onOpen 方法；当服务器收到客户端发送的消息时，会调用 onMessage 方法进行处理。在这个示例中，只是简单地输出收到的消息。最后使用 Twisted 的 reactor 来运行服务器。

这个示例只是一个简单的 WebSocket 服务器程序，Autobahn 还提供了更多功能，例如支持 SSL 加密、支持 WAMP 协议等。