关于twisted 框架中的疑问

needspeedboy

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

class Chat(LineOnlyReceiver):
    def lineReceived(self,data):
        self.factory.sendAll("%s :%s" % (self.getId(), data))

    def getId(self):
        return str(self.transport.getPeer())

    def connectionMade(self):
        print "New commectioin from",self.getId()
        self.transport.write("Welcome to the chat server , %s\n" % self.getId())
        self.factory.addClient(self)

    def connectionLost(self,reason):
        self.factory.delClient(self)

class ChatFactory(Factory):
    protocol = Chat

    def __init__(self):
        self.clients = []

    def addClient(self,newclient):
        self.clients.append(newclient)

    def delClient(self, message):
        for proto in self.clients:
            proto.transport.write(message + "\n")

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

＿＿＿＿＿＿＿＿＿＿＿＿
以上代码用为服务端运行后为什么sendAll不能正常工作，总是报错，或者哪位能帮我编个跟他配套的client

jigloo

你需要为ChatFactory实现sendAll方法

shhgs

没用过LineOnlyReceiver，但是我感觉你应该直接用Chat的sendAll。

needspeedboy

已经解决;
但是还是有很疑问，比如服务端client是什么东东?信息的最大尺度?另外最重要是dataReceived与lineReceived的区别，因为我是客户端是用flex做的，现在对dataReceived支持很好，要如何才能支持lineReceived呢?希望有高人指点

#!/usr/local/python25/bin/python
#-*- encoding:gb2312 -*-

"""
Socket example server using Twisted. chat server test

@author: U{Nick Royce<mailto:ilikedesign2003@yahoo.com.cn>}

@time:2008/6/15
"""

from twisted.internet import protocol
from twisted.protocols import basic
from twisted.python import log
from twisted.internet import reactor
import sys
import pyamf

class ConfigServer(basic.LineReceiver):
    encoding = pyamf.AMF0
   
    def __init__(self):
        self.encoder = pyamf.get_encoder(self.encoding)
        self.stream = self.encoder.stream

    def dataReceived(self, data):
        print "data : " + data
        if data == 'quit':
            self.sendLine("Good bye!")
            self.transport.loseConnection()
        else:
            self.broadcast(data)
   
    def broadcast(self, msg):
        for client in self.factory.clients:
            client.sendLine(msg);

    def connectionMade(self):
        self.factory.clients.append(self)
        print "Connect from %s.." % self.transport.getHost()
        self.sendLine("Welcome...%s" % self.transport.getHost())

    def connectionLost(self, reason):
        self.broadcast("Disconnect...")
        self.factory.clients.remove(self)
        pass

class ConfigServerFactory(protocol.ServerFactory):
    protocol = ConfigServer
    clients = []

def main():
    log.startLogging(sys.stdout)
    reactor.listenTCP(8080,ConfigServerFactory())
    reactor.run()
   
if __name__ == '__main__':      
    main()

[ 本帖最后由 needspeedboy 于 2008-6-15 11:26 编辑 ]

shhgs

twisted的结构还是比较清楚的，但是写文档的人，对普通用户的水平都高估了。这是通病，文档实际上都是写给自己看的，所以看得懂的人一看就懂，看不懂的人，看来看去看不懂。

OK，回答问题。

dataReceived和lineReceived实际上是一个东西，区别在于dataReceived假设数据是两进制的，怎样判断开始结束，要由程序员决定。lineReceived假设数据是文本，而且是以\r\n作为行结束标志的文本。所以推荐大家都用这个。

Factory和Protocol都是非常糟糕的命名。对普通用户来说，这两者跟底层的socket通讯都没有很大的关系。实际上这两者是业务逻辑的东西。Protocol相当于管理一个会话的逻辑，而Factory是控制所有会话的逻辑。至于底层的socket通讯，是protocol里的transport的东西。

twisted的设计是很twisted，至于文档和变量的命名，就已经不是twisted能形容的了。比较合适的名字，应该是perverted。

2gua

没用过。

needspeedboy

谢谢各位回贴,特别是shhgs .

多问一句,关于在twisted如果想客户端调服务端的方法,或是服务端调用客户端要如何操作呢.或是不走twisted这条路了.

[ 本帖最后由 needspeedboy 于 2008-6-16 19:56 编辑 ]

shhgs

这个，我记得twisted有分布式的对象调用的。叫Perspective Broker。说实话，这个东西我没用过，也没研究过，不是很清楚。你可以去研究一下文档。

twisted很cool，体系结构变化得也很快。这个Perspective Broker，1.3的时候就有了，但是好像2.0之后，就有点淡化了。我对这一部分很不了解，不清楚他们是不是放弃了。如果你要用这个做开发，先了解清楚开发者的态度再说。