为了账号安全,请及时绑定邮箱和手机立即绑定

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

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

海绵宝宝撒 2021-03-29 21:10:02
我正在使用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跑步者一起?
查看完整描述

1 回答

  • 1 回答
  • 0 关注
  • 157 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信