Kommentare und Dokumentation ergaenzt

ulrich

2021-03-26 d0bb217f9fd72ff981c1e96aac9d7d87006d7736

 src/de/uhilger/minsrv/handler/FileHandler.java

@@ -20,23 +20,28 @@
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;
import java.io.InputStream;
import java.io.OutputStream;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
import java.util.logging.Logger;

/**
 * Die Klasse FileHandler dient zur Auslieferung von Dateiinhalten über
 * HTTP.
 *
 * Für das Streaming über HTTP wird die Auslieferung von Teilinhalten
 * mit dem Accept-Ranges-Header angeboten und via Range-Header unterstützt.
 * (vgl. https://developer.mozilla.org/en-US/docs/Web/HTTP/Range_requests)
 *
 * @author Ulrich Hilger
 * @version 0.1, 25. März 2021
@@ -47,16 +52,27 @@
  private static final Logger logger = Logger.getLogger(FileHandler.class.getName());

  /* Header Namen */
  final static String RANGE_HEADER = "Range";
  final static String CONTENT_RANGE_HEADER = "Content-Range";
  final static String ACCEPT_RANGES_HEADER = "Accept-Ranges";
  final static String LAST_MODIFIED_DATE_HEADER = "Last-Modified";
  final static String CONTENT_TYPE = "Content-Type";
  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 */
  public static final int SC_OK = 200;
  public static final int SC_PARTIAL_CONTENT = 206;
  public static final int SC_NOT_FOUND = 404;

  /* 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_DOT = ".";
  public static final String STR_NOT_FOUND = " not found.";
  public static final String LM_PATTERN = "EEE, dd MMM yyyy HH:mm:ss zzz";
  public static final String RANGE_PATTERN = "[^\\d-,]";
  public static final String WELCOME_FILE = "index.html";

  /* Ablageort fuer Webinhalte */
  private final String basePath;
@@ -83,37 +99,18 @@
  @Override
  public void handle(HttpExchange e) throws IOException {
    String ctxPath = e.getHttpContext().getPath();
    logger.finer(ctxPath);
    String uriPath = e.getRequestURI().getPath();
    logger.finer(uriPath);
    logger.info(uriPath);
    String fName = uriPath.substring(ctxPath.length());
    logger.finer(fName);
    
    Headers headers = e.getRequestHeaders();
    Set keys = headers.keySet();
    Iterator i = keys.iterator();
    StringBuilder sb = new StringBuilder();
    while(i.hasNext()) {
      String key = i.next().toString();
      sb.append("   ");
      sb.append(key);
      sb.append(": ");
      sb.append(headers.getFirst(key));
      sb.append("\r\n");
    }
    logger.finer(sb.toString());
    
    if (fName.startsWith(".")) {
    if (fName.startsWith(STR_DOT)) {
      sendNotFound(e, fName);
    } else {
      //Headers headers = e.getRequestHeaders();
      Headers headers = e.getRequestHeaders();
      if (headers.containsKey(RANGE_HEADER)) {
        logger.finer("has range header");
        serveFileParts(e, new File(basePath, fName));
      } else {
        logger.finer("no range header");        
        if (fName.endsWith("/")) {
          fName += "index.html";
        if (fName.endsWith(Server.STR_SLASH)) {
          fName += WELCOME_FILE;
        }
        serveFile(e, new File(basePath, fName));
      }
@@ -132,7 +129,7 @@
    if (file.exists()) {
      OutputStream os = e.getResponseBody();
      Headers headers = e.getResponseHeaders();
      headers.add(ACCEPT_RANGES_HEADER, "bytes");
      setCommonHeaders(headers, file);
      e.sendResponseHeaders(SC_OK, file.length());
      InputStream in = new FileInputStream(file);
      int b = in.read();
@@ -177,7 +174,7 @@
      InputStream is = new FileInputStream(file);
      OutputStream os = e.getResponseBody();
      Headers resHeaders = e.getResponseHeaders();
      resHeaders.add(ACCEPT_RANGES_HEADER, "bytes");
      setCommonHeaders(resHeaders, file);
      long responseLength = 0;
      long start = 0;
      long end;
@@ -187,22 +184,9 @@
        Range range = i.next();
        start = range.getStart();
        end = range.getEnd();
        StringBuilder sb = new StringBuilder();
        sb.append("bytes ");
        sb.append(range.getStart());
        sb.append("-");
        sb.append(range.getEnd());
        sb.append("/");
        sb.append(file.length());
        resHeaders.add(CONTENT_RANGE_HEADER, sb.toString());
        logger.info(sb.toString());
        resHeaders.add(CONTENT_RANGE_HEADER, contentRangeHdr(range, file));
        responseLength += (end - start);
        logger.info("responseLength: " + responseLength);
      }
      resHeaders.add(CONTENT_TYPE, "video/mp4");
      SimpleDateFormat sdf = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss zzz");
      Date date = new Date(file.lastModified());
      resHeaders.add(LAST_MODIFIED_DATE_HEADER, sdf.format(date));
      e.sendResponseHeaders(SC_PARTIAL_CONTENT, responseLength);
      if (start > 0) {
        is.skip(start);
@@ -237,7 +221,7 @@
  private RangeGroup parseRanges(HttpExchange e, File file) {
    RangeGroup ranges = new RangeGroup();
    String rangeHeader = e.getRequestHeaders().get(RANGE_HEADER).toString();
    logger.info(rangeHeader);

    /*
      Inhalt des Range-Headers von nicht benoetigten Angaben befreien
    
@@ -250,8 +234,7 @@
      Der regulaere Ausdruck "[^\\d-,]" bezeichnet alle Zeichen, die keine 
      Ziffern 0-9, Bindestrich oder Komma sind.
     */
    rangeHeader = rangeHeader.replaceAll("[^\\d-,]", "");
    logger.info(rangeHeader);
    rangeHeader = rangeHeader.replaceAll(RANGE_PATTERN, "");

    /*
      Die Ranges ermitteln. 
@@ -271,10 +254,10 @@
      values.length > 1 und values[0].length < 1: Fall 1 ist gegeben
      ansonsten: Fall 2 ist gegeben
     */
    String[] rangeArray = rangeHeader.split(",");
    String[] rangeArray = rangeHeader.split(STR_COMMA);
    for (String rangeStr : rangeArray) {
      Range range = new Range();
      String[] values = rangeStr.split("-");
      String[] values = rangeStr.split(STR_DASH);
      if (values.length < 2) {
        // Fall 3
        range.setStart(Long.parseLong(values[0]));
@@ -296,16 +279,56 @@
  }

  /**
   * Eine nicht gefunden Antwort senden
   * 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
   */
  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(Server.STR_SLASH);
    sb.append(file.length());
    return sb.toString();
  }

  /**
   * Die Header erzeugen, die unabh&auml;ngig davon, ob der ganze 
   * Inhalt oder nur Teile davon ausgeliefert werden sollen, in der 
   * Antwort stehen sollen 
   * 
   * @param resHeaders das Objekt, in das die Header erzeugt werden
   * @param file  die Datei, f&uuml;r die die Header gelten
   * @throws IOException falls etwas schief geht entsteht dieser Fehler
   */
  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));
  }

  /**
   * 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
   */
  public void sendNotFound(HttpExchange e, String fname) throws IOException {
  private void sendNotFound(HttpExchange e, String fname) throws IOException {
    OutputStream os = e.getResponseBody();
    String response = fname + " not found.";
    String response = fname + STR_NOT_FOUND;
    byte[] bytes = response.getBytes(StandardCharsets.UTF_8);
    e.sendResponseHeaders(SC_NOT_FOUND, bytes.length);
    os.write(bytes);
@@ -314,7 +337,9 @@
  }

  /**
   * Eine Range
   * Eine Range bezeichnet einen zusammenh&auml;ngenden Bereich 
   * aus Bytes, der sich aus den Bytepositionen des Beginns und Endes 
   * des Bereiches ergibt.
   */
  class Range {