From bebd4767df2dd419a2d04eaa4253592d13336e8c Mon Sep 17 00:00:00 2001 From: ulrich Date: Tue, 06 Apr 2021 22:01:26 +0000 Subject: [PATCH] Gestaltungen angepasst --- src/de/uhilger/mediaz/Server.java | 89 +++++++++++++++++++++++++++++--------------- 1 files changed, 59 insertions(+), 30 deletions(-) diff --git a/src/de/uhilger/mediaz/Server.java b/src/de/uhilger/mediaz/Server.java index 7fbef25..af203fb 100644 --- a/src/de/uhilger/mediaz/Server.java +++ b/src/de/uhilger/mediaz/Server.java @@ -18,94 +18,123 @@ package de.uhilger.mediaz; import com.sun.net.httpserver.HttpServer; -import de.uhilger.mediaz.api.AblageTestHandler; import de.uhilger.mediaz.api.FileHandler; +import de.uhilger.mediaz.api.ListFileHandler; import de.uhilger.mediaz.api.StopServerHandler; -import de.uhilger.mediaz.api.StoreTestHandler; +import de.uhilger.mediaz.api.StorageHandler; +import de.uhilger.mediaz.store.FileStorage; +import de.uhilger.mediaz.entity.Ablageort; import java.io.File; import java.io.IOException; import java.util.logging.Logger; import java.net.InetSocketAddress; import java.util.concurrent.Executors; import java.util.logging.Level; +import de.uhilger.mediaz.entity.Entity; +import java.util.Iterator; +import java.util.List; /** - * Die Klasse Server stellt Methoden zur Ausführung eines - * HTTP-Servers bereit - * + * Die Klasse Server stellt Methoden zur Ausführung eines HTTP-Servers + * bereit + * * @author Ulrich Hilger * @version 0.1, 25.03.2021 */ public class Server { - + private static final Logger logger = Logger.getLogger(Server.class.getName()); - + public static final String RB_SERVER_START_MSG = "msgServerStart"; public static final String RB_WEBROOT = "webroot"; + public static final String RB_STORE = "store"; //public static final String RB_UI_ROOT = "uiroot"; public static final String RB_STOP_SERVER = "stopServer"; - public static final String RB_ABLAGE_TEST = "testAblage"; - public static final String RB_STORE_TEST = "testStore"; + //public static final String RB_ABLAGE_TEST = "testAblage"; + //public static final String RB_STORE_TEST = "testStore"; public static final String RB_SLASH = "slash"; - + private int port; - + private String ctx; - + /** * Ein neues Objekt der Kalsse Server erzeugen - * @param port der Port, über den dieser Server erreichbar sein soll + * + * @param port der Port, über den dieser Server erreichbar sein soll */ public Server(int port) { this.port = port; } - + /** * Den Port angeben, unter dem der Server erreichbar sein soll - * + * * @param port der Port, unter dem der Server erreichbar sein soll */ public void setPort(int port) { this.port = port; } - + /** - * Den Namen des Kontexts angeben, über den dieser Server - * erreichbar sein soll + * Den Namen des Kontexts angeben, über den dieser Server erreichbar sein + * soll + * * @param ctxName Name des Kontexts, unter dem der Server aufrufbar sein soll */ public void setContextName(String ctxName) { String slash = App.getRs(RB_SLASH); - if(!ctxName.startsWith(slash)) { + if (!ctxName.startsWith(slash)) { this.ctx = slash + ctxName; } else { this.ctx = ctxName; } } - + /** - * Die Endpunkte ('Context'e) einrichten, unter denen die Dienste - * dieses Servers erreichbar sein sollen und den Server starten - * - * @throws IOException wenn etwas schief geht, finden sich Angaben - * in diesem Objekt + * Die Endpunkte einrichten, unter denen die Dienste dieses + * Servers erreichbar sein sollen und den Server starten + * + * @throws IOException wenn etwas schief geht, finden sich Angaben in diesem + * Objekt + * @throws java.lang.ClassNotFoundException */ - public void start() throws IOException { + public void start() throws IOException, ClassNotFoundException { logger.log(Level.INFO, App.getRs(RB_SERVER_START_MSG), Integer.toString(port)); - + String wwwData = App.getInitParameter(App.getRs(App.RB_AP_WWW_DATA)); File wwwDir = new File(wwwData); //String ui = App.getInitParameter(App.getRs(App.RB_AP_UI)); //File uiDir = new File(ui); HttpServer server = HttpServer.create(new InetSocketAddress(port), 0); - server.createContext(ctx + App.getRs(RB_WEBROOT), new FileHandler(wwwDir.getAbsolutePath())); + server.createContext(ctx + App.getRs(RB_WEBROOT), + new FileHandler(wwwDir.getAbsolutePath())); + ablageorteEinklinken(server); + server.createContext(ctx + App.getRs(RB_STORE), new StorageHandler()); //server.createContext(ctx + App.getRs(RB_UI_ROOT), new FileHandler(uiDir.getAbsolutePath())); server.createContext(ctx + App.getRs(RB_STOP_SERVER), new StopServerHandler()); - server.createContext(ctx + App.getRs(RB_ABLAGE_TEST), new AblageTestHandler()); - server.createContext(ctx + App.getRs(RB_STORE_TEST), new StoreTestHandler()); + //server.createContext(ctx + App.getRs(RB_ABLAGE_TEST), new AblageTestHandler()); + //server.createContext(ctx + App.getRs(RB_STORE_TEST), new StoreTestHandler()); server.setExecutor(Executors.newFixedThreadPool(20)); server.start(); } + private void ablageorteEinklinken(HttpServer server) throws ClassNotFoundException, IOException { + String typ = Ablageort.class.getSimpleName(); + FileStorage store = new FileStorage(App.getInitParameter(App.getRs(App.RB_AP_CONF))); + List<String> orte = store.list(typ); + Iterator<String> i = orte.iterator(); + while(i.hasNext()) { + String ortName = i.next(); + Entity e = store.read(typ, ortName); + if(e instanceof Ablageort) { + Ablageort ort = (Ablageort) e; + Ablageort ablageort = (Ablageort) e; + logger.fine(ctx + ablageort.getUrl()); + server.createContext(ctx + ablageort.getUrl(), + new ListFileHandler(new File(ablageort.getOrt()).getAbsolutePath())); + } + } + } } -- Gitblit v1.9.3