Netzwerkprogrammierung: Unterschied zwischen den Versionen
(17 dazwischenliegende Versionen von 2 Benutzern werden nicht angezeigt) | |||
Zeile 1: | Zeile 1: | ||
[[Kategorie:Netzwerke(IF)]] | [[Kategorie:Netzwerke(IF)]] | ||
[[Kategorie:Informatik]] | [[Kategorie:Informatik]] | ||
<font color='red'>'''im Abi 2021 und später nicht mehr relevant für Abiturklausuren'''</font> | |||
= Allgemeines = | = Allgemeines = | ||
Netzwerkprogrammierung beschäftigt sich mit der Entwicklung von verteilten Anwendungen. | Netzwerkprogrammierung beschäftigt sich mit der Entwicklung von verteilten Anwendungen. | ||
Dabei kommuniziert zumeist ein '''Server''' mit mehreren '''Clients'''. | Dabei kommuniziert zumeist ein '''Server''' mit mehreren '''Clients'''. | ||
= Schnittstellen des Zentralabitur = | |||
* [[Datei:Server.pdf]] | |||
* [[Datei:Client.pdf]] | |||
* [[Datei:Connection.pdf]] | |||
= Best Practices für Netzwerk-Protokolle = | = Best Practices für Netzwerk-Protokolle = | ||
Zeile 103: | Zeile 106: | ||
Wichtig ist, dass die Klasse ChatServer dann die folgenden Methoden '''überschreibt''', um auf Ereignisse bei den Clients angemessen reagieren zu können: | Wichtig ist, dass die Klasse ChatServer dann die folgenden Methoden '''überschreibt''', um auf Ereignisse bei den Clients angemessen reagieren zu können: | ||
# <code>public void processMessage(String pClientIP, int pClientPort, | # <code>public void processMessage(String pClientIP, int pClientPort, String pMessage)</code> | ||
# <code>public void processNewConnection(String pClientIP, int pClientPort)</code> | # <code>public void processNewConnection(String pClientIP, int pClientPort)</code> | ||
# <code>public void processClosedConnection(String pClientIP, int pClientPort)</code> | # <code>public void processClosedConnection(String pClientIP, int pClientPort)</code> | ||
Zeile 118: | Zeile 121: | ||
=Beispiel: GossipServer= | =Beispiel: GossipServer= | ||
Die Techniken der Netzwerkprogrammierung werden hier am Beispiel des GossipServer gezeigt. | Die Techniken der Netzwerkprogrammierung werden hier am Beispiel des GossipServer gezeigt. | ||
==Spezifikation== | ==Spezifikation== | ||
Der GossipServer soll dazu dienen, Tratsch (=Gossip) zu speichern und weiter zu verbreiten | Der GossipServer soll dazu dienen, Tratsch (=Gossip) zu speichern und weiter zu verbreiten. Es gelten die folgenden Anforderungen: | ||
Gossip schreiben: | |||
* '''Gossip schreiben:''' Man kann | * '''Gossip schreiben:''' Man kann die Verbindung zum GossipServer herstellen und (anonym!) eine neue Nachricht hinterlassen. Die wird als Text mit Datum/Uhrzeit gespeichert. Es werden nur Nachrichten in SMS-Länge akzeptiert. Dafür soll auf der Client-Seite eine Klasse '''<code>GossipClient.java</code>''' entwickelt werden. | ||
* '''Gossip abonnieren:''' | * '''Gossip abonnieren:''' Mithilfe eines geeigneten Befehls kann man den Gossip abonnieren. Der GossipServer schickt dem Client dann jede neu eintreffende Nachricht. Das soll auf der Client-Seite die Klasse '''<code>GossipTicker.java</code>''' erledigen. | ||
* '''Gossip-Archiv lesen:''' Man kann alle Nachrichten | * '''Gossip-Archiv lesen:''' Man kann alle Nachrichten eines Zeitraums vom GossipServer abrufen, indem man einen geeigneten Befehl an den GossipServer schickt und dabei das Anfangs- und das Enddatum angibt. Der GossipServer schickt dann alle Nachrichten aus diesem Zeitraum mit Datum zurück. Dies erledigt auf der Client-Seite die Klasse '''<code>GossipClient.java</code>'''. | ||
* '''Abmelden:''' Mithilfe eines geeigneten Befehls kann man die Verbindung zum GossipServer trennen. | |||
* '''Gossip speichern und die Abonnentenliste verwalten:''' Der <code>GossipServer</code> speichert die Nachrichten und die Abonnenten in Listen und reagiert auf die o.g. Anforderungen des <code>GossipClient</code> und des <code>GossipTicker</code>. | |||
==Arbeitsschritte== | ==Arbeitsschritte== | ||
Zeile 174: | Zeile 177: | ||
==Implementierung== | ==Implementierung== | ||
<code> | <code> | ||
<b>public class GossipServer extends Server </b> | '''//GossipServer erbt von Server!''' | ||
{ | <b>public class GossipServer extends Server </b> | ||
private int port = 5555; | { | ||
private static int port = 5555; | |||
'''//Attribute fuer die Listen''' | '''//Attribute fuer die Listen''' | ||
private ListWithViewer abonnentenListe; | private ListWithViewer<Abonnent> abonnentenListe; | ||
private ListWithViewer nachrichtenListe; | private ListWithViewer<Nachricht> nachrichtenListe; | ||
//Konstruktor | //Konstruktor | ||
'''public GossipServer()''' | '''public GossipServer()''' | ||
{ | { | ||
'''den Konstruktor der Super-Klasse Server aufrufen''' | '''//den Konstruktor der Super-Klasse Server aufrufen''' | ||
super(port); | super(port); | ||
System.out.println("GossipServer wird gestartet"); | System.out.println("GossipServer wird gestartet"); | ||
'''//die Listen als leere Listen erzeugen''' | '''//die Listen als leere Listen erzeugen''' | ||
abonnentenListe = new ListWithViewer(); | abonnentenListe = new ListWithViewer<Abonnent>(); | ||
nachrichtenListe = new ListWithViewer(); | nachrichtenListe = new ListWithViewer<Nachricht>(); | ||
} | } | ||
Zeile 229: | Zeile 233: | ||
} | } | ||
'''public void | '''public void processClosingConnection(String pClientIP, int pClientPort)''' | ||
{ | { | ||
abonnentEntfernen(pClientIP, pClientPort); | abonnentEntfernen(pClientIP, pClientPort); | ||
Zeile 243: | Zeile 247: | ||
{ | { | ||
send(pClientIP, pClientPort, "+OK GossipArchiv"); | send(pClientIP, pClientPort, "+OK GossipArchiv"); | ||
nachrichtenListe.toFirst(); | for(nachrichtenListe.toFirst(); nachrichtenListe.hasAccess(); nachrichtenListe.next()) { | ||
Nachricht dieNachricht = nachrichtenListe.getContent(); | |||
Nachricht dieNachricht = | |||
if(dieNachricht.getZeit().compareTo(pDatumVon)>= 0 && dieNachricht.getZeit().compareTo(pDatumBis) <= 0){ | if(dieNachricht.getZeit().compareTo(pDatumVon)>= 0 && dieNachricht.getZeit().compareTo(pDatumBis) <= 0){ | ||
send(pClientIP, pClientPort, dieNachricht.getZeit()+" "+dieNachricht.getText()); | send(pClientIP, pClientPort, dieNachricht.getZeit()+" "+dieNachricht.getText()); | ||
} | } | ||
} | } | ||
this.send(pClientIP, pClientPort, "."); | this.send(pClientIP, pClientPort, "."); | ||
Zeile 262: | Zeile 264: | ||
'''private void abonnentEntfernen(String pClientIP, int pClientPort)''' | '''private void abonnentEntfernen(String pClientIP, int pClientPort)''' | ||
{ | { | ||
abonnentenListe.toFirst(); | for(abonnentenListe.toFirst(); abonnentenListe.hasAccess(); abonnentenListe.next()){ | ||
Abonnent derAbonnent = abonnentenListe.getContent(); | |||
Abonnent derAbonnent = | |||
if(pClientIP.equals(derAbonnent.getIp())&& pClientPort == derAbonnent.getPort()){ | if(pClientIP.equals(derAbonnent.getIp())&& pClientPort == derAbonnent.getPort()){ | ||
this.abonnentenListe.remove(); | this.abonnentenListe.remove(); | ||
return; | |||
} | } | ||
} | } | ||
} | } | ||
Zeile 275: | Zeile 275: | ||
'''private void nachrichtAnAbonnentenWeiterleiten(String pMessage)''' | '''private void nachrichtAnAbonnentenWeiterleiten(String pMessage)''' | ||
{ | { | ||
abonnentenListe.toFirst(); | for(abonnentenListe.toFirst(); abonnentenListe.hasAccess(); abonnentenListe.next()){ | ||
Abonnent derAbonnent = this.abonnentenListe.getContent(); | |||
Abonnent derAbonnent = | |||
this.send(derAbonnent.getIp(),derAbonnent.getPort(), "+OK NEU "+pMessage); | this.send(derAbonnent.getIp(),derAbonnent.getPort(), "+OK NEU "+pMessage); | ||
abonnentenListe.next() | abonnentenListe.next(); | ||
} | } | ||
} | } | ||
public static void main(String[] args) { | public static void main(String[] args) { | ||
new GossipServer(); | GossipServer gs = new GossipServer(); | ||
new GUI(gs); | |||
} | } | ||
} | } | ||
Zeile 295: | Zeile 295: | ||
===Entscheidung: Client.java oder Connection.java?=== | ===Entscheidung: Client.java oder Connection.java?=== | ||
* Die Klasse '''GossipClient''' benutzt für die Verbindung zum Server am besten die Klasse '''Connection.java'''. Denn hier findet die Kommunikation nur in '''request-response-Zyklen''' statt. GossipClient ''' | * Die Klasse '''GossipClient''' benutzt für die Verbindung zum Server am besten die Klasse '''Connection.java'''. Denn hier findet die Kommunikation nur in '''request-response-Zyklen''' statt. GossipClient '''hat ein Attribut''' vom Typ Connection. | ||
* Die Klasse '''GossipTicker''' benutzt für die Verbindung zum Server am besten die Klasse '''Client.java'''. Denn der GossipServer wird von sich aus aktiv und mit der Klasse Client.java kann der GossipTicker die eintreffenden Nachrichten '''nebenläufig''' verarbeiten (d.h. er kann nebenbei noch andere Dinge tun). Wenn man hier die Klasse Connection.java verwenden würde, dann wäre der GossipClient immer komplett blockiert, während er auf eine neue Nachricht vom Server wartet. GossipTicker ''' | * Die Klasse '''GossipTicker''' benutzt für die Verbindung zum Server am besten die Klasse '''Client.java'''. Denn der GossipServer wird von sich aus aktiv und mit der Klasse Client.java kann der GossipTicker die eintreffenden Nachrichten '''nebenläufig''' verarbeiten (d.h. er kann nebenbei noch andere Dinge tun). Wenn man hier die Klasse Connection.java verwenden würde, dann wäre der GossipClient immer komplett blockiert, während er auf eine neue Nachricht vom Server wartet. GossipTicker '''erbt''' von der Klasse Client. | ||
===Implementierung GossipClient=== | ===Implementierung GossipClient=== | ||
Zeile 327: | Zeile 327: | ||
String message = "ARCHIV "+vonZeit+" "+bisZeit; | String message = "ARCHIV "+vonZeit+" "+bisZeit; | ||
verbindung.send(message); | verbindung.send(message); | ||
//TODO Antwort auslesen und an ergebnis anhängen | //TODO Antwort auslesen und an ergebnis anhängen | ||
ListWithViewer ergebnis = new ListWithViewer(); | ListWithViewer ergebnis = new ListWithViewer(); | ||
String antwort = verbindung.receive(); | String antwort = verbindung.receive(); | ||
Zeile 360: | Zeile 360: | ||
private GossipTickerGUI gui; | private GossipTickerGUI gui; | ||
public GossipTicker(String | public GossipTicker(String pServerIP, int pServerPort){ | ||
super( | super(pServerIP, pServerPort); | ||
gui = new GossipTickerGUI(); | gui = new GossipTickerGUI(); | ||
} | } | ||
Zeile 381: | Zeile 381: | ||
} | } | ||
} | } | ||
</code> | |||
===Implementierung Abonnent und Nachricht=== | |||
* Die Klasse '''Abonnent''' ist eine reine Container-Klasse: Sie dient nur dazu, die Informationen zu einem Abonnenten (d.h. seine Ip und seinen Port) zu speichern. | |||
* In der Klasse '''Nachricht''' wird der Nachrichtentext, das Datum und die Uhrzeit gespeichert. Datum und Uhrzeit werden bei der Erzeugung der Nachricht vom System ausgelesen. | |||
'''Klasse Abonnent:''' | |||
<code> | |||
public class Abonnent { | |||
String ip; | |||
int port; | |||
public Abonnent(String pIp, int pPort) { | |||
super(); | |||
ip = pIp; | |||
port = pPort; | |||
} | |||
public String getIp() { | |||
return ip; | |||
} | |||
public int getPort() { | |||
return port; | |||
} | |||
// fuer die Anzeige im ListWithViewer! | |||
public String toString(){ | |||
return ip+"::"+port; | |||
} | |||
} | |||
</code> | |||
'''Klasse Nachricht''' | |||
<code> | |||
// zu den Import-Statements: vgl. Java Tricks auf sibi-wiki.de | |||
import java.text.SimpleDateFormat; | |||
import java.util.Date; | |||
public class Nachricht { | |||
private String datum; | |||
private String uhrzeit; | |||
private String text; | |||
public Nachricht(String pText){ | |||
this.text = pText; | |||
// Datum und Uhrzeit bestimmen: Vgl. Java Tricks auf sibi-wiki.de | |||
Date dasDatum = new Date(); | |||
SimpleDateFormat formatDatum = new SimpleDateFormat("yyyy-MM-dd"); | |||
String datumString = formatDatum.format(dasDatum); | |||
datum = datumString; | |||
SimpleDateFormat formatUhrzeit = new SimpleDateFormat("HH:mm"); | |||
String uhrzeitString = formatUhrzeit.format(dasDatum); | |||
uhrzeit = uhrzeitString; | |||
} | |||
public String getZeit() { | |||
return (datum+" "+uhrzeit); | |||
} | |||
public String getText() { | |||
return text; | |||
} | |||
// fuer die Anzeige in ListWithViewer! | |||
public String toString(){ | |||
return datum+" "+uhrzeit+":"+text; | |||
} | |||
} | |||
</code> | </code> |
Aktuelle Version vom 16. März 2021, 07:18 Uhr
im Abi 2021 und später nicht mehr relevant für Abiturklausuren
Allgemeines
Netzwerkprogrammierung beschäftigt sich mit der Entwicklung von verteilten Anwendungen.
Dabei kommuniziert zumeist ein Server mit mehreren Clients.
Schnittstellen des Zentralabitur
Best Practices für Netzwerk-Protokolle
siehe: Protokoll_(IF)
Client-Programmierung
Für die Client-Programmierung stehen im Zentralabitur die Schnittstellen Connection.java und Client.java zur Verfügung.
Connection.java vs. Client.java
Die Schnittstellen fürs Zentralabitur stellen zwei Klassen zur Verfügung, mit denen auf der Client-Seite gearbeitet werden kann:
- Connection.java hat die folgenden Methode, um Nachrichten vom Server zu empfangen:
public String receive()
- Client.java hat die folgenden Methode, um Nachrichten vom Server zu empfangen:
public void processMessage(String pMessage)
Die einfachere (=mit weniger Möglichkeiten) ist die Klasse Connection.java. Diese beiden Klassen werden in unterschiedlichen Szenarien benutzt:
- Connection.java wird genutzt, wenn der Server nur auf Anfragen des Clients reagiert, wie z.B. bei Mailprotokollen (SMTP oder POP3).
- Client.java wird genutzt, wenn der Server von sich aus aktiv werden kann. Das ist z.B. bei einem Chat der Fall, denn hier muss der Server Nachrichten eines anderen Client von sich aus an alle Clients weiterleiten können.
Connection: Standardvorgehen
In der Regel wird wie folgt vorgegangen:
- Verbindung herstellen:
- Man verbindet sich mit dem Server, indem man ein neues
Connection
-Objekt erzeugt. - Man empfängt die Willkommensnachricht des Servers und wertet sie ggf. aus.
- Man verbindet sich mit dem Server, indem man ein neues
- Einfache Nachrichten senden/empfangen:
- Man baut einen String
zumServer
zusammen. InzumServer
ist die Nachricht enthalten, die man zum Server schicken möchte. - Man gibt
zumServer
an die Konsole aus - zur Kontrolle! - Man schickt
zumServer
an den Server. - Man empfängt die Antwort des Servers und speichert sie in
vomServer
. - Man gibt
vomServer
an die Konsole aus - zur Kontrolle! - Jetzt kann man
vomServer
auswerten.
- Man baut einen String
- Mehrzeilige Nachrichten empfangen: Wenn eine Serverantwort mehrzeilig ist, dann wird sie in der Regel mit einem einzelnen Punkt (bzw. einer anderen Endmarke) beendet. Darauf reagiert man wie folgt:
- Man empfängt eine Zeile vom Server und speichert sie in
vomServer
. - Eine
while
-Schleife, die so lange läuft, bisvomServer
ein einzelner Punkt (bzw. die Endmarke) ist. In der Schleife passiert folgendes...- Man gibt
vomServer
an die Konsole aus - zur Kontrolle, ob die Antwort vom Server wie erwartet ist. vomServer
auswerten.- Man empfängt die nächste Zeile vom Server und speichert sie in
vomServer
.
- Man gibt
- Man empfängt eine Zeile vom Server und speichert sie in
Connection: Standardvorgehen in Java
- Verbindung herstellen:
Connection verbindung = new Connection("192.168.100.100", 4242);
//IP und Port sind nur Beispiele!String vomServer = verbindung.receive();
- Einfache Nachrichten senden/empfangen:
String zumServer = "LOGIN "+username+" "+passwort;
// das ist ein Beispiel für ein LoginSystem.out.println(zumServer);
verbindung.send(zumServer);
vomServer = verbindung.receive();
.System.out.println(vomServer);
if(vomServer.startsWith("+OK")){
//Beispiel für eine Auswertung
- Mehrzeilige Nachrichten empfangen:
vomServer = verbindung.receive();
while(vomServer.equals(".") == false){
System.out.println(vomServer);
ergebnis.append(vomServer);
// Beispiel für eine Auswertung: An eine ergebnis-Liste anhängen.vomServer = verbindung.receive();
.
Client.java: Standardvorgehen in Java
Von Client.java dagegen wird eine Unterklasse gebildet, die die Fähigkeiten von Client.java erbt. Dabei muss die Methode public void processMessage(String pMessage)
überschrieben werden, damit man auf die Nachrichten des Servers reagieren kann.
Beispiel ChatClient:
public class ChatClient extends Client{
public ChatClient(){
//Konstruktor der Klasse Client aufrufen!
//Dadurch wird die Verbindung zum (selbstprogrammierten) Chatserver hergestellt
super("192.168.100.100", 4444);
}
// Überschreiben der Methode processMessage!
public void processMessage(String pMessage){
// jetzt das Protokoll abarbeiten
if(pMessage.startsWith("neu")){
// usw.
}
// usw.
}
}
Server-Programmierung
Für die Server-Programmierung gibt es die Klasse Server.java. Genauso wie bei Client.java muss die eigene Klasse von Server.java erben, um die Fähigkeiten von Server.java zu übernehmen, z.B.:
public class ChatServer extends Server{
public ChatServer(int pPort){
// Konstruktor der Klasse Server aufrufen!
// Dadurch wird der Server erzeugt.
super(pPort);
}
Wichtig ist, dass die Klasse ChatServer dann die folgenden Methoden überschreibt, um auf Ereignisse bei den Clients angemessen reagieren zu können:
public void processMessage(String pClientIP, int pClientPort, String pMessage)
public void processNewConnection(String pClientIP, int pClientPort)
public void processClosedConnection(String pClientIP, int pClientPort)
Von sich aus kann der Server aktiv werden, indem er...
- einem Client eine Nachricht schickt:
public void send(String pClientIP, int pClientPort, String pMessage)
- allen Clients eine Nachricht schickt:
public void sendToAll(String pMessage)
- einen Client rausschmeißt:
public void closeConnection(String pClientIP, int pClientPort)
- den Server zumacht:
public void close()
Wichtige Methoden der Klasse String
siehe String
Beispiel: GossipServer
Die Techniken der Netzwerkprogrammierung werden hier am Beispiel des GossipServer gezeigt.
Spezifikation
Der GossipServer soll dazu dienen, Tratsch (=Gossip) zu speichern und weiter zu verbreiten. Es gelten die folgenden Anforderungen: Gossip schreiben:
- Gossip schreiben: Man kann die Verbindung zum GossipServer herstellen und (anonym!) eine neue Nachricht hinterlassen. Die wird als Text mit Datum/Uhrzeit gespeichert. Es werden nur Nachrichten in SMS-Länge akzeptiert. Dafür soll auf der Client-Seite eine Klasse
GossipClient.java
entwickelt werden. - Gossip abonnieren: Mithilfe eines geeigneten Befehls kann man den Gossip abonnieren. Der GossipServer schickt dem Client dann jede neu eintreffende Nachricht. Das soll auf der Client-Seite die Klasse
GossipTicker.java
erledigen. - Gossip-Archiv lesen: Man kann alle Nachrichten eines Zeitraums vom GossipServer abrufen, indem man einen geeigneten Befehl an den GossipServer schickt und dabei das Anfangs- und das Enddatum angibt. Der GossipServer schickt dann alle Nachrichten aus diesem Zeitraum mit Datum zurück. Dies erledigt auf der Client-Seite die Klasse
GossipClient.java
. - Abmelden: Mithilfe eines geeigneten Befehls kann man die Verbindung zum GossipServer trennen.
- Gossip speichern und die Abonnentenliste verwalten: Der
GossipServer
speichert die Nachrichten und die Abonnenten in Listen und reagiert auf die o.g. Anforderungen desGossipClient
und desGossipTicker
.
Arbeitsschritte
- Protokoll definieren
- GossipServer:
- Implementationsdiagramm
- Implementierung
- GossipClient und GossipTicker:
- Entscheidung für programmtechnische Grundlage: Client oder Connection?
- Implementationsdiagramme
- Implementierungen
Protokoll
Client sendet | Server antwortet (einem Client) |
Server an alle |
---|---|---|
Client meldet sich an | +OK Willkommen beim GossipServer | |
Gossip schreiben: NEU <nachricht> |
+OK Nachricht akzeptiert -ERR Nachricht zu lang |
an alle Abonennten: NEU <zeit>--<nachricht> --- |
Gossip abonnieren: ABO |
+OK Abo akzeptiert | --- |
Gossip-Archiv lesen: ARCHIV <zeit1> <zeit2> |
+OK GossipArchiv <zeit 1>--<nachricht 1> ... <zeit n>--<nachricht n> . -ERR Datum falsch |
--- |
QUIT | +OK Tschuess Trennt die Verbindung |
--- |
<unbekannter Befehl> | -ERR unbekannter Befehl | --- |
<Parameter fehlt> | -ERR Parameter fehlt | --- |
Implementationsdiagramm
- GossipServer erbt von Server.
- GossipServer muss die Methoden
processMessage
,processNewConnection
undprocessClosedConnection
überschreiben.processMessage
ist notwendig, um Nachrichten von Clients gemäß Protokoll verarbeiten zu können.processNewConnection
ist notwendig, um neue Clients begrüßen zu können.processClosedConnection
ist notwendig, um Clients aus der Abonnentenliste streichen zu können, wenn sie sich abmelden
- GossipServer muss Nachrichten und Abonnenten verwalten können; dafür braucht er jeweils eine Liste.
- Die privaten Methoden sind vorteilhaft, damit die Methode
processMessage
nicht völlig aufgebläht wird.
Implementierung
//GossipServer erbt von Server!
public class GossipServer extends Server
{
private static int port = 5555;
//Attribute fuer die Listen
private ListWithViewer<Abonnent> abonnentenListe;
private ListWithViewer<Nachricht> nachrichtenListe;
//Konstruktor
public GossipServer()
{
//den Konstruktor der Super-Klasse Server aufrufen
super(port);
System.out.println("GossipServer wird gestartet");
//die Listen als leere Listen erzeugen
abonnentenListe = new ListWithViewer<Abonnent>();
nachrichtenListe = new ListWithViewer<Nachricht>();
}
public void processNewConnection(String pClientIP, int pClientPort)
{
send(pClientIP, pClientPort, "+OK Willkommen beim Gossipserver");
//weiter ist hier nichts zu tun.
//denn Abonennten werden erst in die Liste geschrieben, wenn sie sich registriert haben.
}
public void processMessage(String pClientIP, int pClientPort, String pMessage)
{
if(pMessage.startsWith("NEU")){
String nachricht = pMessage.substring(4);
send(pClientIP, pClientPort, "+OK Nachricht akzeptiert");
nachrichtHinzufuegen(pClientIP, pClientPort, nachricht);
nachrichtAnAbonnentenWeiterleiten(nachricht);
return;
}
if(pMessage.equals("ABO")){
send(pClientIP, pClientPort, "+OK Abo akzeptiert");
abonnentHinzufuegen(pClientIP, pClientPort);
return;
}
if(pMessage.startsWith("ARCHIV")){
String[] splits = pMessage.split(" ");
String datumVon = splits[1];
String datumBis = splits[2];
sendeNachrichten(pClientIP, pClientPort, datumVon, datumBis);
return;
}
if(pMessage.equals("QUIT")){
send(pClientIP, pClientPort, "+OK Tschuess");
closeConnection(pClientIP, pClientPort);
return;
}
// kein Befehl trifft zu!
send(pClientIP, pClientPort, "-ERR unbekannter Befehl: "+pMessage);
}
public void processClosingConnection(String pClientIP, int pClientPort)
{
abonnentEntfernen(pClientIP, pClientPort);
}
private void nachrichtHinzufuegen(String pClientIP, int pClientPort, String pNachricht)
{
Nachricht neueNachricht = new Nachricht(pNachricht);
this.nachrichtenListe.append(neueNachricht);
}
private void sendeNachrichten(String pClientIP, int pClientPort, String pDatumVon, String pDatumBis)
{
send(pClientIP, pClientPort, "+OK GossipArchiv");
for(nachrichtenListe.toFirst(); nachrichtenListe.hasAccess(); nachrichtenListe.next()) {
Nachricht dieNachricht = nachrichtenListe.getContent();
if(dieNachricht.getZeit().compareTo(pDatumVon)>= 0 && dieNachricht.getZeit().compareTo(pDatumBis) <= 0){
send(pClientIP, pClientPort, dieNachricht.getZeit()+" "+dieNachricht.getText());
}
}
this.send(pClientIP, pClientPort, ".");
}
private void abonnentHinzufuegen(String pClientIP, int pClientPort)
{
Abonnent neuerAbonnent = new Abonnent(pClientIP, pClientPort);
this.abonnentenListe.append(neuerAbonnent);
}
private void abonnentEntfernen(String pClientIP, int pClientPort)
{
for(abonnentenListe.toFirst(); abonnentenListe.hasAccess(); abonnentenListe.next()){
Abonnent derAbonnent = abonnentenListe.getContent();
if(pClientIP.equals(derAbonnent.getIp())&& pClientPort == derAbonnent.getPort()){
this.abonnentenListe.remove();
return;
}
}
}
private void nachrichtAnAbonnentenWeiterleiten(String pMessage)
{
for(abonnentenListe.toFirst(); abonnentenListe.hasAccess(); abonnentenListe.next()){
Abonnent derAbonnent = this.abonnentenListe.getContent();
this.send(derAbonnent.getIp(),derAbonnent.getPort(), "+OK NEU "+pMessage);
abonnentenListe.next();
}
}
public static void main(String[] args) {
GossipServer gs = new GossipServer();
new GUI(gs);
}
}
GossipClient / GossipTicker
Auf der Client-Seite gibt es zwei Anwendungen:
- Der GossipClient kann Nachrichten an den GossipServer schicken und mit dem Befehl ARCHIV Nachrichten vom Server abrufen.
- Der GossipTicker kann Nachrichten abonnieren; er bekommt dann jede neue Nachricht geschickt.
Entscheidung: Client.java oder Connection.java?
- Die Klasse GossipClient benutzt für die Verbindung zum Server am besten die Klasse Connection.java. Denn hier findet die Kommunikation nur in request-response-Zyklen statt. GossipClient hat ein Attribut vom Typ Connection.
- Die Klasse GossipTicker benutzt für die Verbindung zum Server am besten die Klasse Client.java. Denn der GossipServer wird von sich aus aktiv und mit der Klasse Client.java kann der GossipTicker die eintreffenden Nachrichten nebenläufig verarbeiten (d.h. er kann nebenbei noch andere Dinge tun). Wenn man hier die Klasse Connection.java verwenden würde, dann wäre der GossipClient immer komplett blockiert, während er auf eine neue Nachricht vom Server wartet. GossipTicker erbt von der Klasse Client.
Implementierung GossipClient
Hier ist nur der Teil des GossipClients implementiert, der mithilfe des Befehls ARCHIV Nachrichten vom Server abruft.
import javax.swing.JOptionPane;
public class GossipClient {
private Connection verbindung;
public GossipClient(String pIp, int pPort){
// verbindung mit pIp und pPort initialisieren
verbindung = new Connection(pIp, pPort);
String willkommen = verbindung.receive();
if(willkommen.equals("+OK Willkommen beim Gossipserver")){
nachrichtenAbrufen();
}
else{
System.err.println(willkommen);
}
// verbindung schliessen
verbindung.close();
}
public void nachrichtenAbrufen(){
String vonZeit = JOptionPane.showInputDialog("Start-Zeit: ", "2013-03-21--10:00:30");
String bisZeit = JOptionPane.showInputDialog("End-Zeit: ", "2013-04-21--11:00:30");
//TODO gemaess Protokoll an den Server schicken
String message = "ARCHIV "+vonZeit+" "+bisZeit;
verbindung.send(message);
//TODO Antwort auslesen und an ergebnis anhängen
ListWithViewer ergebnis = new ListWithViewer();
String antwort = verbindung.receive();
if(antwort.equals("+OK GossipArchiv")){
antwort = verbindung.receive();
while(!antwort.equals(".")){
String[] splits = antwort.split(" ");
// die Zeit der Nachricht ist in splits[0]
// der Text der Nachricht ist in splits[1]
ergebnis.append(splits[1]);
antwort = verbindung.receive();
}
return;
}
else{
System.err.println(antwort);
return;
}
}
public static void main(String[] args) {
new GossipClient("127.0.0.1", 5555);
}
}
Implementierung GossipTicker
Hier wird vorausgesetzt, dass es eine Klasse GossipTickerGUI
gibt, die über eine Methode nachrichtAnzeigen(String pText)
verfügt.
public class GossipTicker extends Client{
private GossipTickerGUI gui;
public GossipTicker(String pServerIP, int pServerPort){
super(pServerIP, pServerPort);
gui = new GossipTickerGUI();
}
public void processMessage(String pMessage) {
if(pMessage.equals("+OK Willkommen beim Gossipserver")){
this.send("ABO");
return;
}
if(pMessage.startsWith("+OK NEU")){
String text = pMessage.substring(8);
gui.nachrichtAnzeigen(text);
return;
}
}
public static void main(String[] args) {
GossipTicker gt = new GossipTicker("127.0.0.1", 5555);
}
}
Implementierung Abonnent und Nachricht
- Die Klasse Abonnent ist eine reine Container-Klasse: Sie dient nur dazu, die Informationen zu einem Abonnenten (d.h. seine Ip und seinen Port) zu speichern.
- In der Klasse Nachricht wird der Nachrichtentext, das Datum und die Uhrzeit gespeichert. Datum und Uhrzeit werden bei der Erzeugung der Nachricht vom System ausgelesen.
Klasse Abonnent:
public class Abonnent {
String ip;
int port;
public Abonnent(String pIp, int pPort) {
super();
ip = pIp;
port = pPort;
}
public String getIp() {
return ip;
}
public int getPort() {
return port;
}
// fuer die Anzeige im ListWithViewer!
public String toString(){
return ip+"::"+port;
}
}
Klasse Nachricht
// zu den Import-Statements: vgl. Java Tricks auf sibi-wiki.de
import java.text.SimpleDateFormat;
import java.util.Date;
public class Nachricht {
private String datum;
private String uhrzeit;
private String text;
public Nachricht(String pText){
this.text = pText;
// Datum und Uhrzeit bestimmen: Vgl. Java Tricks auf sibi-wiki.de
Date dasDatum = new Date();
SimpleDateFormat formatDatum = new SimpleDateFormat("yyyy-MM-dd");
String datumString = formatDatum.format(dasDatum);
datum = datumString;
SimpleDateFormat formatUhrzeit = new SimpleDateFormat("HH:mm");
String uhrzeitString = formatUhrzeit.format(dasDatum);
uhrzeit = uhrzeitString;
}
public String getZeit() {
return (datum+" "+uhrzeit);
}
public String getText() {
return text;
}
// fuer die Anzeige in ListWithViewer!
public String toString(){
return datum+" "+uhrzeit+":"+text;
}
}