Twistedは、工場外からすべてのクライアントにデータを送信します。ルーピングコール

Question

私は簡単なツイスト問題を解決しようとしています。

私は、単純化のためにPython 2.7 Twisted Chat.pyの例を使用しています。私がやろうとしている何

from twisted.internet.protocol import Factory 
from twisted.protocols.basic import LineReceiver 
from twisted.internet import reactor 

class Chat(LineReceiver): 

    def __init__(self, users): 
     self.users = users 
     self.name = None 
     self.state = "GETNAME" 

    def connectionMade(self): 
     self.sendLine("What's your name?") 

    def connectionLost(self, reason): 
     if self.users.has_key(self.name): 
      del self.users[self.name] 

    def lineReceived(self, line): 
     if self.state == "GETNAME": 
      self.handle_GETNAME(line) 
     else: 
      self.handle_CHAT(line) 

    def handle_GETNAME(self, name): 
     if self.users.has_key(name): 
      self.sendLine("Name taken, please choose another.") 
      return 
     self.sendLine("Welcome, %s!" % (name,)) 
     self.name = name 
     self.users[name] = self 
     self.state = "CHAT" 

    def handle_CHAT(self, message): 
     message = "<%s> %s" % (self.name, message) 
     for name, protocol in self.users.iteritems(): 
      if protocol != self: 
       protocol.sendLine(message) 


class ChatFactory(Factory): 

    def __init__(self): 
     self.users = {} # maps user names to Chat instances 

    def buildProtocol(self, addr): 
     return Chat(self.users) 


reactor.listenTCP(8123, ChatFactory()) 
reactor.run() 

は60秒ごとに実行され、接続されているすべてのセッションにデータを送信するタスクを作成するにはtwisted.internetタスクを使用しています。

半擬似コード

def broadcastmsg(): 
    for client in factory: 
     client.protocol.transport.write("I am a Test\n\r") 

event = task.LoopingCall(broadcastmsg) 
event.start(60) 

問題は、私が正しく動作するようにツイストを取得することはできませんです。私はそれをセッションごとに行うことができます。しかし、接続するたびに2倍のスパムが掛かります。

Answer 1

どのようにしてルーピング呼び出しを設定していますか？

ご存知のように、プロトコルは工場で作成され、管理されています。すべてのユーザーにメッセージを定期的に送信することは、工場に入れなければならない作業のように見えます。ファクトリ__init__のメソッドでloopingCallを作成し、initの直後に起動することができます。すべての接続ごとに1つの工場があるので、60秒に1回のみ通知を送信する必要があります。

class ChatFactory(Factory): 

    def __init__(self): 
     self.users = {} # maps user names to Chat instances 

     def broadcast_msg(): 
      for name in self.users: 
       self.users[name].sendLine("looping call send to users: {}".format(self.users.keys())) 

     self.looping_call = task.LoopingCall(broadcast_msg) 
     self.looping_call.start(60) 

これは少なくとも私にとってはうまくいくはずです。