我正在使用txzmq并twisted构建一个侦听器服务,该服务将通过推拉模式处理一些数据。这是一个工作代码:from txzmq import ZmqFactory, ZmqEndpoint, ZmqPullConnectionfrom twisted.internet import reactorzf = ZmqFactory()endpoint = ZmqEndpoint('bind', 'tcp://*:5050')def onPull(data): # do something with datapuller = ZmqPullConnection(zf, endpoint)puller.onPull = onPullreactor.run()我的问题是-如何将该代码包装在扭曲的应用程序服务中?也就是说,如何将其包装到特定的服务(例如MyService)中,以便以后使用它运行:from twisted.application.service import Applicationapplication = Application('My listener')service = MyService(bind_address='*', port=5050)service.setServiceParent(application)和twistd跑步者一起?
添加回答
举报
0/150
提交
取消