Creare un oggetto socket e associarlo a una porta in modo che possa ascoltare i messaggi in arrivo :
soc = socket.socket ( socket.AF_INET , socket.SOCK_STREAM ) soc.bind ( ( '127 .0.0.1 ' , 5432 ) ) soc.listen (5 ) economici 2
Definire la classe per ricevere i messaggi . Questo si basa sulla libreria " threading " in modo che possa essere eseguito in background di altre applicazioni :
classe
ChatThread ( threading.Thread ) : def __ init__ (self , c ) : threading.Thread.__init__ (auto ) self.conn = cself.stopIt = False
3
Definire il metodo "run" , che viene eseguito quando un thread del tipo " ChatThread " esegue :
def run ( self): pur non self.stopIt : msg = self.message_recv ( ) print ' ricevuta - >' , msg
4
definire un messaggio di ricezione di classe , che viene eseguito come parte del "correre " metodo. Questo attende per i messaggi e restituisce il messaggio una volta ricevuti:
def message_recv ( self): data = self.conn.recv ( SIZE) self.conn.send ( 'OK' ) msg = self.conn.recv (int ( dati ) ) return msg
5
Ricevi una connessione socket e creare un filo ChatThread :
c1 , a1 = soc.accept ( ) per
thr = ChatThread ( c1 ) thr.start ( ) mittente =
Programmazione © www.354353.com