python - python扭曲中的多组聊天服务器

Question

关闭。这个问题需要多问 focused 。目前不接受答案。

---

想要改进此问题吗？更新问题，使其仅关注一个问题 editing this post .

已关闭 9 年前。

Improve this question

我正在使用twisted框架运行一个聊天服务器，它非常适合一个组，但我需要多个组，以便用户可以加入特定组，并且他可以向该特定组发送/接收消息，那么如何创建多个组或工作函数“joinroom(self,roomname)”并且用户将被重定向到该组？

from twisted.internet import reactor,protocol                                           
from twisted.protocols import basic                                            
from twisted.internet.protocol import Protocol, ClientFactory                  
import time                                                                              

def t():

return "["+ time.strftime("%H:%M:%S") +"] "                                          

class EchoProtocol(basic.LineReceiver):                                                  
  name = "Unnamed"                                                                     

  def connectionMade(self):                                                            

    self.transport.write("WhiteNOISE"+"\n")                                          
    self.sendLine("Enter A name Below...")                                           
    self.sendLine("")                                                                
    self.count = 0                                                                   
    self.factory.clients.append(self)                                                
    self.factory.group.append(self)                                                  
    print t() + "+ Connection from: "+ self.transport.getPeer().host                 

  def connectionLost(self, reason):                                                    

    self.sendMsg("- %s left." % self.name)                                           
    print t() + "- Connection lost: "+ self.name                                     
    self.factory.clients.remove(self) 
  def dataReceived(self, data):                                                        
        #print "data is ", data                                                      
            a = data.split(':')                                                      
            if len(a) > 1:                                                           
                    command = a[0]                                                   
                    content = a[1]                                                   


                    msg = ""                                                         
                    if command == "iam":                                             
                            self.name = content                                      
                            msg = self.name + " has joined"                          

                    elif command == "msg":                                           
                            msg = self.name + ": " + content                         
                    elif command  == "quit":                                         
                            self.transport.loseConnection()                          
                            return                                                   
                    elif command == "/ul":                                           
                            self.chatters()                                          
                            return()                                                 

                    print msg
                    self.sendMsg(msg)

  def username(self, line):                                                            

    for x in self.factory.clients:                                         
        if x.name == line:                                                 
            self.sendLine("This username is taken; please choose another")           
            return                                                                   

    self.name = line                                                                 
    self.chatters()                                                                  
    self.sendLine("You have been connected!")                                        
    self.sendLine("")                                                                
    self.count += 1                                                                  
    self.sendMsg("+ %s joined." % self.name)                                         
    print '%s~ %s connected as: %s' % (t(), self.transport.getPeer().host, self.name)

  def chatters(self):                                                                  
    x = len(self.factory.clients) - 1                                                
    s = 'is' if x == 1 else 'are'                                                    
    p = 'person' if x == 1 else 'people'                                             
    self.sendLine("There %s %i other %s connected:" % (s, x, p) )                    

    for client in self.factory.clients:                                              
        if client is not self:                                                       
            self.sendLine(client.name)                                               
    self.sendLine("")

  def sendMsg(self, message):                                                          

    for client in self.factory.clients:                                              
        client.transport.write( message + '\n')                                      



class EchoServerFactory(protocol.ClientFactory):                                         
protocol  = EchoProtocol                                                             
clients = []                                                                         

if __name__ == "__main__":                                                               
reactor.listenTCP(5001, EchoServerFactory())                                         
print "Chat Server Started"                                                          
reactor.run()

Answer 1

这是一些伪代码，我看到您已经在工厂中创建了名为 group 的变量，所以我猜您有类似的想法，但尝试使用字典而不是列表，以便您可以更优雅地命名和访问您的组。

当然，这意味着您的“msg”命令应该指定组，以便您知道将消息发送到哪个组。

class EchoServerFactory(protocol.ClientFactory):                                         
   protocol  = EchoProtocol                                                             
   clients = []
   groups = {}    

def dataReceived(self, data):                                                        
   # Split string ,error checking ...
   if command == "join":                                             
      self.factory.groups.get(content, []).append(self)  
   # handle other commands             

def sendMsg(self, message, group):                                                          
   for client in self.factory.groups[group]:                                              
      client.transport.write( message + '\n') 

这确实是微不足道的，例如，没有回滚功能，因此新客户将看不到聊天历史记录，消息传递不可靠，因为您不使用任何类型的确认来向服务器发出信号，表明客户端确实已收到消息，或者服务器应将消息重新发送给某些客户端。

更好、更强大的解决方案可能包括:

• 使用Twisted IRC server protocol
• 使用TwistedWords即时通讯服务器/客户端(简单)
• Redis PubSub轻松地将消息从单个客户端扇出到在同一 channel 上订阅的所有其他客户端(不可靠，实现起来几乎微不足道)
• 使用 RabbitMQ将消息路由到所需的客户端或其他一些消息代理(可靠、健壮，比 Redis 或 TwistedWords 需要更多设置)

这是对 reliable and unreliable 含义的简短解释。 .

Reliable messaging is the concept of communicating messages across an unreliable infrastructure whilst being able to make certain guarantees about the successful transmission of the messages; for example, that if the message is delivered, it is delivered at most once, or that all messages successfully delivered arrive in a particular order.

免责声明:我只是提出了我过去使用过的技术和想法，可能还有数百种方法来实现[简单，强大]群聊。