Socket a threading – Python – Fórum – Programujte.com
 x   TIP: Přetáhni ikonu na hlavní panel pro připnutí webu

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

 

Arthurk0
Duch
4. 3. 2016   #1
-
0
-

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()
Nahlásit jako SPAM
IP: 37.221.251.–
Zjistit počet nových příspěvků

Přidej příspěvek

Toto téma je starší jak čtvrt roku – přidej svůj příspěvek jen tehdy, máš-li k tématu opravdu co říct!

Ano, opravdu chci reagovat → zobrazí formulář pro přidání příspěvku

×Vložení zdrojáku

×Vložení obrázku

Vložit URL obrázku Vybrat obrázek na disku
Vlož URL adresu obrázku:
Klikni a vyber obrázek z počítače:

×Vložení videa

Aktuálně jsou podporována videa ze serverů YouTube, Vimeo a Dailymotion.
×
 
Podporujeme Gravatara.
Zadej URL adresu Avatara (40 x 40 px) nebo emailovou adresu pro použití Gravatara.
Email nikam neukládáme, po získání Gravatara je zahozen.
-
Pravidla pro psaní příspěvků, používej diakritiku. ENTER pro nový odstavec, SHIFT + ENTER pro nový řádek.
Sledovat nové příspěvky (pouze pro přihlášené)
Sleduj vlákno a v případě přidání nového příspěvku o tom budeš vědět mezi prvními.
Reaguješ na příspěvek:

Uživatelé prohlížející si toto vlákno

Uživatelé on-line: 0 registrovaných, 3 hosté

Podobná vlákna

Threading or multiprocess — založil daniel

Jak používat Threading? — založil jojo

Socket — založil Michal Baloun

C++ socket — založil Dominik Rozporka

 

Hostujeme u Českého hostingu       ISSN 1801-1586       ⇡ Nahoru Webtea.cz logo © 20032024 Programujte.com
Zasadilo a pěstuje Webtea.cz, šéfredaktor Lukáš Churý