ツイスト共有tcp/udpプロトコル間の変数

Question

以下のtcpserverの簡単な例があります。私はファクタカウンタvarをudpサーバと共有するようにしています。そのため、それぞれの接続では、tcpとudpの両方に値が設定されます。私は、TCPで最初に接続するのであれば、それは...その、私はUDPのポートに接続する場合2が、その後...それが私の主な問題は、側面に沿って動作するUDPクラスを起動して3

#!/usr/bin/env python 

from twisted.internet.protocol import Factory, Protocol 
from twisted.internet import reactor 

class TCP(Protocol): 

    def connectionMade(self): 
     self.factory.counter += 1 
     self.transport.write(str(self.factory.counter)+'\r\n') 
     self.transport.loseConnection() 

class QOTDFactory(Factory): 

    def __init__(self, protocol='tcp'): 
     if protocol == 'tcp': 
      self.protocol = TCP 
     else: 
      self.protocol = UDP 

     self.counter = 1 

reactor.listenTCP(8007, QOTDFactory('tcp')) 
#reactor.listenUDP(8007, QOTDFactory('udp')) 

reactor.run() 

になりますでしょう私の固執ポイントです。

class QOTDFactory(Factory): 
    counter = 1 

    def __init__(self, protocol='tcp'): 
     if protocol == 'tcp': 
      self.protocol = TCP 
     else: 
      self.protocol = UDP 

     QOTDFactory.counter += 1 

Answer 1

引数をreactor.listenUDPにUDPの例に示すように、DatagramProtocolインスタンスでなければなりません：私は、私はカウンタはOKで、あなたはこのカウンタを実装するためにstatic class variableを使用することができ

Answer 2

に動作します参照する方法を考えます： http://twistedmatrix.com/documents/current/core/howto/udp.html。 QOTDFactoryをUDPで使用することはできないため、TCPとUDPの選択ロジックは必要ありません。その代わりに、希望のプロトコルロジックでDatagramProtocolサブクラスを作成し、TCPサーバーが使用するファクトリへの参照を共有させます。

#!/usr/bin/env python 

from twisted.internet.protocol import Factory, Protocol 
from twisted.internet import reactor 

class StreamCounter(Protocol): 
    def connectionMade(self): 
     self.factory.counter += 1 
     self.transport.write(str(self.factory.counter)+'\r\n') 
     self.transport.loseConnection() 


class DatagramCounter(DatagramProtocol): 
    def __init__(self, factory): 
     self.factory = factory 

    def datagramReceived(self, data, address): 
     self.factory.counter += 1 
     self.transport.write(str(self.factory.counter), address) 


class QOTDFactory(Factory): 
    counter = 0 
    protocol = StreamCounter 


factory = QOTDFactory() 
reactor.listenTCP(8007, factory) 
reactor.listenUDP(8007, DatagramCounter(factory)) 

reactor.run() 

彼らはそれぞれTCPとUDPでの使用に限定されていないので、私は、StreamCounterとDatagramCounterにTCPとUDPと改名（およびそれらはひどい説明的な名前はありませんでした;）。たとえば、reactor.listenSSLを使用してSSL上でStreamCounterを使用することもできます。

Answer 3

これはお客様のニーズに適していますか？

#!/usr/bin/env python 

from twisted.internet.protocol import Factory, Protocol 
from twisted.internet import reactor 

class Counter(): 
    def __init__(self): 
    self.count = 0 

class TCP(Protocol): 

    def connectionMade(self): 
     self.factory.counter.count += 1 
     self.transport.write(str(self.factory.counter)+'\r\n') 
     self.transport.loseConnection() 

class QOTDFactory(Factory): 

    def __init__(self, protocol, counter): 
     if protocol == 'tcp': 
      self.protocol = TCP 
     else: 
      self.protocol = UDP 

     self.counter = counter 

counter = Counter() 
reactor.listenTCP(8007, QOTDFactory('tcp', counter)) 
reactor.listenUDP(8007, QOTDFactory('udp', counter)) 

reactor.run()