6

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

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

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

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

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

任何人都知道任何显示带有 tcp 服务器的推送生产者的例子吗？

4

2 回答 2

4

这是推送生产者的完整示例。它已作为示例添加到扭曲的 svn 中。

于 2010-06-21T21:57:50.157 回答
2

像这样简单的东西呢：

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()

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

于 2009-10-20T04:26:40.157 回答