【求助】关于Python的Twisted框架的使用

Silent_hi

小弟最近在看twisted的学习资料，对于deferred的编程一直不是很理解。希望大大指点一下，万分感谢。
1.比如下面这段代码，我连接上服务端然后请求一个任务，接收到数据后运用deferred根据head来判断做哪一个任务，但做完任务，有产生一些数据，我不知道怎么主动传到服务器，难道要在protocol里面实现吗？
2.protocol.dataReceived()接收到的数据是一次完整的self.transport.write()的数据吗？还是要等conncetionLost回调函数被调用才算整个完整的数据包？
3.是不是每个单独的事务都各自实现一个protocol和factory类，然后用Deferred的回调函数里面再调用connectionTCP来执行另外一个事务。还是整个client和server就各自实现一个protocol和factory类?
4.平常这个Deferred怎么使用或者代码中的哪个位置使用，有没有什么好的资料或者代码可以给我学习一下。谢谢了。

1. class MyClientProtocol(Protocol):
   
2. 
   
3. 
   
4.     def connectionMade(self):
   
5.         self.send_jsondata(None)
   
6. 
   
7.     def send_jsondata(self, data):
   
8.         json_data = {'head': 00006, 'client': 00001, 'cmd_id': 123}
   
9.         send_data = json.dumps(json_data)
   
10.         self.transport.write(send_data)
    
11. 
    
12. 
    
13.     def dataReceived(self, data):
    
14.         try:
    
15.             recv_data = json.loads(data)
    
16.         except:
    
17.             print 'Failed loads data'
    
18.         self.factory.process_data(recv_data)
    
19. 
    
20. 
    
21.     def connectionLost(self, reason):
    
22.         print reason
    
23. 
    
24. 
    
25. class MyClientFactory(ClientFactory):
    
26.     protocol = MyClientProtocol
    
27. 
    
28. 
    
29.     def __int__(self):
    
30.         self.d = Deferred()
    
31. 
    
32. 
    
33.     def process_data(self, recv_data=None):
    
34.         d.callback(recv_data)
    
35. 
    
36. def process_event(recv_data):
    
37.     if recv_data['head'] == 00012:
    
38.         opener = Urllib2Opener()
    
39.         username = recv_data['username']
    
40.         password = recv_data['password']
    
41.         login = Login(opener=opener, username=username, passwd=password)
    
42.         print login.login()
    
43. 
    
44. def conn_server(host, port):
    
45.     factory = MyClientFactory()
    
46.     from twisted.internet import reactor
    
47.     reactor.connectTCP(host, port, factory)
    
48.     return factory.d
    
49. 
    
50. if __name__ == '__main__':
    
51.     d = conn_server('127.0.0.1', 8007)
    
52.     d.addCallback(process_event)

复制代码

Silent_hi

晕，没有哪位朋友指点一下吗？谢谢了。

Silent_hi

哪位朋友指点一下吗？

Silent_hi

都没有人用twisted吗？