[socket]Python HTTP通信，response数据是乱码

bill_chuang

我还是Python网络编程新手，在网上找了一个PythonProxy的代理代码阅读，我打印response后的数据，但是在控制台中显示全部都是乱码，这是什么问题，是字符编码不对么。求助！

1. #coding:UTF-8
   
2. import socket, thread, select
   
3. 
   
4. __version__ = '0.1.0 Draft 1'
   
5. BUFLEN = 8192
   
6. VERSION = 'Python Proxy/'+__version__
   
7. HTTPVER = 'HTTP/1.1'
   
8. 
   
9. class ConnectionHandler:
   
10.     def __init__(self, connection, address, timeout):
    
11.         self.client = connection
    
12.         self.client_buffer = ''
    
13.         self.timeout = timeout
    
14.         self.method, self.path, self.protocol = self.get_base_header()
    
15.         if self.method=='CONNECT':
    
16.             self.method_CONNECT()
    
17.         elif self.method in ('OPTIONS', 'GET', 'HEAD', 'POST', 'PUT',
    
18.                              'DELETE', 'TRACE'):
    
19.             self.method_others()
    
20.         self.client.close()
    
21.         self.target.close()
    
22. 
    
23.     def get_base_header(self):
    
24.         while 1:
    
25.             self.client_buffer += self.client.recv(BUFLEN)
    
26.             end = self.client_buffer.find('\n')
    
27.             if end!=-1:
    
28.                 break
    
29.         print '%s'%self.client_buffer[:end]#debug
    
30.         data = (self.client_buffer[:end+1]).split()
    
31.         self.client_buffer = self.client_buffer[end+1:]
    
32.         return data
    
33. 
    
34.     def method_CONNECT(self):
    
35.         self._connect_target(self.path)
    
36.         self.client.send(HTTPVER+' 200 Connection established\n'+
    
37.                          'Proxy-agent: %s\n\n'%VERSION)
    
38.         self.client_buffer = ''
    
39.         self._read_write()        
    
40. 
    
41.     def method_others(self):
    
42.         self.path = self.path[7:]
    
43.         i = self.path.find('/')
    
44.         host = self.path[:i]        
    
45.         path = self.path[i:]
    
46.         self._connect_target(host)
    
47.         self.target.send('%s %s %s\n'%(self.method, path, self.protocol)+
    
48.                          self.client_buffer)
    
49.         self.client_buffer = ''
    
50.         self._read_write()
    
51. 
    
52.     def _connect_target(self, host):
    
53.         i = host.find(':')
    
54.         if i!=-1:
    
55.             port = int(host[i+1:])
    
56.             host = host[:i]
    
57.         else:
    
58.             port = 80
    
59.         (soc_family, _, _, _, address) = socket.getaddrinfo(host, port)[0]
    
60.         self.target = socket.socket(soc_family)
    
61.         self.target.connect(address)
    
62. 
    
63.     def _read_write(self):
    
64.         time_out_max = self.timeout/3
    
65.         socs = [self.client, self.target]
    
66.         count = 0
    
67.         while 1:
    
68.             count += 1
    
69.             (recv, _, error) = select.select(socs, [], socs, 3)
    
70.             if error:
    
71.                 break
    
72.             if recv:
    
73.                 for in_ in recv:
    
74.                     data = in_.recv(BUFLEN)
    
75.                     if in_ is self.client:
    
76.                         out = self.target
    
77.                     else:
    
78.                         print '[RESPONSE]:'+data#在这里输出服务器返回的数据，但是都是乱码
    
79.                         out = self.client
    
80.                     if data:
    
81.                         out.send(data)
    
82.                         count = 0
    
83.             if count == time_out_max:
    
84.                 break
    
85. 
    
86. def start_server(host='localhost', port=8080, IPv6=False, timeout=60,
    
87.                   handler=ConnectionHandler):
    
88.     if IPv6==True:
    
89.         soc_type=socket.AF_INET6
    
90.     else:
    
91.         soc_type=socket.AF_INET
    
92.     soc = socket.socket(soc_type)
    
93.     soc.bind((host, port))
    
94.     print "Serving on %s:%d."%(host, port)#debug
    
95.     soc.listen(0)
    
96.     while 1:
    
97.         thread.start_new_thread(handler, soc.accept()+(timeout,))
    
98. 
    
99. if __name__ == '__main__':
    
100.     start_server()

复制代码

输出：
[RESPONSE]:E��������u5�@t��ҋ�d3"�T
��ˮ��d�mt��ѹ
�
�
SCE�8�(��� b�
jB/Z�˛e�ZI��J�;"�"F88{ci�sC����?STC���ܩX�����4��+.+�3�ׇ5�aiV�H?P�H�+�� /&V�w