python asyncore一个例子遇到的问题

小_蜜_蜂

最近小弟在学习python socket,看到asyncore的时候，自己试着去理解了一个例子， 有些不懂的地方， 还请有大牛哥能给解释一下， 感谢！

1. import argparse
   
2. 
   
3. 解析命令参数的
   
4. 
   
5. 
   
6. import asyncore
   
7. 
   
8. 异步核心,封装socket用的
   
9. 
   
10. import socket
    
11. 
    
12. socket基础支持模块
    
13. 
    
14. 
    
15. LOCAL_SERVER_HOST = 'localhost'
    
16. 
    
17. 定义一个本地LOCAL变量
    
18. 
    
19. REMOTE_SERVER_HOST = 'www-test-com'
    
20. 
    
21. 定义一个远程SERVR变量
    
22. 
    
23. BUFSIZE = 4096
    
24. 
    
25. 定义一个允许最大字节大小
    
26. 
    
27. class PortForwarder(asyncore.dispatcher):
    
28. 
    
29. 定义一个继承asyncore.dispatcher的端口转发类,dispatcher是基础类,目的是方便任意组合通道
    
30. 
    
31.     def __init__(self,ip,port,remoteip,remoteport,backlog=5):
    
32. 
    
33. 
    
34. 在端口转发类中定义一个构造函数，该构造函数给了五个参数，依次为ip(本地客户端ip),port(本地客户端port),remoteip(远程服务端ip),remoteport(服务端端口)
    
35. 
    
36.         asyncore.dispatcher.__init__(self):
    
37. 
    
38. 使用asyncore.dispatcher重写该构造函数
    
39. 
    
40.             self.remoteip = remoteip
    
41. 
    
42. 把对象方法remoteip重定义为remoteip
    
43. 
    
44.             self.remoteport = remoteport
    
45. 
    
46. 把对象方法remoteport重定义为remoteport
    
47. 
    
48.             self.create_socket(socket.INET,socket.SOCK_STREAM)
    
49. 
    
50. 创建一个IPV4,TCP的套接字对象
    
51. 
    
52.             self.set_reuse_addr()
    
53. 
    
54. 定义一个set_reuse_addr方法，这么做的目的是为了保留当前port number一段时间， 除非使用该方法才能重新使用一个端口
    
55. 
    
56.             self.bind((ip,port))
    
57. 
    
58. 使用bind方法,绑定local ip, port, 因为它是一个元组，所以使用()括起来
    
59. 
    
60.             self.listen(backlog)
    
61. 
    
62. 使用listen方法监听传入的new socket
    
63. 
    
64.     def handle_accept(asyncore.dispatcher):
    
65. 
    
66. 如果监听到了传入连接，就会触发accpet,这个时候得到的是一个handle_accept,到这里，依然是继承asyncore.dispatcher
    
67. 
    
68.         conn,addr = self.accept()
    
69. 
    
70. conn是得到的一个新的套接字对象，addr是新套接字对象的ip,port, 然后使用对象.accpet()进行队列处理
    
71. 
    
72.         print('Connect',addr)
    
73. 
    
74. 打印出一条欢迎信息
    
75. 
    
76.         Sender(Receiver(conn),remoteip,remoteport)
    
77. 
    
78. 
    
79. 使用sender类发送receiver处理后的新套接字对象，就是把客户端ip，port 转发到远程。
    
80.         
    
81. class Receiver(asyncore.dispatcher):
    
82. 
    
83. 这个是处理接收新套接字的类
    
84. 
    
85.     def __init__(self,conn):
    
86. 
    
87. 依然是一个构造函数，因为这个只是处理新套接字的，所以就一个conn
    
88. 
    
89.         asyncore.dispatcher.__init__(self,conn)
    
90. 
    
91. 使用asyncore.dispatcher重写构造函数
    
92. 
    
93. 
    
94. /////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
    
95. 
    
96.         self.from_remote_buffer = ''
    
97. 
    
98. 预定义一个发送时的buffer大小？其实这里我不确定
    
99. 
    
100.         self.to_remote_buffer = ''
     
101. 
     
102. 预定义一个接收到的buffer大小，这里也不确定。。
     
103. 
     
104. 
     
105. from和to这里，from应该是local ip port的buffer吧，to是remote接收到的？
     
106. 希望有大牛能给解释一下，感谢。。。有点晕。
     
107. 
     
108. 
     
109. 
     
110. 
     
111.         self.sender = None
     
112. 
     
113. 这里为什么写一个这个，还留了一个空?
     
114. 
     
115.     def handle_connect(self):
     
116.         pass
     
117. 
     
118. 这里我知道，如果开始建立连接了，得到的是一个connect句柄，因为这个时候是不会有传递的，所以pass掉
     
119. 
     
120.     def handle_read(self):
     
121. 
     
122. 真正建立链接后开始读取
     
123. 
     
124.         read = self.read(BUFSIZE)
     
125.         self.from_remote_buffer += read
     
126.     def writeable(self):
     
127.         return (len(self.to_remote_buffer)>0)
     
128.     def handle_write(self):
     
129.         sent = self.send(self.to_remote_buffer)
     
130.         self.to_remote_buffer = self.to_remote_buffer[sent:]
     
131.         def handle_close(self):
     
132.             self.close()
     
133.             if self.sender:
     
134.                 self.sender.close()
     
135. 
     
136. 
     
137. class Sender(asyncore.dispatcher):
     
138.     def __init__(self,receiver,remoteaddr,remoteport):
     
139.         asyncore.dispatcher.__init__(self)
     
140.         self.receiver = receiver
     
141.         self.sender = slef
     
142.         self.create_socket(socket.AF_INET,socket.SOCK_STREAM)
     
143.         self.connect((remoteaddr,remoteport))
     
144.     def handle_connect(self):
     
145.         pass
     
146.     def handle_read(self):
     
147.         read = self.recv(BUFSIZE)
     
148.         self.receiver.to_remote_buffer + = read
     
149.     def writable(self):
     
150.         return (len(self.receiver.from_remote_buffer)>0)
     
151.     def handle_write(self):
     
152.         sent = self.send(self.receiver.from_remote_buffer)
     
153.         self.receiver.from_remote_buffer = self.receiver.from_remote_buffer[sent:]
     
154.     def handle_close(self):
     
155.         self.close()
     
156.         self.receiver.close()
     
157.   
     
158. 
     
159.   //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

复制代码

/////中的信息， 再次感谢！

小_蜜_蜂

自顶～。。。

hiyachen

哪里不明白呢？