[nove]

Also ... um auch Anfängern einen Einblick zu verschaffen um was es hier geht, werde ich hier versuchen in einfachen Worten das WAS, WO und WIE zu erklären.

Bitte nicht hier reinposten. Falls Ihr Kommentare hierzu abgeben möchtet bitte eine PrivatMessage(PM) senden.

Ok dann lass mal anfangen....

[nove]

Einführung verteilte Systeme

Der Unterschied zwischen nicht-verteilten und verteilten Systemen ist wohl grundsätzlich der, daß bei nicht-veteilten Systemen die Aufgaben auf einem Rechner gelöst werden und bei verteilten auf mehreren Systemen.

Sobald mehrere Programmkomponenten zur Lösung einer Aufgabe gebraucht werden entsteht eine höhere Kommunikationslast. Man kann verteilte Systeme sehen wie dieses Forum hier, jeder Moderator und User übernimmt spezielle Aufgaben und löst diese.

Hierbei funktioniert die Plattform(Forums-Software) als Server der die Aufgaben aufnimmt und/oder bereitstellt. Die Moderatoren fungieren hier als Kontrollinstanzen und die User als lösende Programmkomponenten.

Ein Beispiel aus der freien Wirtschaft:

Ein Logistikunternehmen das Auslagerungen für z.B. Möbelteile übernimmt. Erhält einen Auftrag zur Lieferung von Möbelfronten per E-Mail.

Hier könnte die Lösung z. B. so aussehen:
Ein Server nimmt die E-Mails an, übernimmt den Anhang der E-Mail, parst diesen nach Auftragsdaten. Dann nimmt der Server eine Plausibilitätsprüfung vor(ist dies ein Auftrag?, sind alle Daten vorhanden?). Verläuft die Plausibilitätsprüfung erfolgreich so gibt der Server diesen Auftrag zur weiterverarbeitung an eine weitere Methode weiter die nun anhand einer Datenbank überprüft ob die Artikel des Auftrages an Lager sind.

Wenn ja wird der Client des Disponenten benachrichtig, daß ausführbare Aufträge auf Freigabe warten, gibt der Disponet(Client) die Aufträge frei so wird dem Server die Auftragsfreigabe mitgeteilt, dieser druckt in der Kommissionierungs-Abteilung die Aufträge dann aus oder benachrichtigt den/die Client/s der Kommissionierungs-Abteilungung.

Wenn nein, wird der Client des Disponenten benachrichtigt, daß hier Fehlmengen vorliegen und der Auftrag nicht komplett erfüllt werden kann. Hier erfolgt dann zusätzlich eine Nachricht an das System des Auftraggebers sowie eine Terminanfrage an das System des Lieferanten.

Diese Beispiel lässt sich nun unendlich ausbauen. Hier kann man erkennen, daß hier ein verteiltes System Vorteile hat gegenüber einem nicht-verteilten System. Hauptaufgaben werden vom Server übernohmen und weitere Aufgaben an Clients deligiert.

... wird fortgesetzt .....

[nove]

Erste Schritte zur Client/Server Kommunikation

Um eine Kommunikations zwischen einem Server und seinen Clients zu ermöglichen bietet JAVA die Kommunikation über sogenannte Sockets. Ein Socket ist die Kombination von IP-Adresse und Portnummer. (Was jetzt ne IP-Adresse und ne Portnummer ist, werde ich jetzt nicht erklären)

Um Klar zu machen wie so etwas funktioniert hier mal ein kleines primitives Beispiel:

[nove]

DER CLIENT

//Import benötigter Klassen:
 
import java.io.InputStreamReader;
import java.io.BufferedReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.URL;
import java.net.URLConnection;
 
 
public class Client {
    
  public static void main (String args[]) {
    try {
     // Kontakt zum Server aufnehmen
     Socket server = new Socket ( "localhost", 6666 );     
            
     System.out.println ("Verbindung zum Server aufgenommen...");
            
     // öffnen der Streams:
     PrintWriter out = 
         new PrintWriter ( server.getOutputStream() );
     BufferedReader in = new BufferedReader (
        new InputStreamReader ( 
            server.getInputStream()
        )
     );        
     
     // Befehl 1 an Server
     String command_1 = "Hi Server";
     System.out.println ("sende: " + befehl_1);   
     out.println ( befehl_1 );
     out.flush();
     //Bearbeiten der Antwort 1
     String answer_1 = in.readLine();
     System.out.println ( "Server antwort: " + antwort_1 );
     // Befehl 2 an Server
     String command_2 = "Wieviel Uhr?";
     System.out.println ("sende: " + befehl_2);
     out.println ( befehl_2 );
     out.flush();
     //Bearbeiten der Antwort 2
     String answer_2 = in.readLine();
     System.out.println ( "Server sagt: " + antwort_2 );
    } catch (Exception e) {
 
        System.out.println ( "Error: " + e );
    }
  }
}

[nove]

Der Server

import java.io.PrintWriter;
import java.io.IOException;
import java.net.Socket;
import java.net.ServerSocket;
import java.util.Date;
import java.text.SimpleDateFormat;
import java.io.BufferedReader;
import java.io.InputStreamReader;
 
public class Server {
   
    //Server erzeugen
   
    public Server(int portNummer) throws IOException {
        // Port belegen
        ServerSocket servers = new ServerSocket ( portNummer );
        System.out.println ("Server auf Port " + portNummer + " gestartet!");
       
        while (true) {
            // Auf client requests warten:        
            Socket client_request = servers.accept();
       
            // client request bearbeiten:
            requesthandling (client_request);
        }
    }
 
 
   //crequest bearbeiten
    private void requesthandling ( Socket crequest ) throws IOException {
        // Streams initialisieren:
        BufferedReader in = new BufferedReader (
            new InputStreamReader (crequest.getInputStream()
            )
        );
        PrintWriter out = new PrintWriter ( 
            crequest.getOutputStream() 
        );
        
                
        // handling
        String hallo = in.readLine();
        System.out.println ("Client Anfrage: " + hallo);
        String answer_1 = "Hallo Client!";
        System.out.println ("sende: " + answer_1);
        
        out.println ( answer_1 );
        out.flush();
        
        String frage = in.readLine();
        System.out.println ("Client Anfrage: " + frage);
        String answer_2 = act_time();
        System.out.println ("sende: " + answer_2);
        
        out.println ( answer_2 );
        out.flush();
        
        // schließen der Kommunikation:
        in.close();
        out.close();
        crequest.close();
    }
 
 
public static void main (String args[]) {
        // Start des Servers
        try {
            new Server ( 6666 );
        } catch (IOException e) {
            
            System.out.println ("I/O Error: " + e);
        }            
    }
    private String current_time () {
        Date currenttime = new Date();
        SimpleDateFormat dateformat= new SimpleDateFormat ("HH:mm  dd.MM.yyyy");
 
        // verzögerung der Antwort um 5 Sekunden (Effekthascherei ;-) )
        try {
            Thread.sleep( 5000 );
        } catch (InterruptedException e) {}
        
        return dateformat.format(currenttime);
    }
   
}