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í, tak aby se
toto spojení doopravdy ukončilo i na serveru a ukončilo se toto komunikační
vlákno. 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-50print 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:', sentexceptExceptionas 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()
exceptExceptionas err1:
print'Chyba1 : ',err1
strstat='Chyba1: '+str(err1)
passdef 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()
Děláme co je v našich silách, aby byly zdejší diskuze co nejkvalitnější. Proto do nich také mohou přispívat pouze registrovaní členové. Pro zapojení do diskuze se přihlas. Pokud ještě nemáš účet, zaregistruj se, je to zdarma.
