WebSocket在收到1000条消息后关闭

Question

我正在编写一个应用程序，用WebSocket将apachekafka的消息流式传输到浏览器。当服务器有一段时间不使用消息并且偏移量落后时，websocket将在1000或2000条消息之后关闭。这个数字似乎在每次测试运行时都在这两者之间交替。消息是utf8，长度通常为130-140字节，分为8字节片段。在

当偏移量被捕获，消息以稍慢的速度传入时，它会持续更长时间，但有时在打开一段时间后仍会随机关闭。在

在服务器端，我使用的是带有Twisted的Autobahn、kafka-python库以及浏览器端的原生WebSocket对象。在任何情况下，两端都会收到1006错误代码（意外关闭）。在

我目前只在RHEL和OSX上用Firefox31测试过。服务器的python版本是2.6.6。升级是相当困难的，所以不幸的是，我不能仅仅看到一个新的python版本是否可以修复它；但是如果确实是这个问题，那么它是可以做到的。在

目前的代码非常简单-当连接打开时，服务器开始消费Kafka消息并将其发送到websocket上。客户机在使用jquery将它们添加到一个简单的span元素之后，将它们添加到主体中。在

Answer 1

如果没有代码示例，我可以想到的一个问题是您没有处理WebSocketPING / PONG帧，因此浏览器在某个时候认为连接是非活动的。在

你可以试试这个：https://github.com/tavendo/AutobahnPython/tree/master/examples/twisted/websocket/ping