【socket問題】socketserver的finish方法老是報錯

wfnh

一段代碼，finish老是報錯，不知道是什么原因，很多情況我都試過了，還是沒解決。

socket不是很熟悉，各位看看
服務(wù)端：

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()
    

復(fù)制代碼

客戶端的：

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"

復(fù)制代碼

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.         打包成二進(jìn)制數(shù)據(jù),返回二進(jìn)制流
    
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

復(fù)制代碼

輸出信息如下：

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. ----------------------------------------
    

復(fù)制代碼

106033177

回復(fù) 1# wfnh
報什么錯？

   

wfnh

106033177 發(fā)表于 2012-08-30 15:11
回復(fù) 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]