当前位置：文江博客话题详情

Twisted：带有推送生产者示例的 tcp 服务器？

发布于 2024-08-08 11:22:58 字数 362 浏览 1 评论 0原文

我想使用 Python 和 Twisted 组合简单的 TCP 服务器。

服务器启动并等待连接 - 我已经有客户端 - 非 python 应用程序。一旦建立连接，服务器就会开始以一定的间隔（例如1秒）发送数据。

服务器从静态文件读取数据（一次一条记录），我应该能够弄清楚这部分。

我假设一旦客户端连接，我将使用推送生成器开始推送数据。

我有一个简单的tcp服务器，工厂是twisted，我可以对connectionMade/dataReceived等做出反应，但我不知道如何插入推送生产者。

有人知道在twisted中显示带有tcp服务器的推送生产者的示例吗？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

旧竹 2024-08-15 11:22:58

这里是推送生成器的完整示例。它已被添加到twisted svn 中作为示例。

回复收藏 0 原文

末が日狂欢 2024-08-15 11:22:58

一些简单的事情怎么样：

thedata = '''
Questa mattina
mi son svegliato
o bella ciao, bella ciao,
bella ciao, ciao, ciao
questa mattina
mi son svegliato
ho trovato l'invasor!
'''.splitlines(True)

class Push(protocol.Protocol):
    """This is just about the simplest possible protocol"""
    def connectionMade(self):
        for line in thedata:
          if not line or line.isspace():
            continue
          self.transport.write(line)
          time.sleep(1.0)
        self.transport.loseConnection()

这有硬编码的数据，但你说从文件中读取它不是你的问题。如果您能告诉我们这个过于简单的“推送服务器”有什么问题，也许我们可以提供更好的帮助！-)

What about something simplistic like:

thedata = '''
Questa mattina
mi son svegliato
o bella ciao, bella ciao,
bella ciao, ciao, ciao
questa mattina
mi son svegliato
ho trovato l'invasor!
'''.splitlines(True)

class Push(protocol.Protocol):
    """This is just about the simplest possible protocol"""
    def connectionMade(self):
        for line in thedata:
          if not line or line.isspace():
            continue
          self.transport.write(line)
          time.sleep(1.0)
        self.transport.loseConnection()

This has hard-coded data, but you say that reading it from a file instead is not your problem. If you can tell us what's wrong with this overly simplistic "push server", maybe we can offer better help!-)

回复收藏 0 原文

~没有更多了~