ツイスト:プッシュプロデューサーの例とTCPサーバ?
質問
私は一緒にPythonとツイストを使用して簡単なTCPサーバーを置きたい。
サーバーは、接続のために起動して待機 - 非Pythonアプリケーション - 私はすでにクライアントを持っています。接続が確立されると、サーバは、いくつかの時間間隔(例えば1秒)でデータの送信を開始します。
サーバーは、静的なファイル(当時のレコード)からのデータは、私はこの部分を把握することができるはず読み込みます。
私は、クライアントが接続されると、データをプッシュを開始するためにプッシュプロデューサーを使用することを前提としています。
私はツイストに工場を持つ単純なTCPサーバを持っていると私はconnectionMade / dataReceivedに反応することができますし、そうでなく、私はできないの図のアウトプッシュプロデューサーにプラグインする方法の。
の誰でもツイストでTCPサーバとプッシュプロデューサーを示す任意の例を知っている?の
解決
のような単純な何かについて何ます:
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()
これはハードコーディングされたデータを持っていますが、あなたの代わりに、ファイルから読み取ることは問題ではないことを言います。あなたは、この過度に単純化した「プッシュサーバ」と間違って何私たちに伝えることができた場合は、多分私達はより良い援助を提供することができます - !)
他のヒント
こちらプッシュ生産の完全な例であります。それは、一例として、ツイストのsvnに追加されています。
所属していません StackOverflow