如何关闭处于socket监听状态的线程？

Shaquile

下面的程序只能等到下一个连接到来时，才能关闭线程。在怎么能当调用stop时，立刻关闭呢

1. 
   
2. class ListenThread(threading.Thread):
   
3.     def __init__(self, server):
   
4.         threading.Thread.__init__(self)
   
5.         self.server = server
   
6.         self.event = threading.Event()
   
7.         self.event.clear()
   
8.         
   
9.     def run(self):
   
10.         while (not self.event.is_set()):
    
11.             try:
    
12.                 client, addr = self.server.accept()
    
13. 
    
14.                 data = client.recv(1024)
    
15.                 client.send('I GOT: %s' % data)
    
16. 
    
17.                 client.close()
    
18.             except:
    
19.                 break
    
20. 
    
21.     def stop(self):
    
22.         self.event.set()                                            
    
23. 
    

复制代码

jeppeter

回复 1# Shaquile


    这个问题我遇到过，我的解决办法是用select，而不是直接accept，因为有一个时间设定（这个我一般设置为1 second），如果得到exception，就退出了，这个可以基本满足你的需求。
   下面给一个代码

1. def SelAccept(sock):
   
2.         try:
   
3.                 while True:
   
4.                         rlist = [sock]
   
5.                         wlist = []
   
6.                         xlist = []
   
7.                         ret = select.select(rlist,wlist,xlist,1)
   
8.                         if len(ret) > 0 and len(ret[0]) > 0:
   
9.                                 rsock ,addr= sock.accept()
   
10.                                 return rsock
    
11.         except :
    
12.                 return None
    

复制代码

Shaquile

多谢，继续研究中。。。

106033177

回复 1# Shaquile
stop里直接把连接close掉不完了

   

Shaquile

不行呀。我也这么做过，虽然close没有报错，但是socket还是在accept的阻塞状态

106033177

Shaquile 发表于 2013-05-28 09:35
不行呀。我也这么做过，虽然close没有报错，但是socket还是在accept的阻塞状态

会这样吗？

Shaquile

回复 6# 106033177

要是不这样，我也就不在这提问了

你可以试试


   

106033177

回复 7# Shaquile
我试的不会

1. 
   
2. class ListenThread(threading.Thread):
   
3.     def __init__(self, server):
   
4.         ...
   
5.         self.client = None
   
6.         
   
7.     def run(self):
   
8.         while True:
   
9.             try:               
   
10.                 self.client,  = self.server.accept()               
    
11.                 data = self.client.recv(1024)
    
12.                 ....
    
13. 
    
14.     def stop(self):
    
15.         self.server.close()
    
16.         if self.client:
    
17.             self.client.close()
    
18.               

复制代码

Shaquile

这是我得全部代码，照着你的盖了，还是不行
点击"stop tcp server"后，依然可以接受一次请求

1. #coding=utf-8
   
2. from Tkinter import *
   
3. import threading
   
4. import socket
   
5. import time
   
6. 
   
7. 
   
8. class ListenThread(threading.Thread):
   
9.     def __init__(self, listBox, server, port):
   
10.         threading.Thread.__init__(self)
    
11.         self.listBox = listBox
    
12.         self.server = server
    
13.         self.port = port
    
14.         self.client = None
    
15.         
    
16.     def run(self):
    
17.         while True:
    
18.             try:
    
19.                 self.client, addr = self.server.accept()
    
20.                 self.listBox.insert(0, now() + 'Incomming connection: %s:%d\n'%addr)
    
21.                
    
22.                 data = self.client.recv(1024)
    
23.                 self.listBox.insert(0, 'Receive data: %s\n' % data)
    
24.                
    
25.                 self.client.send('I GOT: %s' % data)
    
26.                 self.client.close()
    
27.                 self.listBox.insert(0, 'Close connection\n')
    
28.             except Exception, msg:
    
29.                 self.listBox.insert(0, 'Close connection error, code: ' + str(msg[0]))
    
30.                 break
    
31.         self.listBox.insert(0, '^^^^^^^^\n')
    
32.     def stop(self):
    
33.         self.server.close()
    
34.         if self.client:
    
35.             self.client.close()
    
36. 
    
37.         
    
38. class Control(threading.Thread):
    
39.     def __init__(self, listBox, port):
    
40.         threading.Thread.__init__(self)
    
41.         self.listBox = listBox
    
42.         self.port = port
    
43.         self.event = threading.Event()
    
44.         self.event.clear()
    
45.         
    
46.     def run(self):
    
47.         server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)   #Create Socket
    
48.         server.bind(('', self.port))                                 #绑定本机1051端口
    
49.         server.listen(5)                                             #开始监听
    
50.         self.listBox.insert(0, 'Listening on ' + str(self.port) + '\n')
    
51.         
    
52.         self.lt = ListenThread(self.listBox, server, self.port)        
    
53.         self.lt.setDaemon(True)
    
54.         self.lt.start()                                              #执行监听
    
55.         self.event.wait()                                            #进入等待
    
56. 
    
57.         try:
    
58.             self.lt.stop()
    
59.             server.close()
    
60.             self.listBox.insert(0, 'Close sever successfully\n')           
    
61.         except Exception, msg:
    
62.             self.listBox.insert(0, 'Close server error, code: ' + str(msg[0]))
    
63.      
    
64.     def stop(self):
    
65.         self.event.set()                                             #结束控制进程
    
66.         
    
67.         
    
68. class Window:
    
69.     def __init__(self, root):
    
70.         self.root = root
    
71.         root.geometry("600x400")
    
72. 
    
73.         self.labList = Label(root, text='Messages output:')
    
74.         self.labList.place(x = 10, y = 10)
    
75. 
    
76.         self.sbar = Scrollbar(root, orient = VERTICAL)
    
77.         self.listBox = Listbox(root, width = 75, height = 10, yscrollcommand = self.sbar.set, selectmode=EXTENDED)
    
78. 
    
79.         self.listBox.place(x = 10, y = 30)
    
80.         self.sbar.place(x = 462, y = 30, height = 160)
    
81.         self.sbar.configure(command = self.listBox.yview)
    
82.         
    
83.         self.butlisten = Button(root, text = 'Start TCP Server', command = self.Listen)
    
84.         self.butlisten.place(x = 500, y = 60)
    
85.         self.butclose = Button(root, text = 'Stop TCP Server', command = self.Close, state = 'disabled')
    
86.         self.butclose.place(x = 500, y = 100)
    
87.         self.butclear = Button(root, text = 'Clear messages', command = self.Clear)
    
88.         self.butclear.place(x = 500, y = 140)
    
89.         
    
90.         self.labPort = Label(root, text='Listening port:')
    
91.         self.labPort.place(x = 500, y = 10)
    
92.         self.listenPort = IntVar()
    
93.         self.listenPort.set(1288)
    
94.         self.entPort = Entry(root, width = 10, textvariable = self.listenPort)
    
95.         self.entPort.place(x = 500, y = 30)
    
96. 
    
97.         
    
98.         #self.edit = Text(root, width=60, height=20)
    
99.         #self.edit.place(y = 100)
    
100. 
     
101.     def Listen(self):
     
102.         self.ctrl = Control(self.listBox, self.listenPort.get())
     
103.         self.ctrl.setDaemon(True)
     
104.         self.ctrl.start()                                           #执行控制线程
     
105.         self.butlisten['state']='disabled'
     
106.         self.butclose['state']='normal'
     
107.         
     
108.     def Close(self):
     
109.         self.ctrl.stop()
     
110.         self.butlisten['state']='normal'
     
111.         self.butclose['state']='disabled'
     
112. 
     
113.     def Clear(self):
     
114.         self.listBox.delete(0, END)
     
115. 
     
116. def now():
     
117.     return time.strftime('%Y-%m-%d %H:%M:%S ',time.localtime(time.time()))
     
118.         
     
119. root = Tk()      
     
120. window = Window(root)
     
121. root.title('Socket server')
     
122. root.mainloop()
     

复制代码

106033177

Shaquile 发表于 2013-05-29 13:42
点击"stop tcp server"后，依然可以接受一次请求

我测试的不会这样。close之前shutdown一下试试.