Według Wikipedii nazwany potok jest zdefiniowany jako jedno z podejść powszechnie używanych do wykonywania komunikacji międzyprocesowej (IPC), w której procesy mogą łatwo udostępniać dane między sobą. Potok jest traktowany jak plik, a procesy mogą zapisywać lub odczytywać z nazwanego potoku. Do dziś można go wdrożyć zarówno w systemach operacyjnych Linux, jak i Windows. W tym przykładzie zostanie utworzony Python Server i Python Client, aby zademonstrować, jak wykonać komunikację nazwanego potoku między nimi w systemie Windows przy użyciu opartego na Pythonie interfejsu API Win32.

Serwer nazwanych potoków w języku Python

Interfejsy API, które zostaną użyte do utworzenia serwera nazwanego potoku w języku Python, obejmują:

• win32pipe.CreateNamedPipe: Aby użyć nazwanego potoku dla IPC, najpierw musimy zainicjować nazwany potok, przypisując mu określoną nazwę. Utworzy instancję nazwanego potoku i zwróci uchwyt dla kolejnych operacji na potoku. Łańcuch musi mieć format „\. \ Pipe <i> pipename”, gdzie w tym przykładzie nazwa potoku jest ustawiona na „ABC”. Inne parametry, takie jak openMode, pipeMode, nMaxInstances, nOutBufferSize, nInBufferSize, nDefaultTimeOut i lpSecurityAttributes, można ustawić na domyślne lub w zależności od potrzeb. OpenMode jest ustawiony na „ePIPE_ACCESS_DUPLEX” wskazuje, że zarówno procesy serwera, jak i klienta mogą odczytywać i zapisywać w nazwanym potoku. Tryb potoku jest ustawiony na „PIPE_TYPE_MESSAGE”, co oznacza, że ​​dane zostaną zapisane w nazwanym potoku jako strumień komunikatów lub „PIPE_READMODE_MESSAGE” umożliwiający odczyt danych z nazwanego potoku jako strumień komunikatów lub włączenie „PIPE_WAIT” tryb blokowania.

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: Po zainicjowaniu przez serwer nazwanego potoku klient będzie musiał połączyć się z serwerem przez nazwany potok przy użyciu tej funkcji lub innego nazewnictwa, jak „CallNamedPipe”. Jeśli instancja potoku jest dostępna, uchwyt zostanie zwrócony klientowi. Parametr dwDesiredAccess jest ustawiony na „GENERIC_READ” lub „GENERIC_WRITE”, co pozwala klientowi na odczyt lub zapis do nazwanego potoku. Parametr dwCreationDisposition ustawiony na „OPEN_EXISTING” wskazuje, że nazwany potok zostanie otwarty w przypadku wyjścia. Parametr dwFlagsAndAttributes jest ustawiony na „FILE_ATTRIBUTE_NORMAL”, ponieważ nazwany potok nie ma ustawionych innych atrybutów.

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)

Bibliografia

1. Komunikacja między procesami: https://en.wikipedia.org/wiki/Inter-process_communication
2. Potoki nazwane w Pythonie i Windows: https://stackoverflow.com/questions/48542644/python-and-windows-named-pipes
3. Nazwane operacje potoku: https://docs.microsoft.com/en-us/windows/win32/ipc/named-pipe-operations
4. Pomoc dotycząca rozszerzeń Python for Win32 http://timgolden.me.uk/pywin32-docs/contents.html