在Autobahn组件中捕获连接错误

from autobahn.twisted.websocket import WebSocketClientProtocol, WebSocketClientFactory

class MyProtocol(WebSocketClientProtocol):
    def onConnect(self, response):
        print("连接成功")

    def onOpen(self):
        print("WebSocket连接已打开")

    def onMessage(self, payload, isBinary):
        print("收到消息：{}".format(payload.decode('utf8')))

    def onClose(self, wasClean, code, reason):
        print("连接已关闭")

    def onError(self, failure):
        print("连接错误：{}".format(failure.getErrorMessage()))
        # 处理连接错误的逻辑

factory = WebSocketClientFactory("ws://example.com/ws")
factory.protocol = MyProtocol

# 创建WebSocket连接
from twisted.internet import reactor
reactor.connectTCP("example.com", 80, factory)
reactor.run()