如何解决 websocket ping 超时？

Question

在运行以下代码时（理论上它应该每分钟发送一个值）

from __future__ import print_function
from twisted.internet.ssl import CertificateOptions
options = CertificateOptions()
from os import environ
from twisted.internet.defer import inlineCallbacks
from twisted.internet import reactor
from autobahn.twisted.wamp import ApplicationSession, ApplicationRunner
from autobahn import wamp
from datetime import datetime, timedelta
import xlwings as wb
import time
import xlwings as wb

class Component(ApplicationSession):

"""
An application component that publishes an event every second.
"""

@inlineCallbacks
def onJoin(self, details):
    print("session attached")


while True:
    try:
        wb.Book(r'C:\Users\Administrator\Desktop\Datasets\test_feed.xlsx')
        e = wb.Range('A2').value
        b = wb.Range('C2').value
        c = wb.Range('E2').value
    except Exception:
        print("----Waiting for RTD server response----")
        time.sleep(1)          
    try:                
        epoch = datetime(now.year, now.month, now.day)
        result = epoch + timedelta(days=c)
        result = result.replace(microsecond=0, second=0)
        if result > now:
            now = result
            print("Stock", e, "Time", now, "Price", b)
            self.publish(u'com.myapp.ma', b)
    except Exception:
        print("-----Waiting1 for RTD server response----")
        time.sleep(1)
def onDisconnect(self):
        print("disconnected")
        reactor.stop()



if __name__ == '__main__':
    runner = ApplicationRunner(
        environ.get("AUTOBAHN_DEMO_ROUTER", u"ws://127.0.0.1:8080/ws"),
        u"crossbardemo")
    runner.run(Component)

返回如下错误

2017-12-28T18:43:52+0100 [Router       1604] dropping connection to peer tcp4:127.0.0.1:61531 with abort=True: WebSocket ping timeout (peer did not respond with pong in time)
2017-12-28T18:43:52+0100 [Router       1604] session "8526139172223346" left realm "crossbardemo"

我尝试解决这个问题的方法：

我）

from twisted.internet.ssl import CertificateOptions
options = CertificateOptions()
if __name__ == '__main__':
    runner = ApplicationRunner(
        environ.get("AUTOBAHN_DEMO_ROUTER", u"ws://127.0.0.1:8080/ws"),
        u"crossbardemo", ssl=options)
    runner.run(Component)

二）

if __name__ == '__main__':
    runner = ApplicationRunner(
        environ.get("AUTOBAHN_DEMO_ROUTER", u"ws://127.0.0.1:8080/ws"),
        u"crossbardemo",
    )
    runner.run(Component, auto_reconnect=True)

三）

注册编辑

[HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Control\SecurityProviders\SCHANNEL\Protocols\TLS

1.0]

[HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Control\SecurityProviders\SCHANNEL\Protocols\TLS

1.0\客户端] "DisabledByDefault"=dword:00000000 “启用”=dword:00000001

四）

安装证书模块（pip install certifi）设置SSL_CERT_FILE，比如 导出 SSL_CERT_FILE="$(python -m certifi)"

仍然是同样的错误。我在 Windows 10 上运行，带有交叉开关演示路由器、高速公路和扭曲。

路由器配置链接：

https://github.com/crossbario/autobahn-python/tree/master/examples/twisted/wamp/pubsub/basic/.crossbar

另外，下面的示例代码工作正常：

counter = 100
        while True:
            print("publish: com.myapp.ma", counter)
            self.publish(u'com.myapp.ma', counter)
            counter += 100
            yield sleep(30)

Answer 1

为了让 Twisted 处理更多的 I/O 事件，您必须将控制权交还给反应器。 Twisted 实现了一个协作多任务系统。各种任务在反应器线程中运行。这是通过每项任务仅花费短暂的控制时间来完成的。代码如下：

while True:
     ...
     sleep(1)

防止任何其他任务获得执行控制权，并防止反应器获得控制权以服务 I/O 事件。

由于这段代码在一个用inlineCallbacks 修饰的函数中，所以有一个很小的变化，至少不会与 Twisted 的操作模式完全不兼容。

试试这个表达式，而不是time.sleep(1)：

yield deferLater(reactor, 1, lambda: None)

然后从twisted.internet.task 导入deferLater。这将执行“睡眠”，将控制权交还给反应堆，并让其他任务在睡眠期间执行。这应该允许 Autobahn 发送必要的 ping/pong 消息，并允许它处理您的 publish 呼叫。