| | |
| | | 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(App.getInitParameter(App.getRs(App.RB_AP_WWW_DATA)))); |
| | | 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())); |
| | | } |
| | | } |
| | | } |
| | | } |