Twisted: servidor TCP con el ejemplo productor de empuje?

Question

Quiero juntar servidor TCP simple usando Python y trenzado.

El servidor se pone en marcha y espera para la conexión - Ya tengo aplicación cliente - no pitón. Una vez que la conexión se hace de servidor inicia el envío de datos a un cierto intervalo (por ejemplo, 1 seg).

El servidor lee datos de un archivo estático (un registro a la vez), que debería ser capaz de entender esta parte.

Asumo que yo usaría productor empuje para empezar a empujar los datos una vez cliente está conectado.

Tengo servidor TCP sencilla con la fábrica en retorcida y que pueda reaccionar a connectionMade / DataReceived y así sucesivamente, pero no puedo cifra encontrar la manera de conectar el productor de empuje .

Cualquier persona conoce ningún ejemplo que muestran productor de empuje con el servidor TCP en el trenzado?

Answer 1

¿Qué pasa algo simplista como:

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

Esto tiene datos codificados de forma rígida, pero decir que la lectura de un archivo en lugar no es su problema. Si nos puede decir lo que está mal con este excesivamente simplista "servidor de inserción", tal vez podamos ofrecer una mejor ayuda! -)

Answer 2

Aquí es un ejemplo completo de un productor de empuje . Se ha añadido a la svn trenzado como un ejemplo.