Java Anwendungen
Hello World mit Java JXTA
zum Compilieren und Ausführen werden folgende Jar-Dateien benötigt (z.B. aus
/opt/JXTA_Demo/lib):jxta.jar log4j.jar jxtasecurity.jar jxtaptls.jar minimalBC.jar beepcore.jar cryptix-asn1.jar cryptix32.jar
PeerGroupFactory.newNetPeerGroup()liefert ein Objekt, das die NetPeer Gruppe repräsentiert und initialisiert das JXTA Laufzeitsystemüber diese
PeerGrouperfolgen alle weiteren Kontakte mit der JXTA UmgebunggetPeerGroupID()zeigt die ID der (Net) Peer GroupgetPeerID()liefert die eigene ID des PeersgetPeerName()zeigt den eigenen Namennach der Initialisierung der JXTA Umgebung ist der Peer dann in der Net Peer Group sichtbar
getPeerGroupAdvertisement()liefert das Advertisement der Net Peer Gruppe, das anschliessend ausgegeben wird
import net.jxta.peergroup.PeerGroup;
import net.jxta.peergroup.PeerGroupID;
import net.jxta.peergroup.PeerGroupFactory;
import net.jxta.peer.PeerID;
import net.jxta.protocol.PeerGroupAdvertisement;
import net.jxta.exception.PeerGroupException;
import net.jxta.discovery.DiscoveryService;
import net.jxta.pipe.PipeService;
import net.jxta.membership.MembershipService;
import net.jxta.resolver.ResolverService;
import net.jxta.document.StructuredTextDocument;
import net.jxta.document.MimeMediaType;
import java.io.IOException;
public class HelloWorldJXTA {
PeerGroup gruppe = null;
Screen sc = new Screen();
public static void main(String[] args) {
HelloWorldJXTA hello = new HelloWorldJXTA();
hello.startJXTA();
}
void startJXTA() {
sc.println("starting JXTA hello world");
try {
gruppe = PeerGroupFactory.newNetPeerGroup();
} catch (PeerGroupException e) {
e.printStackTrace();
return;
}
if ( gruppe == null ) {
sc.println("Net Group not found, no way to continue");
return;
}
sc.println("Net Group is: " + gruppe);
PeerGroupID pgid = gruppe.getPeerGroupID();
sc.println("pgid: " + pgid);
PeerID pid = gruppe.getPeerID();
sc.println("pid: " + pid);
String pname = gruppe.getPeerName();
sc.println("pname: " + pname);
PeerGroupAdvertisement pgadv = gruppe.getPeerGroupAdvertisement();
sc.println("pgadv: ");
StructuredTextDocument doc = (StructuredTextDocument)
pgadv.getDocument( new MimeMediaType("text/xml") );
try {
doc.sendToWriter( sc );
} catch (IOException e) {
e.printStackTrace();
} finally {
sc.flush();
}
// core services:
DiscoveryService disco = gruppe.getDiscoveryService();
PipeService pipe = gruppe.getPipeService();
MembershipService member = gruppe.getMembershipService();
ResolverService resolv = gruppe.getResolverService();
sc.println("got core services");
}
}
Die Ausgabe des Programms zeigt der Reihe nach die Peer Group ID, die Peer ID und den Peer Namen:
starting JXTA hello world Net Group is: net.jxta.impl.peergroup.PeerGroupInterface@118958e pgid: urn:jxta:jxta-NetGroup pid: urn:jxta:uuid-59616261646162614A78746150325033499E205EAB4C4933BF588B24A8CA76C703 pname: intec peer
Die weitere Ausgabe zeigt dann das XML Dokument, das das Advertisement der Net Peer Group enthält:
pgadv:
<?xml version="1.0"?>
<!DOCTYPE jxta:PGA>
<jxta:PGA xmlns:jxta="http://jxta.org">
<GID>
urn:jxta:jxta-NetGroup
</GID>
<MSID>
urn:jxta:uuid-DEADBEEFDEAFBABAFEEDBABE000000010206
</MSID>
<Name>
NetPeerGroup
</Name>
<Desc>
NetPeerGroup by default
</Desc>
</jxta:PGA>
Der Rest des Programms zeigt noch den Zugriff auf verschiedene Services, die von der Gruppe angeboten werden.
JXTA Konfigurator
Beim ersten Ausführen des obigen (oder eines beliebigen) JXTA Programms wird ein Konfigurationszyklus durchlaufen. Dabei werden die Netzwerkeinstellungen, Namen und Passwörter abgefragt.
JXTA Konfigurator
der Peer Name ist der Name, unter dem der Peer in den Peer Gruppen erscheint
unter Use Proxy Server kann ggf. ein Proxy eingerichtet werden, mit dem man über eine Firewall hinwegkommt
auf der Advanced Seite sind die Netzwerk Parameter einzustellen
Trace Level bietet bei Bedarf mehr Informationen über den Ablauf. Die Level entsprechen den Leveln von Log4j.
HTTP-Settings:
muss man deaktivieren, wenn man zu Hause in einem privaten Netz testetTCP-Settings:
testet man mehrere Peers auf einem Rechner benötigt jeder einen eigenen Port.
hat man mehrere Netzwerkinterfaces ist ggf. eine IP-Adresse einzutragen
in der Netzwerkkonfiguration des Rechners muss auf jeden Fall eine
defaultRoute eingetragen sein, damit Multicast für Peer Discovery funktioniert.unter Rendevouz/Relays sind zunächst keine Eingaben notwendig
auf der Security Seite wird ein Name und ein Passwort für die privaten Schlüssel erfragt (der Name tritt nicht nach aussen in Erscheinung)
der Konfigurator erstellt anschliessend ein Verzeichnis
.jxtain dem alle Konfigurationsinformationen und die privaten Schlüssel abgelegt werdenexistiert in dem Verzeichnis
.jxtaeine Dateireconfwird der Konfigurationszyklus erneut durchlaufenwird das Verzeichnis
.jxtagelöscht wird es erneut angelegt. Dabei werden neue Schlüssel erzeugt.
Wird das Programm erneut ausgeführt, werden nur noch der Namen und das Passwort für den privaten Schlüssel abgefragt.
Name und Passwort für den privaten Schlüssel
Konfigurationsdateien
Das Verzeichnis .jxta enthalt folgende Teile:
die Datei
PlatformConfigenthält die meisten Informationen des Konfiguratorsdas Verzeichnis
cmenthält gecachte Advertisements, z.B. für alle bekannten Peer Gruppen;
für jede Peer Gruppe gibt es ein eigenes Verzeichnis, das wiederum Unterverzeichnisse für Peers, PeerGruppen etc. enthält.
bei JXTA 2.0 gibt es dafür Xindice Dateiendas Verzeichnis
pseenthält den privaten und öffentlichen Schlüssel, die erforderlichen Passwörter und die Schlüssel der Root-CA (ist der Peer selbst)
JXTA Shell
Für die ersten Schritte mit JXTA existiert eine (Unix ähnliche) Shell. Diese Shell bietet für alle wichtigen JXTA Funktionen kleine Kommandos an. Damit lässt sich z.B. ein Überblick über die Peer Gruppen, Peers, Services etc gewinnen.
Shell zum Testen von JXTA Anwendungen
Übersicht über die Shell Kommandos, wie sie vom
Kommando man geliefert wird:
cat Concatanate and display a Shell object chpgrp Change the current peer group clear Clear the shell's screen cms No description available for this ShellApp env Display environment variable exit Exit the Shell exportfile Export to an external file get Get data from a pipe message grep Search for matching patterns groups Discover peer groups help No description available for this ShellApp history No description available for this ShellApp importfile Import an external file instjar Installs jar-files containing additional Shell commands join Join a peer group leave Leave a peer group man An on-line help command that displays information about a specific Shell command mkadv Make an advertisement mkmsg Make a pipe message mkpgrp Create a new peer group mkpipe Create a pipe more Page through a Shell object peerconfig Peer Configuration peerinfo Get information about peers peers Discover peers put Put data into a pipe message rdvserver No description available for this ShellApp rdvstatus Display information about rendezvous recv Receive a message from a pipe rshd JXTA Shell command interpreter search Discover jxta advertisements send Send a message into a pipe set Set an environment variable setenv Set an environment variable sftp Send a file to another peer share Share an advertisement Shell JXTA Shell command interpreter sql Issue an SQL command (not implemented) sqlshell JXTA SQL Shell command interpreter talk Talk to another peer transports Display information about the message transports in the current group uninstjar Uninstalls jar-files previously installed with 'instjar' version No description available for this ShellApp wc Count the number of lines, words, and chars in an object who Display credential information whoami Display information about a peer or peergroup
Instant JXTA Anwendung
Neben der JXTA Shell gibt es eine schöne Anwendung von JXTA, die Chat-Funktionen, Gruppen-Management und File-Sharing/Search erlaubt.
Begrüssungsbild der Instant JXTA Anwendung
Für die Konfiguration startet sich wieder der bekannte JXTA Konfigurator. Mit "Proceed Anyway" erreicht man den Hauptschirm der Anwendung.
Hauptschirm der Instant JXTA Anwendung
In der oberen Anzeige sind alle bekannten Peer Gruppen angezeigt. Ein "joined" hinter einem Gruppennamen gib an, dass man Mitglied dieser Gruppe ist. Die aktuelle Gruppe kann durch anklicken mit der Maus gewechselt werden. Die untere Anzeige hängt von der gewählten Funktion ab.
Anlegen einer neuen Peer Gruppe mit Instant JXTA
Über das Menue "Group - New Group" kann eine neue Gruppe angelegt werden. Optional kann ein Passwort für den Zugang zur Gruppe festgelegt werden.
Hauptschirm der Instant JXTA Anwendung mit einer neuen Peer Gruppe "InTec"
Peer Groups finden und erzeugen
Peer Groups können über den Discovery Service gesucht werden.
Dieser findet lokale oder entfernte Advertisements mit den Methoden
getLocalAdvertisements() und
getRemoteAdvertisements().
Soll eine bestimmte Peer Group verwendet werden,
müssen alle Programme die richtige ID der Peer Group verwenden.
Zur Erzeugung einer Peer Group dient die Methode
newGroup(Advertisement)
bzw. newGroup( ID, Impl, name, desc).
String pgname = "InTecPeerGroup";
String pgURL = "jxta:uuid-3E2406ADF2E542FD87F1A9744052C30D02";
private PeerGroup searchPG(String pgname) throws Exception {
PeerGroup ipg = null;
DiscoveryService disco = gruppe.getDiscoveryService();
Enumeration pgs = null;
for (int i = RETRIES; i > 0; i-- ){
try {
pgs = disco.getLocalAdvertisements(
DiscoveryService.GROUP,
"Name",
pgname);
if ( pgs != null && pgs.hasMoreElements() ) break;
disco.getRemoteAdvertisements(
null,
DiscoveryService.GROUP,
"Name",
pgname,
1,
null);
try {
Thread.sleep( TIMEOUT );
} catch (InterruptedException e) { }
} catch (IOException e) { }
}
PeerGroupAdvertisement pgAdv = null;
if ( pgs != null && pgs.hasMoreElements() ) {
sc.println("PeerGroup " + pgname + " found");
try {
pgAdv = (PeerGroupAdvertisement) pgs.nextElement();
ipg = gruppe.newGroup( pgAdv );
} catch (PeerGroupException e) {
e.printStackTrace();
}
return ipg;
}
sc.println("PeerGroup " + pgname + " not found, creating new one");
ModuleImplAdvertisement implAdv =
gruppe.getAllPurposePeerGroupImplAdvertisement();
ipg = gruppe.newGroup(
mkGroupID(),
implAdv,
pgname,
"The " + pgname + " Description"
);
return ipg;
}
private PeerGroupID mkGroupID() throws Exception {
URL u = new URL( "urn", "", pgURL );
return (PeerGroupID) IDFactory.fromURL( u );
}
Die Ausgabe könnte z.B. so aussehen:
searching InTecPeerGroup PeerGroup InTecPeerGroup found searched InTecPeerGroup ipgid: urn:jxta:uuid-3E2406ADF2E542FD87F1A9744052C30D02
Mitglied einer Peer Group werden
Advertisements werden auch mit Hilfe des Discovery Services
publiziert.
Die entscheidende Methode ist remotePublish().
PeerGroupAdvertisement adv = ipg.getPeerGroupAdvertisement();
DiscoveryService disco = gruppe.getDiscoveryService();
disco.remotePublish(adv, DiscoveryService.GROUP);
sc.println(pgname + " published");
Mit Hilfe des Membership Services kann man Mitglied
in einer Peer Group werden.
Der Service bietet dafür die
Methoden apply() und join().
private void joinPeerGroup(PeerGroup pg) throws Exception {
MembershipService ms = pg.getMembershipService();
AuthenticationCredential ac =
new AuthenticationCredential(pg, null, null);
Authenticator a = ms.apply( ac );
if ( a.isReadyForJoin() ) {
ms.join( a );
} else {
sc.println("a not ready for join "+ pg.getPeerGroupName());
}
}
Beispiel Ausgabe:
joining peer group InTecPeerGroup peer group joined
Peers finden
Wie bei Peer Groups findet man Peers auch mit Hilfe des Discovery Service.
Die Methoden sind wieder
getLocalAdvertisements() und
getRemoteAdvertisements(),
wobei jetzt der Typ disco.PEER verwendet wird.
private void discoverPeers(PeerGroup pg) throws Exception {
sc.println("discovering peers in group " + pg.getPeerGroupName() );
DiscoveryService disco = pg.getDiscoveryService();
Enumeration ps = null;
for (int i = RETRIES; i > 0; i-- ){
try {
disco.getRemoteAdvertisements(
null, disco.PEER, null, null,2, null);
try {
Thread.sleep( TIMEOUT );
} catch (InterruptedException e) { }
} catch (/*IO*/Exception e) { }
}
ps = disco.getLocalAdvertisements(disco.PEER, null, null);
// sc.println("peers: " + ps);
if ( ps == null ) return;
while ( ps.hasMoreElements() ) {
try {
PeerAdvertisement pa =
(PeerAdvertisement) ps.nextElement();
sc.println("found peer: " + pa.getName());
} catch (Exception e) {
e.printStackTrace();
}
}
}
Die Ausgabe könnte wie folgt aussehen:
discovering peers discovering peers in group InTecPeerGroup found peer: InTec Peer found peer: Heinz jxta_2.1 shell found peer: InTec java Peer discovering peers in group NetPeerGroup found peer: InTec Peer found peer: Heinz jxta_2.1 shell found peer: InTec java Peer peers discovered
Die weiteren Möglichkeiten von JXTA, wie die Verwendung von Pipes oder der Aufbau von verschlüsselten Verbindungen können hier nicht behandelt werden.
