Wie kann ich Interprozesskommunikation einfach in Python implementieren?

Interprozesskommunikation in Python

Bei der Arbeit mit mehreren Python-Laufzeiten ist es notwendig, eine effektive Interprozesskommunikation einzurichten. Es gibt verschiedene Methoden, darunter:

• Named Pipes (os.mkfifo): Obwohl es sich um eine einfache Option handelt, kann sie sich unausgeklügelt und fehleranfällig anfühlen.
• DBus-Dienste:Geeignet für Desktop-Umgebungen, aber zu komplex für Headless-Systeme.
• Sockets:Low-Level und manuell aufwendig.

Eine umfassende Lösung

Um Ihren spezifischen Anforderungen gerecht zu werden, sollten Sie die Multiprocessing-Bibliothek in Betracht ziehen. Es bietet Listener und Clients, die die Socket-Kommunikation nahtlos abwickeln und die Übertragung beliebiger Python-Objekte ermöglichen.

Serverimplementierung

Der Server kann so konfiguriert werden, dass er auf eingehende Nachrichten wartet:

<code class="python">from multiprocessing.connection import Listener

address = ('localhost', 6000)
listener = Listener(address, authkey=b'secret password')
conn = listener.accept()
print('connection accepted from', listener.last_accepted)
while True:
    msg = conn.recv()
    # Process the received message here
    if msg == 'close':
        conn.close()
        break
listener.close()</code>

Client-Implementierung

Der Client kann die Kommunikation initiieren und Befehle als Python-Objekte senden:

<code class="python">from multiprocessing.connection import Client

address = ('localhost', 6000)
conn = Client(address, authkey=b'secret password')
conn.send('close')
# Send arbitrary objects:
# conn.send(['a', 2.5, None, int, sum])
conn.close()</code>

Das obige ist der detaillierte Inhalt vonWie kann ich Interprozesskommunikation einfach in Python implementieren?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!