Twisted: servidor tcp con ejemplo de productor de inserción?

Question

Quiero armar un servidor TCP simple usando Python y Twisted.

El servidor se inicia y espera la conexión, ya tengo el cliente, la aplicación que no es de Python. Una vez que se establece la conexión, el servidor comienza a enviar datos en algún intervalo (por ejemplo, 1 segundo).

El servidor lee los datos de un archivo estático (un registro a la vez), debería poder descifrar esta parte.

Supongo que usaría el productor de inserción para comenzar a enviar datos una vez que el cliente está conectado.

Tengo servidor tcp simple con la fábrica en retorcida y puedo reaccionar a la conexión Hechos/datos recibidos, y así sucesivamente, pero no puedo entender cómo conectar el productor de inserción.

¿Alguien conoce algún ejemplo que muestre al productor de inserción con el servidor tcp en twisted?

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 puede decirnos qué le pasa a este "servidor de inserción" excesivamente simplista, ¡tal vez podamos ofrecerle una mejor ayuda! -)

Answer 2

Here es un ejemplo completo de un productor de inserción. Se ha agregado al svn retorcido como un ejemplo.