Socket a threading – Python – Fórum – Programujte.com

Potřeboval bych poradit. Mám jednoduchý TCP server(přes socket) v něm naslouchám na určitém portu, pokud se client připojí tak pro toto přpojení se spustí vlákno ve kterém probíhá komunikace s klientem. Jde mi o to nějak hezky ošetřit situaci kdy klient ukončí spojení(nebo třeba fyzické přerušení spojení), tak aby se toto spojení doopravdy ukončilo i na serveru a ukončilo se toto komunikační vlákno, něco sem vypotil tak by mě zajímalo jestli je to správná cesta. Níže uvedu ukázku serveru. Ještě by se mi hodil tip na nějáký prográmek na monitorování která aplikace(proces) má obsazený jaký port. A tip na prográmek kde by bylo vidět kolik v aplikaci běží vláken. Nyní zdroják serveru, upozornění: jsem začátečník.

class sckServer_sber:
    def __init__(self):
        print "sckServer_sber.init"
        self._write_lock = threading.Lock()

    def shortcut(self):
        self.beh=True
        self.thread_listen=threading.Thread(target=self.thlisten)
        self.thread_listen.setDaemon(True)
        self.thread_listen.setName('sckServer_sber.listen')
        self.thread_listen.start()

    def clientHandler(self,dataSocket):

        try:
            global strstat,pol_data
            dataSocket.settimeout(30)
            delkapr=512
            data=range(512)
            pbeh=True
            rdata=bytearray((64,9,0,40,35))
            while (self.beh and pbeh):
                try:
                    try:
                         data = dataSocket.recv(delkapr)
                    except socket.timeout as err0:
                        print time.strftime('%H:%M:%S'),'Chyba0.timeout(120) : ',err0
                        strstat='Chyba0: '+str(err0)
                        pbeh=False
                        dataSocket.close()
                        thread.exit()

                    adata=bytearray(data)
                    global rpcas
                    if(len(data)==512):
                        rpcas=int(adata[4]*256+adata[5])
                        iddata=adata[0:5]
                        tepl0=float(adata[21]*256+adata[20])/100-50
                        tepl1=float(adata[23]*256+adata[22])/100-50
                        print time.strftime('%H:%M:%S')," ID:",iddata,tepl0,tepl1

                    time.sleep(0.1) # pretend we're doing something here...

                    #print 'sending:', rdata
                    #sent = dataSocket.send(rdata)
                    #print 'sent:', sent

                except Exception as err2:
                    print 'Chyba2 : ',err2
                    strstat='Chyba2: '+str(err2)
                    time.sleep(2)
                    if(err2==IndexError):
                         print 'Chyba indexu'
                    else:
                         print 'Ukonceni spojeni a konec sber vlakna'
                         dataSocket.close()
                         thread.exit()
            print "Konec Sberaciho vlakna"
            dataSocket.close()

        except Exception as err1:
            print 'Chyba1 : ',err1
            strstat='Chyba1: '+str(err1)

            pass


    def thlisten(self):
        global strstat
        port=6062
        cit=0
        serverSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        serverSocket.bind(('', port))
        serverSocket.listen(1)
        print "Naslouchani na portu :",str(port)
        while self.beh:
            cit=cit+1
            time.sleep(1)

            clientSocket, clientAddress = serverSocket.accept()
            print "Accepted connection z "+str(clientAddress)
            thread.start_new_thread(self.clientHandler, (clientSocket,))

            self._write_lock.acquire()
            global strcas
            strcas=time.strftime('%H:%M:%S')
            strstat="Accepted connection z "+str(clientAddress)

            self._write_lock.release()

        print "Konec vlakna sckServer_sber.listen"
        serverSocket.close()

    def stop(self):
        if self.beh:
            self.beh=False
            self.thread_listen.join()