package javacodebook.thread.httpserver; import java.net.Socket; import java.io.*; /** * Der RequestHandler bearbeitet einen Request und sendet an den Client die * von ihm verlangte Seite. */ public class RequestHandler extends Thread { String docRoot; Socket socket; public RequestHandler(String docRoot, Socket socket) { this.docRoot = docRoot; this.socket = socket; } public void run() { try { // Erst einmal feststellen, welche Seite der Client den überhaupt // verlangt hat. Sollte dies nicht feststellbar sein, wird eine // Fehlerseite an den Client zurückgeschickt. String requestedUrl = getRequestedUrl(socket); if (requestedUrl == null) { sendError(444, "Konnte request nicht auslesen"); return; } // Die vom Client angeforderte Seite und die Datei im // Dateisystem, welche der angeforderten Seite entspricht, werden // als LOG-Information ausgegeben. System.out.print("Verlangte Seite: " + requestedUrl); System.out.println(" -> "+ docRoot + requestedUrl); File file = new File(docRoot + requestedUrl); // Huch, die Datei gibt es gar nicht! Der Client wird darüber // informiert. if (!file.exists()) sendError(404, "Datei nicht gefunden!"); // Evtl. ist die angeforderte Seite gar keine Seite sondern ein // Verzeichnis. Dann wird dem Client der Inhalt des Verzeichnisses // aufgelistet else if (file.isDirectory()) sendDirectory(requestedUrl); // Der Normalfall: Die angeforderte Seite wird an den Client // gesendet. else sendFile(file); // Nach getaner Arbeit wird die Verbindung zum Client geschlossen // und der Thread beendet sich. socket.close(); } catch (Exception e) { System.err.print("Anfrage konnte nicht korrekt beantwortet werden"); System.err.println("Grund: " + e.getMessage()); } } /** * Die in der ersten Zeile eines Requests stehende URL wird ausgelesen. */ private String getRequestedUrl(Socket socket) throws Exception { BufferedReader input = new BufferedReader( new InputStreamReader(socket.getInputStream())); String request = input.readLine(); int start = request.indexOf(' '); int end = request.indexOf(' ', start+1); return request.substring(start+1, end); } /** * Sendet eine Datei an den Client */ private void sendFile(File file) throws IOException { // Streams zum lesen der Datei und schreiben zum Client öffnen. FileInputStream input = new FileInputStream(file); PrintStream output = new PrintStream(this.socket.getOutputStream()); // HTTP-Header an Client senden. Da der Content-Type der Datei // (Kann z.B. eine HTML-Seite, ein Bild, eine PDF-Datei sein) unbekannt // ist, wird auch kein Content-Type angegeben. output.println("HTTP/1.0 200 OK"); output.println(""); // Komplette Datei auslesen und an Client senden int size = 0; byte buf[] = new byte[1024]; while(true) { size = input.read(buf); if (size < 0) break; output.write(buf, 0, size); } output.close(); input.close(); } private void sendError(int errorCode, String errorMsg) throws IOException { PrintStream output = new PrintStream(this.socket.getOutputStream()); // HTTP-Header mit Fehlercode und Fehlermeldung schreiben output.println("HTTP/1.0 " + errorCode + " " + errorMsg); output.println("Content-type: text/html"); output.println(""); // Eine Standard-Fehlermeldungsseite an den Client senden. output.println(""); output.println(""); output.println(errorCode + " - " + errorMsg); output.println(""); output.println(""); output.println("

"); output.println(errorCode + " - " + errorMsg); output.println("

"); output.println(""); output.println(""); output.close(); } private void sendDirectory(String requestedUrl) throws IOException { // Verzeichniss-Angaben muessen immer mit einem Slash enden. if (!requestedUrl.endsWith("/")) requestedUrl += "/"; // Einen Stream zum schreiben von Daten an den Client öffnen PrintStream output = new PrintStream(this.socket.getOutputStream()); // Den gesamten Inhalt des Verzeichnisses lesen File dir = new File(docRoot + requestedUrl); File[] entries = dir.listFiles(); output.println("HTTP/1.0 200 OK"); output.println("Content-type: text/html"); output.println(""); output.println(""); output.println(""); output.println("

" + requestedUrl + "

"); output.println(""); // Evtl. die Möglichkeit bieten eine Verzeichnisebene hochzuklettern // (Aber nur, wenn man sich noch nicht im Root-Verzeichnis befindet) if (!requestedUrl.equals("/")) { output.println(""); output.println(""); output.println(""); output.println(""); } for (int i=0; i"); output.println(""); output.println(""); output.println(""); } output.println("
dir..
"); // Verzeichnisse mit 'dir', Dateien mit 'file' bezeichnen. if (entries[i].isDirectory()) output.println("dir"); else output.println("file"); output.println(""); output.print(""); output.println(name + ""); output.println("
"); output.println(""); output.println(""); output.close(); } } --- Neue Klasse --- package javacodebook.thread.httpserver; import java.net.*; import java.io.*; /** * Der Hauptthread des HTTP-Servers. Er nimmt Anfragen von Clients entgegen und * leitet diese weiter an einen RequestHandler. Jede einzelne Anfrage wird in * einem eigenen Thread bearbeitet. Damit wird sichergestellt, das Anfragen von * mehreren Clients gleichzeitig beantwortet werden können. */ public class TinyHttpDaemon extends Thread { private int port; private String docRoot; /** * Damit der HTTP-Server arbeiten kann braucht er die Information, auf * welchem Port der Server horchen soll und wo die HTML-Seiten liegen. */ public TinyHttpDaemon(String docRoot, int port) { this.docRoot = docRoot; this.port = port; } public void run() { ServerSocket socket; Socket request; RequestHandler handler; System.out.println("Starte HttpDaemon ..."); try { socket = new ServerSocket(this.port); } catch (Exception e) { System.err.println( "Konnte HttpDaemon nicht starten. " + "Fehlermeldung: " + e.getMessage() ); return; } // Die Hauptroutine des HTTP-Servers System.out.println("HttpDaemon bereit."); while(true) { try { // Der Aufruf von accept() blockiert solange, bis sich ein // neuer Client mit einem Request an den Server wendet request = socket.accept(); // Für jeden Request wird ein neuer Thread erzeugt. handler = new RequestHandler(this.docRoot, request); handler.start(); } catch (Exception e) { System.err.println( "Konnte Anfrage nicht bearbeiten. " + "Grund: " + e.getMessage() ); } } } } --- Neue Klasse --- package javacodebook.thread.httpserver; /** * Startet den HTTP-Server. * * Der Anwendung können max. 2 Parameter übergeben werden. Der erste Parameter * definiert das Verzeichnis, aus dem die HTML-Seite, Bilder etc. geladen werden * sollen (sog. Document-Root). Der zweite Parameter ist optional und definiert * den Port, auf dem der Server Anfragen entgegennimmt. Wenn hier nichts * angegeben wird, nutzt der Server den Port 8080. */ public class Starter { public static void main(String []args) { int port = 8080; try { String docRoot = args[0]; if (args.length>1) port = Integer.parseInt(args[1]); TinyHttpDaemon daemon = new TinyHttpDaemon(docRoot, port); daemon.start(); } catch (Exception e) { System.err.println("Bitte rufen Sie das Beispiel wie folgt auf: "); System.err.println("java javacodebook.thread.httpserver.Starter docRoot [port]"); } } }