Δημιουργήστε ένα αντικείμενο υποδοχή και δεσμεύονται σε μια θύρα , έτσι ώστε να μπορεί να ακούει για τα εισερχόμενα μηνύματα :
soc = socket.socket ( socket.AF_INET , socket.SOCK_STREAM ) soc.bind ( ( '127 .0.0.1 ' , 5432 ) ) soc.listen ( 5 ) 2
Ορίστε την τάξη για να λαμβάνετε μηνύματα . Αυτό εξαρτάται από την " threading " βιβλιοθήκη , έτσι ώστε να μπορεί να τρέξει στο παρασκήνιο άλλες εφαρμογές :
τάξη ChatThread ( threading.Thread ) : def __ init__ ( self , γ) : threading.Thread.__init__ ( self ) self.conn = cself.stopIt = False
εικόνων 3
να ορίσετε τη μέθοδο "τρέχει" , το οποίο εκτελείται όταν ένα νήμα τύπου " ChatThread " εκτελεί :
def τρέξει ( αυτο) : αν και δεν self.stopIt : msg = self.message_recv ( ) print ' recieved - >' , msg
Η 4
Ορίστε ένα μήνυμα που λαμβάνει τάξη, η οποία λειτουργεί ως μέρος της μέθοδος "τρέχει" . Αυτό περιμένει για μηνύματα και επιστρέφει το μήνυμα τη στιγμή που υποβλήθηκαν:
def message_recv ( αυτο) : δεδομένα = self.conn.recv ( SIZE ) self.conn.send ( 'OK' ) msg = self.conn.recv ( int (δεδομένα ) ) επιστρέφει msg
5
Πάρτε μια σύνδεση υποδοχής και να δημιουργήσει ένα νήμα ChatThread :
γ1 , a1 = soc.accept ( )
thr = ChatThread ( γ1) thr.start ( ) = αποστολέα
εικόνων
Πνευματικά δικαιώματα © Γνώση Υπολογιστών Όλα τα δικαιώματα κατοχυρωμένα