Autobahn Python - 未在服务器上调用 onMessage 事件答案

【问题标题】：Autobahn Python - onMessage event not called on serverAutobahn Python - 未在服务器上调用 onMessage 事件
【发布时间】：2017-11-13 02:02:07
【问题描述】：

我对 python 和 websockets 很陌生，我正在使用 Twisted 和高速公路为一个学校项目创建一个 WebSocket 服务器。我正在使用来自this Python chat example.

的 html/javascript 客户端测试此服务器

服务器本身通过 key(sessionID):client 的字典跟踪连接的客户端。当调用 OnMessage() 时，我读取该值，创建一个 json，然后使用 Kafka 将其发送以进行其他处理。

服务器在我的本地主机上运行良好，使用我们学校提供的 Ubuntu 服务器上的 Kafka。但是，在我尝试在 Ubuntu 服务器上部署此 WebSocket 服务器后，我无法让 OnMessage() 事件发生。

我得到了 OnOpen(), OnClose() 事件，但是 OnMessage（也有 OnMessageBegin）事件永远不会被调用，无论我对客户端/服务器做什么。

我尝试通过 iptables 和 ufw 关闭防火墙，但没有成功。由于此服务器的限制，仅开放 8000 到 9000 范围内的端口。使用 websockets 时，这可能是高速公路/扭曲的问题吗？

这是我用于 WebSocket 服务器协议的代码：

class MiddleServerProtocol(WebSocketServerProtocol):

def onConnect(self, request):
    logger.info("Client connecting: {0}".format(request.peer))

def onOpen(self):
    identifier = uuid.uuid4()
    self.factory.register(self, identifier)
    logger.info("WebSocket connection open, Session ID: " + identifier)

def onMessageBegin(self, isBinary):
    super(MiddleServerProtocol, self).onMessageBegin(isBinary)


def onMessage(self, payload, is_binary):
    key = str(list(clients.keys())[list(clients.values()).index(self)])
    if is_binary:
        logger.error("Invalid message recieved: {0} bytes".
                     format(len(payload)) + " , Session ID: " + key)
    else:
        # SEND MESSAGE TO KAFKA
        message = prepare_message(payload, key).encode("utf-8")
        self.factory.producer_kafka.send(configLoad.
                                         get_value('TOPIC_SEND'),
                                         value=json.loads(message),
                                         key=key.encode('utf-8'))
        self.factory.producer_kafka.flush()
        logger.info("Json message received: " + message.
                    decode('cp1250') + " ,Session ID: " + key)

def onClose(self, was_clean, code, reason):
    key = str(list(clients.keys())[list(clients.values()).index(self)])
    logger.info("WebSocket connection closed: {0}".
                format(reason) + " , Session ID: " + key)

这是我用于 Websocket Server Factory 的代码：

class MiddleServerFactory(WebSocketServerFactory):

def __init__(self, *args, **kwargs):
    super(MiddleServerFactory, self).__init__(*args, **kwargs)
    self.producer_kafka = KafkaProducer(value_serializer=lambda v: json.dumps(v).encode('utf-8'),
                                        bootstrap_servers=configLoad.
                                        get_value('BOOTSTRAPSERVER'))
    logger.info(" Server successfully started.")

def register(self, client, identifier):
    """
   Add client to list of managed connections.
   We use generated ID as a unique identifier.
   """
    clients[identifier] = client

def unregister(self, identifier):
    """
   Remove client from list of managed connections.
   """
    del clients[identifier]

这是我的运行方式：

factory = MiddleServerFactory(configLoad.get_value('URL'))
factory.protocol = MiddleServerProtocol
reactor.listenTCP(int(configLoad.get_value('PORT')), factory)
reactor.run()

提前感谢所有帮助和建议。

【问题讨论】：

标签： python websocket twisted ubuntu-server autobahn

【解决方案1】：

致仍然想知道的人：

这个问题是我没有在服务器和客户端之间使用 HTTPS (WSS) 通信，因为服务器本身位于代理后面，这会弄乱 HTTP 标头。为了解决这个问题，我不得不切换到 HTTPS (WSS) 通信，这显然会保持 HTTP 标头加密并且代理不会与它们混淆。

【讨论】：