From f5728b1d24410f076777c1a6cd409c5e65d72051 Mon Sep 17 00:00:00 2001 From: ulrich Date: Sat, 03 Jul 2021 08:27:56 +0000 Subject: [PATCH] FileHandler aufgeraeumt --- src/de/uhilger/httpserver/base/handler/FileHandler.java | 384 ++---------------------------------------------------- 1 files changed, 19 insertions(+), 365 deletions(-) diff --git a/src/de/uhilger/httpserver/base/handler/FileHandler.java b/src/de/uhilger/httpserver/base/handler/FileHandler.java index af37a16..b939b2f 100644 --- a/src/de/uhilger/httpserver/base/handler/FileHandler.java +++ b/src/de/uhilger/httpserver/base/handler/FileHandler.java @@ -17,17 +17,14 @@ */ package de.uhilger.httpserver.base.handler; +import de.uhilger.httpserver.base.HttpResponder; import com.sun.net.httpserver.Headers; import com.sun.net.httpserver.HttpExchange; import com.sun.net.httpserver.HttpHandler; +import de.uhilger.httpserver.base.HttpHelper; +import de.uhilger.httpserver.base.actor.FileActor; import java.io.File; -import java.io.FileInputStream; import java.io.IOException; -import java.io.InputStream; -import java.io.OutputStream; -import java.util.ArrayList; -import java.util.Iterator; -import java.util.List; import java.util.logging.Logger; /** @@ -57,13 +54,11 @@ /* Statuscodes */ public static final int SC_OK = 200; public static final int SC_PARTIAL_CONTENT = 206; + public static final int SC_FORBIDDEN = 403; public static final int SC_NOT_FOUND = 404; public static final int SC_METHOD_NOT_ALLOWED = 405; public static final int SC_UNPROCESSABLE_ENTITY = 422; - /* HTTP Methoden */ - public static final String HTTP_GET = "GET"; - /* String Konstanten */ //public static final String STR_BYTES = "bytes"; public static final String STR_SLASH = "/"; @@ -77,18 +72,10 @@ public static final String WELCOME_FILE = "index.html"; /* Ablageort fuer Webinhalte */ - protected final String fileBase; - - /** - * Ein neues Objekt der Klasse FileHandler erzeugen - * - * @param absoluteDirectoryPathAndName der absolute Pfad und Name des - * Ordners im Dateisystem, der die Inhalte enthaelt, die von diesem - * Handler ausgeliefert werden sollen - */ - public FileHandler(String absoluteDirectoryPathAndName) { - this.fileBase = absoluteDirectoryPathAndName; - } + //protected final String fileBase; + + public static final String ATTR_FILE_BASE = "fileBase"; + public static final String ATTR_WELCOME_FILES = "welcomeFiles"; /** * Die Datei ermitteln, die sich aus dem angefragten URL ergibt, prüfen, @@ -101,360 +88,27 @@ */ @Override public void handle(HttpExchange e) throws IOException { - String fName = getFileName(e); + String fName = new HttpHelper().getFileName(e); if (fName.startsWith(STR_DOT)) { HttpResponder fs = new HttpResponder(); fs.sendNotFound(e, fName); } else { Headers headers = e.getRequestHeaders(); if (headers.containsKey(RANGE_HEADER)) { - serveFileParts(e, new File(fileBase, fName)); + FileActor fa = new FileActor(); + fa.serveFileParts(e, new File(e.getHttpContext().getAttributes().get(ATTR_FILE_BASE).toString(), fName)); } else { - if (fName.length() < 1 || fName.endsWith(STR_SLASH)) { - fName += WELCOME_FILE; - } HttpResponder fs = new HttpResponder(); - fs.serveFile(e, new File(fileBase, fName)); - } - } - } - - /** - * Den Namen der gewünschten Datei aus der HTTP-Anfrage ermitteln - * - * @param e das Objekt mit Methoden zur Untersuchung der Anfrage sowie zum - * Anfertigen und Senden der Antwort - * @return Name der gewünschten Datei - */ - protected String getFileName(HttpExchange e) { - String ctxPath = e.getHttpContext().getPath(); - String uriPath = e.getRequestURI().getPath(); - logger.info(uriPath); - return uriPath.substring(ctxPath.length()); - } - - /** - * Den Inhalt einer Datei ausliefern - * - * @param e das Objekt mit Methoden zur Untersuchung der Anfrage sowie zum - * Anfertigen und Senden der Antwort - * @param file die Datei, deren Inhalt ausgeliefert werden soll - * @throws IOException falls etwas schief geht entsteht dieser Fehler - */ - /* - protected void serveFile(HttpExchange e, File file) throws IOException { - if (file.exists()) { - setHeaders(e, file); - e.getResponseHeaders().set(CONTENT_LENGTH, Long.toString(file.length())); - e.sendResponseHeaders(SC_OK, file.length()); - if(HTTP_GET.equalsIgnoreCase(e.getRequestMethod())) { - InputStream in = new FileInputStream(file); - OutputStream os = e.getResponseBody(); - int b = in.read(); - while (b > -1) { - os.write(b); - b = in.read(); + File file = new File(e.getHttpContext().getAttributes().get(ATTR_FILE_BASE).toString(), fName); + if (fName.length() < 1 || fName.endsWith(STR_SLASH)) { + HttpHelper helper = new HttpHelper(); + File welcomeFile = helper.tryWelcomeFiles(e, fName); + if(welcomeFile != null) { + file = welcomeFile; + } } - in.close(); - os.flush(); - os.close(); + fs.serveFile(e, file); } - } else { - sendNotFound(e, file.getName()); - } - } - */ - - /** - * Einen Teil des Inhalts einer Datei ausliefern - * - * Wenn eine Range angefragt wird, hat die Antwort einen Content-Range Header - * wie folgt: - * - * <code> - * Content-Range: bytes 0-1023/146515 - * Content-Length: 1024 - * </code> - * - * Wenn mehrere Ranges angefragt werden, hat die Antwort mehrere Content-Range - * Header als Multipart Response. Multipart Responses fehlen dieser - * Implementierung noch. - * - * (vgl. https://developer.mozilla.org/en-US/docs/Web/HTTP/Range_requests) - * - * @param e das Objekt mit Methoden zur Untersuchung der Anfrage sowie zum - * Anfertigen und Senden der Antwort - * @param file die Datei, deren Inhalt teilweise ausgeliefert werden soll - * @throws IOException falls etwas schief geht entsteht dieser Fehler - */ - /* - */ - protected void serveFileParts(HttpExchange e, File file) throws IOException { - if (file.exists()) { - HttpResponder fs = new HttpResponder(); - fs.setHeaders(e, file); - long responseLength = 0; - long start = 0; - long end; - RangeGroup rangeGroup = parseRanges(e, file); - Iterator<Range> i = rangeGroup.getRanges(); - Headers resHeaders = e.getResponseHeaders(); - while (i.hasNext()) { - Range range = i.next(); - start = range.getStart(); - end = range.getEnd(); - resHeaders.add(CONTENT_RANGE_HEADER, contentRangeHdr(range, file)); - responseLength += (end - start); - } - e.sendResponseHeaders(SC_PARTIAL_CONTENT, responseLength); - if(HttpResponder.HTTP_GET.equalsIgnoreCase(e.getRequestMethod())) { - InputStream is = new FileInputStream(file); - OutputStream os = e.getResponseBody(); - if (start > 0) { - is.skip(start); - } - long count = 0; - int byteRead = is.read(); - while (byteRead > -1 && count < responseLength) { - ++count; - os.write(byteRead); - byteRead = is.read(); - } - os.flush(); - os.close(); - is.close(); - } - } else { - HttpResponder fs = new HttpResponder(); - fs.sendNotFound(e, file.getName()); - } - } - - /** - * Die Byte-Ranges aus dem Range-Header ermitteln. - * - * Der Range-Header kann unterschiedliche Abschnitte bezeichnen, Beispiele: - * Range: bytes=200-1000, 2000-6576, 19000- Range: bytes=0-499, -500 (vgl. - * https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Range) - * - * @param e das Objekt mit Methoden zur Untersuchung der Anfrage sowie zum - * Anfertigen und Senden der Antwort - * @param file die Datei, deren Inhalt ausgeliefert werden soll - * @return die angefragten Byte-Ranges - */ - protected RangeGroup parseRanges(HttpExchange e, File file) { - RangeGroup ranges = new RangeGroup(); - String rangeHeader = e.getRequestHeaders().get(RANGE_HEADER).toString(); - - /* - Inhalt des Range-Headers von nicht benoetigten Angaben befreien - - Ein Range Header enthaelt neben den Start- und Endwerten der Ranges auch - die Angabe "bytes:". Es ist aber keine andere Auspraegung als Bytes - spezifiziert, daher muss die Angabe nicht ausgewertet werden und kann - entfallen. Der Range-Header kann zudem noch eckige Klammern haben - wie in [bytes=200-1000]. - - Der regulaere Ausdruck "[^\\d-,]" bezeichnet alle Zeichen, die keine - Ziffern 0-9, Bindestrich oder Komma sind. - */ - rangeHeader = rangeHeader.replaceAll(RANGE_PATTERN, ""); - - /* - Die Ranges ermitteln. - - Nach dem vorangegangenen Schritt besteht der Header-Ausdruck nur noch - aus einer mit Kommas getrennten Liste aus Start- und Endwerten wie z.B. - "-103,214-930,1647-" - - Ein Range-Ausdruck kann dann drei verschiedene Auspraegungen haben: - 1. Startwert fehlt, z.B. -200 - 2. Start und Ende sind vorhanden, z.B. 101-200 - 3. Endwert fehlt, z.B. 201- - - Teilt man einen Range-String mit der Methode String.split("-") am - Bindestrich ('-') in ein String-Array 'values' gilt: - values.length < 2: Fall 3 ist gegeben - values.length > 1 und values[0].length < 1: Fall 1 ist gegeben - ansonsten: Fall 2 ist gegeben - */ - String[] rangeArray = rangeHeader.split(STR_COMMA); - for (String rangeStr : rangeArray) { - Range range = new Range(); - String[] values = rangeStr.split(STR_DASH); - if (values.length < 2) { - // Fall 3 - range.setStart(Long.parseLong(values[0])); - range.setEnd(file.length()); - } else { - if (values[0].length() < 1) { - // Fall 1 - range.setStart(0); - range.setEnd(Long.parseLong(values[1])); - } else { - // Fall 2 - range.setStart(Long.parseLong(values[0])); - range.setEnd(Long.parseLong(values[1])); - } - } - ranges.addRange(range); - } - return ranges; - } - - /** - * Einen Content-Range Header erzeugen - * - * @param range die Range, aus deren Inhalt der Header erzeugt werden soll - * @param file die Datei, die den Inhalt liefert, der vom Header - * bezeichnet wird - * @return der Inhalt des Content-Range Headers - */ - protected String contentRangeHdr(Range range, File file) { - StringBuilder sb = new StringBuilder(); - sb.append(HttpResponder.STR_BYTES); - sb.append(STR_BLANK); - sb.append(range.getStart()); - sb.append(STR_DASH); - sb.append(range.getEnd()); - sb.append(STR_SLASH); - sb.append(file.length()); - return sb.toString(); - } - - /** - * Die Header erzeugen, die unabhängig davon, ob der ganze - * Inhalt oder nur Teile davon ausgeliefert werden sollen, in der - * Antwort stehen sollen - * - * @param e das Objekt mit Methoden zur Untersuchung der Anfrage sowie zum - * Anfertigen und Senden der Antwort - * @param file die Datei, für die die Header gelten - * @throws IOException falls etwas schief geht entsteht dieser Fehler - */ - /* - protected void setHeaders(HttpExchange e, File file) throws IOException { - Headers resHeaders = e.getResponseHeaders(); - resHeaders.add(ACCEPT_RANGES_HEADER, STR_BYTES); - String mimeType = Files.probeContentType(file.toPath()); - if (mimeType != null) { - resHeaders.add(CONTENT_TYPE, mimeType); - } - SimpleDateFormat sdf = new SimpleDateFormat(LM_PATTERN); - Date date = new Date(file.lastModified()); - resHeaders.add(LAST_MODIFIED_DATE_HEADER, sdf.format(date)); - } - */ - - /** - * Eine nicht gefunden Antwort senden - * - * @param e das Objekt mit Methoden zur Untersuchung der Anfrage sowie zum - * Anfertigen und Senden der Antwort - * @param fname Name der Datei, die nicht gefunden wurde - * @throws IOException falls etwas schief geht entsteht dieser Fehler - */ - /* - protected void sendNotFound(HttpExchange e, String fname) throws IOException { - OutputStream os = e.getResponseBody(); - String response = fname + STR_NOT_FOUND; - byte[] bytes = response.getBytes(StandardCharsets.UTF_8); - e.sendResponseHeaders(SC_NOT_FOUND, bytes.length); - os.write(bytes); - os.flush(); - os.close(); - } - */ - - /** - * Eine Range bezeichnet einen zusammenhängenden Bereich - * aus Bytes, der sich aus den Bytepositionen des Beginns und Endes - * des Bereiches ergibt. - */ - public class Range { - - private long start; - private long end; - - /** - * Den Beginn dieser Range ermitteln - * - * @return Beginn dieser Range - */ - public long getStart() { - return start; - } - - /** - * Den Beginn dieser Range angeben - * - * @param start Beginn dieser Range - */ - public void setStart(long start) { - this.start = start; - } - - /** - * Das Ende dieser Range ermitteln - * - * @return Ende dieser Range - */ - public long getEnd() { - return end; - } - - /** - * Das Ende dieser Range angeben - * - * @param end Ende dieser Range - */ - public void setEnd(long end) { - this.end = end; - } - } - - /** - * Eine Gruppe aus Ranges - */ - class RangeGroup { - - private List<Range> ranges; - private long totalSize; - - /** - * Ein neues Objekt der Klasse RangeGroup erzeugen - */ - public RangeGroup() { - ranges = new ArrayList(); - } - - /** - * Dieser RangeGroup eine Range hinzufuegen. - * - * @param range die Range, die dieser RangeGroup hinzugefuegt werden soll - */ - public void addRange(Range range) { - ranges.add(range); - totalSize += range.getEnd() - range.getStart(); - } - - /** - * Die Gesamtgröße dieser RangeGroup ermitteln, also die Summe - * der Anzahl von Bytes aller ihrer Ranges. - * - * @return die Größe dieser RangeGroup in Bytes - */ - public long getSize() { - return totalSize; - } - - /** - * Einen Iterator über die Ranges dieser RangeGroup abrufen - * - * @return Iterator über die Ranges dieser RangeGroup - */ - public Iterator<Range> getRanges() { - return ranges.iterator(); } } } -- Gitblit v1.9.3