Wie leer ein socket in python?

Muss ich leeren Sie die Daten auf einem socket (sicherstellen, dass es nichts zu erhalten).
Leider gibt es keine Funktion in der python-socket-Modul.

Habe ich umgesetzt, etwas so:

def empty_socket(sock):
    """remove the data present on the socket"""
    input = [sock]
    while 1:
        inputready, o, e = select.select(input,[],[], 0.0)
        if len(inputready)==0: break
        for s in inputready: s.recv(1)

Was denkst du? Gibt es eine bessere Weise, das zu tun?

Update: ich will nicht zu ändern Sie das socket-timeout. Was ist der Grund, warum ich lieber wählen, um gelesen zu werden.

Update: Die ursprüngliche Frage war mit dem "flush" Begriff. Es scheint, dass 'leer' ist ein besserer Begriff.

Update - 2010-02-27 :
Ich habe bemerkt einen Fehler, wenn das paar hat sich geschlossen. Die inputready ist immer gefüllt mit den sockets. Ich behoben, indem eine maximale Anzahl von loops. Gibt es eine bessere Lösung?

  • das ist nicht wirklich ein "flush" pro sagen. Werfen Sie einen Blick auf die Beispiele in der Dokumentation für das Lesen von einem socket. docs.python.org/library/socket.html#example
  • Haben Sie sich überlegt, Verdrillte für Ihr Programm stattdessen? Wenn Sie es wüssten, würden Sie nie brauchen, um zu tun etwas wie dieses. Verdreht sofort ziehen alle Daten aus der Steckdose und stellen es Ihnen immer, wenn einer ankommt, so brauchen Sie nicht, um Chaos über mit hässlichen details wie die select () - problem beschrieben durch Thomas ' Antwort unten.
  • Nein, ich habe nicht betrachten Sie Verdreht, weil ich wollte, dass die standard-python-Modul, um zu vermeiden, dass externe Abhängigkeiten. Vielen Dank für diesen Kommentar, ich werde schauen, Twisted und vielleicht überdenken, meine Wahl
InformationsquelleAutor luc | 2009-07-08
  1. 6

    Wenn Sie von "flush" bedeutet wegwerfen, ausstehende eingehende Daten, dann können Sie entweder wählen Sie() wie Sie tun, oder legen Sie die Buchse auf nicht blockierenden und lese in einer Schleife, bis Sie aus Daten.

    Beachten Sie auch, dass (aus der Linux manpage):

    Unter Linux, wählen Sie() meldet möglicherweise eine socket-file-Deskriptor als "bereit
    für das Lesen", während dennoch eine nachfolgende lese-Blöcke. Diese
    könnte zum Beispiel passieren, wenn die Daten da sind, aber auf
    Prüfung falschen Prüfsumme und wird verworfen. Es können auch andere
    Umstände, in denen ein Datei-Deskriptor ist spuriously gemeldet
    bereit. Dadurch kann es sicherer zu benutzen, O_NONBLOCK auf sockets, sollte
    nicht blockieren.

    Unechte Systemupdate-Benachrichtigung für Select-System-call

    Und wie bereits erwähnt, von anderen, "flush" bezieht sich normalerweise auf die Ausgabe.

    • Was wäre der richtige Begriff für "flushing" ein Eingang? Danke für deine Antwort
    • Persönlich würde ich es nennen, was Sie tun "Entleerung" der Steckdose. Obwohl es scheint seltsam für mich, warum würden Sie wollen, dies zu tun - jemand hat Sie, dass die Daten für einen Grund, warum Sie werfen es alles Weg, ohne ihn auszuführen? 🙂
    • cant wir einfach eine "recv" - Vorgang mit len zu Lesen als 0 nach dem wählen gibt?
    • Ich glaube Abfluss der normalen Begriff
    InformationsquelleAutor Thomas
  2. 2

    Mit select.select ist gute Praxis, wie in der Socket Programmierung HOWTO. Sie müssen der socket als nicht-blockierend, mit sock.setblocking(0).

    Nur ein Kommentar zur Nomenklatur: flush ist in der Regel verbunden mit Ausgabe Operationen.

    InformationsquelleAutor Vinay Sajip
  3. 1

    Für UDP-Pakete, ich habe die folgenden:

    1. Nach dem erstellen des socket-Optionen setzen, und die Bindung, die ich verwenden socket.settimeout(). Beachten Sie die Dokumentation für setblocking() gibt einige Informationen, die, dass der settimeout() nicht - wenn Sie möchten, dass Ihre socket-Operationen zu blockieren, sollten Sie nur verwenden settimeout() zum festlegen der timeout-Zeit. setblocking() legt einfach ein unendliches timeout auf. (Ich hatte einen bug Aufruf settimeout() gefolgt von setblocking(1).)

    2. Mein "Puffer leeren" - Funktion ist dann nur dieses ("Listener" ist meine Buchse):

      def FlushListen(self):
      while 1:
      try:
      PacketBytes = self.__Listener.recv(1024)
      except:
      break;

      Mit einem timeout von 1 Sekunde, so wird Lesen Sie alle UDP-Pakete und dann wieder 1 Sekunde nach gibt es keine Daten.

    In meinem Fall verwende ich es, nur zu reden, zwischen zwei Programmen auf demselben PC, also könnte ich einfach unten meine timeout-aber Geschwindigkeit ist nicht ein Problem, also ich bin mit diesem feinen.

    Entsprechend einige andere links gepostet, sollte diese Arbeit mit Daten-streams.

    InformationsquelleAutor darda
  4. 0

    Cant wir einfach weiter Lesen bis der Puffer leer ist?

    def clear_buffer(sock):
    try:
        while sock.recv(1024): pass
    except:
        pass
    • Weil Sie nicht wollen, zu warten timeout...
    InformationsquelleAutor Aamir Shaikh
  5. -1

    Nicht sicher, ob dies funktionieren wird, aber man könnte anfügen einer Datei-Objekt, das socket-file-Deskriptor, und rufen Sie die flush() Methode auf das Datei-Objekt:

    import os

file_obj = os.fdopen(your_socket.fileno())
file_obj.flush()

    Diese funktioniert nicht in Windows, da der Deskriptor zurückgegeben fileno() können nicht übergeben werden os.fdopen() im Windows

    • flush auf die Datei-Objekte nur leert den Ausgabe-Cache im userspace. Vergleichen Sie DATEI* in C und fflush. Raw-socket-I/O ist in der Regel nicht gepuffert ist, und wenn es ist, dann ist es nicht gepuffert ist in userspace, und ein fflush-wie wird ein Betrieb nicht funktionieren. Möchten Sie vielleicht Blick auf "push" für TCP.
    InformationsquelleAutor Steef
Schreibe einen Kommentar