From 2eeb9e441b99e390067cb5573d858c8bd72902f1 Mon Sep 17 00:00:00 2001
From: ulrich
Date: Sat, 27 Mar 2021 11:29:28 +0000
Subject: [PATCH] Unterscheidung HEAD/GET eingebaut
---
src/de/uhilger/minsrv/handler/FileHandler.java | 166 +++++++++++++++++++++++++++++++++----------------------
1 files changed, 99 insertions(+), 67 deletions(-)
diff --git a/src/de/uhilger/minsrv/handler/FileHandler.java b/src/de/uhilger/minsrv/handler/FileHandler.java
index d566db4..035ad25 100644
--- a/src/de/uhilger/minsrv/handler/FileHandler.java
+++ b/src/de/uhilger/minsrv/handler/FileHandler.java
@@ -20,6 +20,7 @@
import com.sun.net.httpserver.Headers;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
+import de.uhilger.minsrv.Server;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
@@ -50,24 +51,26 @@
/* Der Logger fuer diesen FileHandler */
private static final Logger logger = Logger.getLogger(FileHandler.class.getName());
- /* Header Namen */
+ /* Headernamen */
public static final String RANGE_HEADER = "Range";
public static final String CONTENT_RANGE_HEADER = "Content-Range";
public static final String ACCEPT_RANGES_HEADER = "Accept-Ranges";
public static final String LAST_MODIFIED_DATE_HEADER = "Last-Modified";
public static final String CONTENT_TYPE = "Content-Type";
- /* Status Codes */
+ /* Statuscodes */
public static final int SC_OK = 200;
public static final int SC_PARTIAL_CONTENT = 206;
public static final int SC_NOT_FOUND = 404;
+ /* HTTP Methoden */
+ public static final String HTTP_GET = "GET";
+
/* String Konstanten */
public static final String STR_BYTES = "bytes";
public static final String STR_BLANK = " ";
public static final String STR_DASH = "-";
public static final String STR_COMMA = ",";
- public static final String STR_SLASH = "/";
public static final String STR_DOT = ".";
public static final String STR_NOT_FOUND = " not found.";
public static final String LM_PATTERN = "EEE, dd MMM yyyy HH:mm:ss zzz";
@@ -75,16 +78,17 @@
public static final String WELCOME_FILE = "index.html";
/* Ablageort fuer Webinhalte */
- private final String basePath;
+ private final String fileBase;
/**
* Ein neues Objekt der Klasse FileHandler erzeugen
*
- * @param basePath der Pfad zu Inhalten, die von diesem Handler ausgeliefert
- * werden
+ * @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 basePath) {
- this.basePath = basePath;
+ public FileHandler(String absoluteDirectoryPathAndName) {
+ this.fileBase = absoluteDirectoryPathAndName;
}
/**
@@ -98,25 +102,29 @@
*/
@Override
public void handle(HttpExchange e) throws IOException {
- String ctxPath = e.getHttpContext().getPath();
- String uriPath = e.getRequestURI().getPath();
- logger.info(uriPath);
- String fName = uriPath.substring(ctxPath.length());
+ String fName = getFileName(e);
if (fName.startsWith(STR_DOT)) {
sendNotFound(e, fName);
} else {
Headers headers = e.getRequestHeaders();
if (headers.containsKey(RANGE_HEADER)) {
- serveFileParts(e, new File(basePath, fName));
+ serveFileParts(e, new File(fileBase, fName));
} else {
- if (fName.endsWith(STR_SLASH)) {
+ if (fName.endsWith(Server.STR_SLASH)) {
fName += WELCOME_FILE;
}
- serveFile(e, new File(basePath, fName));
+ serveFile(e, new File(fileBase, fName));
}
}
}
+ 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
*
@@ -125,21 +133,22 @@
* @param file die Datei, deren Inhalt ausgeliefert werden soll
* @throws IOException falls etwas schief geht entsteht dieser Fehler
*/
- private void serveFile(HttpExchange e, File file) throws IOException {
+ protected void serveFile(HttpExchange e, File file) throws IOException {
if (file.exists()) {
OutputStream os = e.getResponseBody();
- Headers headers = e.getResponseHeaders();
- setCommonHeaders(headers, file);
+ setHeaders(e, file);
e.sendResponseHeaders(SC_OK, file.length());
- InputStream in = new FileInputStream(file);
- int b = in.read();
- while (b > -1) {
- os.write(b);
- b = in.read();
+ if(HTTP_GET.equalsIgnoreCase(e.getRequestMethod())) {
+ InputStream in = new FileInputStream(file);
+ int b = in.read();
+ while (b > -1) {
+ os.write(b);
+ b = in.read();
+ }
+ in.close();
+ os.flush();
+ os.close();
}
- in.close();
- os.flush();
- os.close();
} else {
sendNotFound(e, file.getName());
}
@@ -169,17 +178,17 @@
*/
/*
*/
- private void serveFileParts(HttpExchange e, File file) throws IOException {
+ protected void serveFileParts(HttpExchange e, File file) throws IOException {
if (file.exists()) {
InputStream is = new FileInputStream(file);
OutputStream os = e.getResponseBody();
- Headers resHeaders = e.getResponseHeaders();
- setCommonHeaders(resHeaders, file);
+ 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();
@@ -188,45 +197,24 @@
responseLength += (end - start);
}
e.sendResponseHeaders(SC_PARTIAL_CONTENT, responseLength);
- if (start > 0) {
- is.skip(start);
+ if(HTTP_GET.equalsIgnoreCase(e.getRequestMethod())) {
+ 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();
}
- 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 {
sendNotFound(e, file.getName());
}
- }
-
- private String contentRangeHdr(Range range, File file) {
- StringBuilder sb = new StringBuilder();
- sb.append(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();
- }
-
- private void setCommonHeaders(Headers resHeaders, File file) throws IOException {
- 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));
}
/**
@@ -241,7 +229,7 @@
* @param file die Datei, deren Inhalt ausgeliefert werden soll
* @return die angefragten Byte-Ranges
*/
- private RangeGroup parseRanges(HttpExchange e, File file) {
+ protected RangeGroup parseRanges(HttpExchange e, File file) {
RangeGroup ranges = new RangeGroup();
String rangeHeader = e.getRequestHeaders().get(RANGE_HEADER).toString();
@@ -302,6 +290,48 @@
}
/**
+ * 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(STR_BYTES);
+ sb.append(STR_BLANK);
+ sb.append(range.getStart());
+ sb.append(STR_DASH);
+ sb.append(range.getEnd());
+ sb.append(Server.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
@@ -309,7 +339,7 @@
* @param fname Name der Datei, die nicht gefunden wurde
* @throws IOException falls etwas schief geht entsteht dieser Fehler
*/
- public void sendNotFound(HttpExchange e, String fname) throws IOException {
+ 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);
@@ -320,7 +350,9 @@
}
/**
- * Eine Range
+ * Eine Range bezeichnet einen zusammenhängenden Bereich
+ * aus Bytes, der sich aus den Bytepositionen des Beginns und Endes
+ * des Bereiches ergibt.
*/
class Range {
--
Gitblit v1.9.3