[C++] Interprozesskommunikation: Windows Pipes

Abend liebe Community,

Ich habe hier ein sehr interessantes Thema f�r euch: Kommunikation zwischen zwei Prozessen auf dem selben Computer. Das hei�t, wie k�nnen zwei Programme, die auf einem System laufen, Daten untereinander austauschen? Dazu gibt es erstmal mehrere M�glichkeiten und ich habe mir da jetzt mal die Pipes rausgepickt. Die Frage, was ein Pipe ist, lasse ich mal durch Wikipedia kl�ren. Dazu bitte HIER mal nachschauen. Um f�r euch den Umgang mit den Pipes einfach zu gestalten habe ich euch mal schnell zwei Klassen programmiert. Eine PipeServer- und einer PipeClient-Klasse. Damit ist es letztendlich nicht sehr schwer das Ganze zu realisieren :)

Ladet euch die Header- und .CPP-Dateien runter und bindet sie in euer aktuelles Projekt ein.
So, nun k�nnen wir anfangen zu Programmieren. Zuerst wollen wir einen Pipe-Server programmieren:

Code:

#include <iostream>
#include <string>
#include "class_Pipe.h"

using namespace std;
using namespace pipe;


int main( int argc, char** argv )
{
    return 0;
}

Der Code d�rfte bisher eig. klar sein. Wir binden zuerst den iostream-Header f�r in- und output ein und dann den Header von unseren Pipe-Klassen. Unsere Klassen stehen zudem im Namensraum pipe, weswegen wir dem Compiler mitteilen, dass wir diesen im gesamten Projekt verwenden wollen. Dann erstellen wir mal ein Objekt der Klasse PipeServer:

Code:

#include <iostream>
#include <string>
#include "class_Pipe.h"

using namespace std;
using namespace pipe;


int main( int argc, char** argv )
{
    PipeServer pipeServer;
    return 0;
}

Einfach :) Nun teilen wir der Klasse den "Namen" unseres Servers mit, anhand dem wir ihn sp�ter identifizieren k�nnen und die Gr��e des Servers in Bytes:

Code:

#include <iostream>
#include <string>
#include "class_Pipe.h"

using namespace std;
using namespace pipe;


int main( int argc, char** argv )
{
    PipeServer pipeServer;
    pipeServer.SetPipeAttributes( "TEST", 512 );
    return 0;
}

In unserem Beispiel ist der Name also "TEST" und die max. Gr��e 512 BYTES. Nun k�nnen wir den Server erstellen und uns mit ihm Verbinden:

Code:

#include <iostream>
#include <string>
#include "class_Pipe.h"

using namespace std;
using namespace pipe;


int main( int argc, char** argv )
{
    PipeServer pipeServer;
    pipeServer.SetPipeAttributes( "TEST", 512 );
    if( ! pipeServer.CreateServer() )
    {
        cout << "Konnte Server nicht erstellen\n";
        return 1;
    }
    if( ! pipeServer.ConnectToServer() )
    {
        cout << "Konnte sich nicht mit dem Server verbinden\n";
        return 1;
    }
    return 0;
}

Der Quellcode sollte wirklich nicht all zu schwer nachzuvollziehen sein ;) ConnectToServer ist nebenbei ein BlockingCall, das hei�t der Programmablauf bleibt solange unterbrochen, bis sich ein Client noch mit dem Server verbunden hat. So nachdem sich ein Client mit dem Server verbunden hat, wird der Client an den Server ein Request senden. Diesen soll unser Server nat�rlich auch empfangen. Das geschieht mit der Funktion Recv(), die als R�ckgabewert den empfangenen string enth�lt:

Code:

#include <iostream>
#include <string>
#include "class_Pipe.h"

using namespace std;
using namespace pipe;


int main( int argc, char** argv )
{
    PipeServer pipeServer;
    pipeServer.SetPipeAttributes( "TEST", 512 );
    if( ! pipeServer.CreateServer() )
    {
        cout << "Konnte Server nicht erstellen\n";
        return 1;
    }
    if( ! pipeServer.ConnectToServer() )
    {
        cout << "Konnte sich nicht mit dem Server verbinden\n";
        return 1;
    }

    string empfangen = pipeServer.Recv();
    cout << "Empfangen: " << empfangen << "\n";
    return 0;
}

Nat�rlich wollen wir dem Clienten nun auch was zur�ckschreiben. Das geschieht mit der Funktion Send( string* ). Diese erwartet als Parameter einen Zeiger auf den String, der gesendet werden soll:

Code:

#include <iostream>
#include <string>
#include "class_Pipe.h"

using namespace std;
using namespace pipe;


int main( int argc, char** argv )
{
    PipeServer pipeServer;
    pipeServer.SetPipeAttributes( "TEST", 512 );
    if( ! pipeServer.CreateServer() )
    {
        cout << "Konnte Server nicht erstellen\n";
        return 1;
    }
    if( ! pipeServer.ConnectToServer() )
    {
        cout << "Konnte sich nicht mit dem Server verbinden\n";
        return 1;
    }

    string empfangen = pipeServer.Recv();
    cout << "Empfangen: " << empfangen << "\n";

    string sende = "Huhu";
    pipeServer.Send( &sende );

    return 0;
}

Joa damit sind wir schon fertig mit dem Server. Ich sag ja, ist relativ einfach :) Nun bereitet uns der Client auch keine gro�en Probleme mehr denk ich. Wir erstellen wieder zuerst ein Objekt der Klasse PipeClient, �bergeben dann die Daten vom Server (Name, Gr��e), verbinden ns mit dem Server, richten eine request an den Server und empfangen schlie�lich dessen Antwort:

Code:

#include <iostream>
#include <string>
#include "class_Pipe.h"

using namespace std;
using namespace pipe;


int main( int argc, char** argv )
{
    PipeClient pipeClient;
    pipeClient.SetPipeAttributes( "TEST", 512 );
    if( ! pipeClient.ConnectToServer() )
    {
        cout << "Konnte sich nicht mit dem Server verbinden\n";
        return 1;
    }
    string sende = "Hallo, Server";
    pipeClient.Send( &sende );
    string rec = pipeClient.Recv();
    cout << rec;

    return 0;
}

Wenn ihr Fragen habt, fragt, freue mich auch auf Feedback und wie immer Viel Spa� damit :D