【socket问题】socketserver的finish方法老是报错

wfnh

一段代码，finish老是报错，不知道是什么原因，很多情况我都试过了，还是没解决。

socket不是很熟悉，各位看看
服务端：

1. #coding=gb2312
   
2. #-------------------------------------------------------------------------------
   
3. # Name:        模块1
   
4. # Purpose:
   
5. #
   
6. # Author:      Administrator
   
7. #
   
8. # Created:     02/03/2012
   
9. # Copyright:   (c) Administrator 2012
   
10. # Licence:     <your licence>
    
11. #-------------------------------------------------------------------------------
    
12. #!/usr/bin/env python
    
13. #import gevent
    
14. import SocketServer
    
15. import sys
    
16. import MsgHelper
    
17. import os
    
18. class RequestHandler(SocketServer.StreamRequestHandler):
    
19.     def handle(self):
    
20.             """Read from StreamRequestHandler's provided rfile member,
    
21.             which contains the input from the client. Mirror the text
    
22.             and write it to the wfile member, which contains the output
    
23.             to be sent to the client."""
    
24.         l = True
    
25.         while l:
    
26.             l = self.rfile.readline().strip()
    
27.             if l:
    
28.                 self.wfile.write(l[::-1] + '\n')
    
29.                 print "client say:",l + '\n'
    
30. 
    
31. 
    
32. 
    
33. class RouteService(SocketServer.StreamRequestHandler):
    
34.     allow_reuse_address = True
    
35.     client_map = {}
    
36.     msg_helper = MsgHelper.MsgHelper()
    
37.     def handle(self):
    
38.         ip_address = self.client_address[0]
    
39.         print ip_address
    
40.         print  '-' * 80
    
41.         self.client_map[ip_address] = True
    
42.         while True:
    
43.             msg = self.rfile.readline().strip()
    
44.             #print "befor:",msg
    
45.             if msg:
    
46.                 print "recv msg:",msg
    
47.                 struct = self.msg_helper.unpack(msg)
    
48.                 print 'parse msg:',type(struct),struct
    
49.                 self.wfile.write(self.msg_helper.pack({'respon':'ok'}) + '\r\n')
    
50.                 #self.request.send(self.msg_helper.pack({'respon':'ok'}) + '\r\n')
    
51.                 #self.wfile.flush()
    
52.                 print '*' * 50
    
53. 
    
54.     def finish(self):
    
55.         print "@call finish"
    
56.         if not self.wfile.closed:
    
57.             print "@call finish 0"
    
58.             self.wfile.flush()
    
59.         self.wfile.close()
    
60.         print "@call finish 1"
    
61.         self.rfile.close()
    
62.         print "@call finish 2"
    
63.         ip_address = self.client_address[0]
    
64.         print "client down:",ip_address
    
65.         self.client_map.pop(ip_address)
    
66.         self.request.close()
    
67. 
    
68. 
    
69. 
    
70. if __name__ == '__main__':
    
71.     hostname = '127.0.0.1'
    
72.     port = 1399
    
73.     print "pid:",os.getpid()
    
74.     server = SocketServer.ThreadingTCPServer((hostname, port), RouteService)
    
75.     server.serve_forever()
    

复制代码

客户端的：

1. #coding=gb2312
   
2. #-------------------------------------------------------------------------------
   
3. # Name:        模块1
   
4. # Purpose:
   
5. #
   
6. # Author:      Administrator
   
7. #
   
8. # Created:     02/03/2012
   
9. # Copyright:   (c) Administrator 2012
   
10. # Licence:     <your licence>
    
11. #-------------------------------------------------------------------------------
    
12. #!/usr/bin/env python
    
13. import socket
    
14. import MsgHelper
    
15. import os
    
16. class MirrorClient:
    
17.     def __init__(self, server, port):
    
18.         #self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
19.         #self.wbufsize = 0
    
20.         #self.rbufsize = -1
    
21.         #self.wfile = self.socket.makefile('wb', self.wbufsize)
    
22.         #self.rfile = self.socket.makefile('rb', self.rbufsize)
    
23.         #self.socket.connect((server, port))
    
24.         self.helper = MsgHelper.MsgHelper()
    
25.         self.mail_box = MsgHelper.MailBox(server,port)
    
26. 
    
27.     def mirror(self, s):
    
28.         msg = {}
    
29.         msg['do_check'] = s
    
30.         ser = self.helper.pack(msg)
    
31.         print "ser:",ser
    
32.         self.mail_box.send(ser)
    
33.       
    
34. 
    
35.     def rece_msg(self):
    
36.         msg = self.mail_box.recv()
    
37.         print self.helper.unpack(msg)
    
38. 
    
39. 
    
40.     def close(self):
    
41.         self.mail_box.finish()
    
42. 
    
43. if __name__ == '__main__':
    
44.         hostname = '127.0.0.1'
    
45.         port = 1399
    
46.         print 'client pid:',os.getpid()
    
47.         toMirror = 'weigun is good man'
    
48.         m = MirrorClient(hostname, port)
    
49.         for i in xrange(5):
    
50.            print m.mirror(toMirror)
    
51.         m.rece_msg()
    
52.         m.close()
    
53.         print "done"

复制代码

MsgHelper模块：

1. #coding=gb2312
   
2. #-------------------------------------------------------------------------------
   
3. # Name:        模块1
   
4. # Purpose:
   
5. #
   
6. # Author:      Administrator
   
7. #
   
8. # Created:     02/03/2012
   
9. # Copyright:   (c) Administrator 2012
   
10. # Licence:     <your licence>
    
11. #-------------------------------------------------------------------------------
    
12. #!/usr/bin/env python
    
13. import msgpack
    
14. import socket
    
15. class MsgHelper():
    
16.     def __init__(self):
    
17.         self.packer = msgpack.Packer()
    
18.         self.unpacker = msgpack.Unpacker()
    
19. 
    
20.     def pack(self,struct):
    
21.         '''
    
22.         打包成二进制数据,返回二进制流
    
23.         '''
    
24.         return msgpack.packb(struct)
    
25.         #return self.pack(struct)
    
26. 
    
27.     def unpack(self,bin_stream):
    
28.         return msgpack.unpackb(bin_stream)
    
29.         #self.unpacker.feed(bin_stream)
    
30.         #return self.unpacker.unpack()
    
31. 
    
32. class MailBox():
    
33.     def __init__(self,address,port,debug = False):
    
34.         self.address = address or '127.0.0.1'
    
35.         self.port = port or 1399
    
36.         self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
37.         self.wbufsize = 0
    
38.         self.rbufsize = -1
    
39.         self.debug = debug
    
40.         self.wfile = self.socket.makefile('wb', self.wbufsize)
    
41.         self.rfile = self.socket.makefile('rb', self.rbufsize)
    
42.         #--self.helper = MsgHelper()
    
43.         self.socket.connect((address, port))
    
44. 
    
45.     def __set_wbufsize(self,size):
    
46.         self.wbufsize = size
    
47. 
    
48.     def __set_rbufsize(self,size):
    
49.         self.rbufsize = size
    
50. 
    
51.     def send(self,msg):
    
52.         if self.debug:
    
53.             print msg
    
54.         try:
    
55.             self.wfile.write(msg)
    
56.             self.wfile.write('\r\n')
    
57.         except:
    
58.             self.finish()
    
59.             raise
    
60. 
    
61.     def recv(self):
    
62.         try:
    
63.             recv_msg = self.rfile.readline().strip()
    
64.             #--struct = self.helper.unpack(recv_msg)
    
65.             if self.debug:
    
66.                 print "recv msg:",recv_msg
    
67.                 #--print "parse recv_msg:",type(struct),struct
    
68.             return recv_msg
    
69.         except:
    
70.             self.finish()
    
71.             raise
    
72. 
    
73. 
    
74.     def finish(self):
    
75.         if not self.wfile.closed:
    
76.             self.wfile.flush()
    
77.         self.wfile.close()
    
78.         self.rfile.close()
    
79.         self.socket.close()
    
80. 
    
81. 
    
82. if __name__ == '__main__':
    
83.     pass

复制代码

输出信息如下：

1. pid: 8960
   
2. 127.0.0.1
   
3. --------------------------------------------------------------------------------
   
4. 
   
5. recv msg: 仺do_check瞱eigun is good man
   
6. parse msg: <type 'dict'> {'do_check': 'weigun is good man'}
   
7. **************************************************
   
8. recv msg: 仺do_check瞱eigun is good man
   
9. parse msg: <type 'dict'> {'do_check': 'weigun is good man'}
   
10. **************************************************
    
11. recv msg: 仺do_check瞱eigun is good man
    
12. parse msg: <type 'dict'> {'do_check': 'weigun is good man'}
    
13. **************************************************
    
14. recv msg: 仺do_check瞱eigun is good man
    
15. parse msg: <type 'dict'> {'do_check': 'weigun is good man'}
    
16. @call finish
    
17. @call finish 0
    
18. @call finish 1
    
19. @call finish 2
    
20. client down: 127.0.0.1
    
21. ----------------------------------------
    
22. Exception happened during processing of request from ('127.0.0.1', 64388)
    
23. Traceback (most recent call last):
    
24.   File "C:\Python27\lib\SocketServer.py", line 582, in process_request_thread
    
25.     self.finish_request(request, client_address)
    
26.   File "C:\Python27\lib\SocketServer.py", line 323, in finish_request
    
27.     self.RequestHandlerClass(request, client_address, self)
    
28.   File "C:\Python27\lib\SocketServer.py", line 639, in __init__
    
29.     self.handle()
    
30.   File "D:\test-area\getItem\gwsj\google svn\monitorService\routeService.py", li
    
31. ne 50, in handle
    
32.     self.request.send(self.msg_helper.pack({'respon':'ok'}) + '\r\n')
    
33. error: [Errno 10053]
    
34. ----------------------------------------
    

复制代码

106033177

回复 1# wfnh
报什么错？

   

wfnh

106033177 发表于 2012-08-30 15:11
回复 1# wfnh
报什么错？

报错是：
Exception happened during processing of request from ('127.0.0.1', 6438
Traceback (most recent call last):
  File "C:\Python27\lib\SocketServer.py", line 582, in process_request_thread
    self.finish_request(request, client_address)
  File "C:\Python27\lib\SocketServer.py", line 323, in finish_request
    self.RequestHandlerClass(request, client_address, self)
  File "C:\Python27\lib\SocketServer.py", line 639, in __init__
    self.handle()
  File "D:\test-area\getItem\gwsj\google svn\monitorService\routeService.py", li
ne 50, in handle
    self.request.send(self.msg_helper.pack({'respon':'ok'}) + '\r\n')
error: [Errno 10053]