Laut Wikipedia wird eine Named Pipe als einer der üblicherweise für die Durchführung der Interprozesskommunikation (IPC) verwendeten Ansätze definiert, bei denen die Prozesse die Daten problemlos zwischen ihnen austauschen können. Eine Pipe wird als Datei behandelt und die Prozesse können in eine Named Pipe schreiben oder aus dieser lesen. Bis heute kann es sowohl auf Linux- als auch auf Windows-Betriebssystemen implementiert werden. In diesem Beispiel werden ein Python-Server und ein Python-Client erstellt, um zu demonstrieren, wie eine Named-Pipe-Kommunikation zwischen ihnen unter Windows mithilfe der Python-basierten Win32-API durchgeführt wird.

Python Named Pipe Server

Die APIs, die zum Erstellen von Python Named Pipe Server verwendet werden, umfassen:

• win32pipe.CreateNamedPipe: Um die Named Pipe für IPC zu verwenden, müssen wir zunächst eine Named Pipe initialisieren, indem wir ihr einen bestimmten Namen zuweisen. Es wird eine Instanz einer Named Pipe erstellt und ein Handle für nachfolgende Pipe-Operationen zurückgegeben. Die Zeichenfolge muss dem Format "\. \ Pipe <i> pipename" entsprechen, wobei der Pipename in diesem Beispiel auf "ABC" gesetzt ist. Andere Parameter wie openMode, pipeMode, nMaxInstances, nOutBufferSize, nInBufferSize, nDefaultTimeOut und lpSecurityAttributes können auf Standard oder entsprechend Ihren Anforderungen festgelegt werden. Der openMode ist auf "ePIPE_ACCESS_DUPLEX" festgelegt. Dies gibt an, dass sowohl Server- als auch Client-Prozesse aus der Named Pipe lesen und in diese schreiben dürfen. Der PipeMode ist auf "PIPE_TYPE_MESSAGE" festgelegt, was bedeutet, dass die Daten als Nachrichtenstrom oder "PIPE_READMODE_MESSAGE" in die benannte Pipe geschrieben werden, damit die Daten als Nachrichtenstrom aus der benannten Pipe gelesen werden können oder "PIPE_WAIT" aktiviert wird der Sperrmodus.

pipe = win32pipe.CreateNamedPipe(r'\\.\pipe\ABC', win32pipe.PIPE_ACCESS_DUPLEX, win32pipe.PIPE_TYPE_MESSAGE | win32pipe.PIPE_READMODE_MESSAGE | win32pipe.PIPE_WAIT, 1, 65536, 65536, 0, None)

win32pipe.ConnectNamedPipe(pipe, None)

err, bytes_written=win32file.WriteFile(pipe, some_data)

win32file.FlushFileBuffers(pipe)

win32pipe.DisconnectNamedPipe(pipe)

win32file.CloseHandle(pipe)

• win32file.CreateFile: Nachdem der Server die Named Pipe initialisiert hat, muss der Client über diese Named Pipe mit dieser Funktion oder einer anderen Benennung als "CallNamedPipe" eine Verbindung zum Server herstellen. Wenn eine Pipe-Instanz verfügbar ist, wird ein Handle an den Client zurückgegeben. Der dwDesiredAccess ist entweder "GENERIC_READ" oder "GENERIC_WRITE", wodurch der Client aus der Named Pipe lesen oder in diese schreiben kann. Der Parameter von dwCreationDisposition ist auf "OPEN_EXISTING" gesetzt. Dies zeigt an, dass die Named Pipe beim Beenden geöffnet wird. Der Parameter von dwFlagsAndAttributes ist auf "FILE_ATTRIBUTE_NORMAL" festgelegt, da für die Named Pipe keine anderen Attribute festgelegt sind.

handle = win32file.CreateFile(r'\\.\pipe\ABC',win32file.GENERIC_READ | win32file.GENERIC_WRITE, 0, None, win32file.OPEN_EXISTING, win32file.FILE_ATTRIBUTE_NORMAL, None)

res = win32pipe.SetNamedPipeHandleState(handle, win32pipe.PIPE_READMODE_MESSAGE, None, None)

resp = win32file.ReadFile(handle, 65536)

Verweise

1. Interprozesskommunikation: https://en.wikipedia.org/wiki/Inter-process_communication
2. Named Pipes für Python und Windows: https://stackoverflow.com/questions/48542644/python-and-windows-named-pipes
3. Named Pipe Operations: https://docs.microsoft.com/en-us/windows/win32/ipc/named-pipe-operations
4. Hilfe zu Python für Win32-Erweiterungen http://timgolden.me.uk/pywin32-docs/contents.html