Secondo Wikipedia, una named pipe è definita come uno degli approcci comunemente utilizzati per eseguire la comunicazione tra processi (IPC), in cui i processi possono condividere facilmente i dati tra di loro. Una pipe viene considerata come un file e ai processi è consentito scrivere o leggere da una named pipe. Ad oggi può essere implementato sia su sistemi operativi Linux che Windows. In questo esempio, verranno creati un server Python e un client Python per dimostrare come eseguire una comunicazione con pipe denominata tra di loro su Window utilizzando l'API Win32 basata su Python.

Python Named Pipe Server

Le API che verranno utilizzate per creare Python Named Pipe Server includono:

• win32pipe.CreateNamedPipe: Per utilizzare la named pipe per IPC, in primo luogo, dobbiamo inizializzare una named pipe assegnandogli un nome specifico. Creerà un'istanza di una pipe denominata e restituirà un handle per le successive operazioni sulle pipe. La stringa deve seguire il formato "\. \ Pipe <i> pipename" dove il pipename è impostato su "ABC" in questo esempio. Altri parametri come openMode, pipeMode, nMaxInstances, nOutBufferSize, nInBufferSize, nDefaultTimeOut e lpSecurityAttributes possono essere impostati come predefiniti o in base alle proprie esigenze. OpenMode è impostato su "ePIPE_ACCESS_DUPLEX" indica che sia i processi server che client possono leggere e scrivere sulla named pipe. PipeMode è impostato su "PIPE_TYPE_MESSAGE", il che significa che i dati verranno scritti nella named pipe come flusso di messaggi o "PIPE_READMODE_MESSAGE", consentendo la lettura dei dati dalla named pipe come flusso di messaggi oppure "PIPE_WAIT" all'accensione la modalità di blocco.

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: dopo che il server ha inizializzato la named pipe, al client verrà richiesto di connettersi al server tramite la named pipe utilizzando questa funzione o un'altra denominazione come "CallNamedPipe". Se è disponibile un'istanza di pipe, un handle verrà restituito al client. DwDesiredAccess è impostato su "GENERIC_READ" o "GENERIC_WRITE", che consente al client di leggere o scrivere sulla named pipe. Il parametro di dwCreationDisposition è impostato su "OPEN_EXISTING" indica che la named pipe verrà aperta se esce. Il parametro di dwFlagsAndAttributes è impostato su "FILE_ATTRIBUTE_NORMAL" perché la named pipe non ha altri attributi impostati.

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)

Riferimenti

1. Comunicazione tra processi: https://en.wikipedia.org/wiki/Inter-process_communication
2. Python e Windows Named Pipe: https://stackoverflow.com/questions/48542644/python-and-windows-named-pipes
3. Operazioni con tubi denominati: https://docs.microsoft.com/en-us/windows/win32/ipc/named-pipe-operations
4. Guida alle estensioni di Python per Win32 http://timgolden.me.uk/pywin32-docs/contents.html