C++: implementación de canalizaciones con nombre utilizando la API de Win32

windows winapi

Question

Estoy tratando de implementar canalizaciones con nombre en C ++, pero o mi lector no está leyendo nada, o mi escritor no está escribiendo nada (o ambos). Aquí está mi lector:

int main()
{
    HANDLE pipe = CreateFile(GetPipeName(), GENERIC_READ, 0, NULL, OPEN_EXISTING, FILE_FLAG_OVERLAPPED, NULL);

    char data[1024];
    DWORD numRead = 1;

    while (numRead >= 0)
    {
        ReadFile(pipe, data, 1024, &numRead, NULL);

        if (numRead > 0)
            cout << data;
    }

    return 0;
}

LPCWSTR GetPipeName()
{
    return L"////.//pipe//LogPipe";
}

Y aquí está mi escritor:

int main()
{
    HANDLE pipe = CreateFile(GetPipeName(), GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_FLAG_OVERLAPPED, NULL);

    string message = "Hi";
    WriteFile(pipe, message.c_str(), message.length() + 1, NULL, NULL); 

    return 0;
}

LPCWSTR GetPipeName()
{
    return L"////.//pipe//LogPipe";
}

¿Se ve bien? numRead en el lector siempre es 0, por alguna razón, y no lee nada más que 1024 -54 (algún personaje I raro).

Solución:

Lector (Servidor):

while (true)
{
    HANDLE pipe = CreateNamedPipe(GetPipeName(), PIPE_ACCESS_INBOUND | PIPE_ACCESS_OUTBOUND , PIPE_WAIT, 1, 1024, 1024, 120 * 1000, NULL);

    if (pipe == INVALID_HANDLE_VALUE)
    {
        cout << "Error: " << GetLastError();
    }

    char data[1024];
    DWORD numRead;

    ConnectNamedPipe(pipe, NULL);

    ReadFile(pipe, data, 1024, &numRead, NULL);

    if (numRead > 0)
        cout << data << endl;

    CloseHandle(pipe);
}

Escritor (cliente):

HANDLE pipe = CreateFile(GetPipeName(), GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, NULL);

if (pipe == INVALID_HANDLE_VALUE)
{
    cout << "Error: " << GetLastError();
}

string message = "Hi";

cout << message.length();

DWORD numWritten;
WriteFile(pipe, message.c_str(), message.length(), &numWritten, NULL); 

return 0;

El servidor bloquea hasta que obtiene un cliente conectado, lee lo que el cliente escribe y luego se configura para una nueva conexión, ad infinitum. ¡Gracias por toda la ayuda!

Answer 1

Debe usar CreateNamedPipe() para crear el extremo del servidor de un conducto con nombre. Asegúrese de especificar un tamaño de búfer distinto de cero, cero (documentado por MSDN como "uso del tamaño de búfer predeterminado del sistema") no funciona. MSDN tiene muestras decentes para un cliente y servidor multiproceso.

Answer 2

Un cliente de canalización con nombre puede abrir la canalización con nombre con CreateFile , pero el servidor de canalización con nombre necesita utilizar CreateNamedPipe para crear la canalización con nombre. Después de que se creó el conducto con nombre, el servidor utiliza ConnectNamedPipe para esperar a que se conecte un cliente. Solo después de que el cliente se haya conectado, el servidor debe hacer un bloqueo de lectura, como su llamada a ReadFile .