扭曲：用推制片例如TCP服务器？

Question

我想把一起使用Python和扭曲简单的TCP服务器。

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

在服务器从一个静态文件（在时间的记录）中读取数据，我应该能够找出这个部分。

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

我与工厂简单TCP服务器在扭曲和我可以对connectionMade / dataReceived反应等，但我不能图的如何在推插生产者

<强>任何人都知道示出在扭曲TCP服务器推送生产者任何例子吗

Answer 1

关于喜欢的东西简单化什么：

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

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

Answer 2

这里是推生产者的一个完整的例子。它被添加到扭曲SVN，例如，