猿问

如何在扭曲的应用程序服务中包装zeromq绑定套接字?

我正在使用txzmq并twisted构建一个侦听器服务,该服务将通过推拉模式处理一些数据。这是一个工作代码:


from txzmq import ZmqFactory, ZmqEndpoint, ZmqPullConnection

from twisted.internet import reactor


zf = ZmqFactory()

endpoint = ZmqEndpoint('bind', 'tcp://*:5050')


def onPull(data):

    # do something with data


puller = ZmqPullConnection(zf, endpoint)

puller.onPull = onPull


reactor.run()

我的问题是-如何将该代码包装在扭曲的应用程序服务中?也就是说,如何将其包装到特定的服务(例如MyService)中,以便以后使用它运行:


from twisted.application.service import Application


application = Application('My listener')

service = MyService(bind_address='*', port=5050)

service.setServiceParent(application)

和twistd跑步者一起?


海绵宝宝撒
浏览 158回答 1
1回答
随时随地看视频慕课网APP

相关分类

Python
我要回答