Merge pull request #123 from qq254963746/develop

Develop

Author: qq254963746

build.cmd

@@ -4,7 +4,7 @@ start mvn clean install -DskipTests
 echo "LTS: mvn clean install -DskipTests"
 echo "LTS: After sub window finished, close it , and press any key to continue" & pause>nul
 
-set VERSION=1.6.0-SNAPSHOT
+set VERSION=1.6.0-beta2
 set BASE_HOME=%~dp0%
 set DIST_BIN_DIR=lts-%VERSION%-bin
 

build.sh

@@ -1,6 +1,6 @@
 #!/usr/bin/env bash
 
-VERSION="1.6.0-SNAPSHOT"
+VERSION="1.6.0-beta2"
 
 LTS_BIN="${BASH_SOURCE-$0}"
 LTS_BIN="$(dirname "${LTS_BIN}")"

lts-admin/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>lts-parent</artifactId>
         <groupId>com.lts</groupId>
-        <version>1.6.0-SNAPSHOT</version>
+        <version>1.6.0-beta2</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <packaging>war</packaging>

lts-admin/src/main/java/com/lts/web/support/H2ConsoleWebServlet.java

@@ -3,27 +3,85 @@
 import com.lts.core.constant.Constants;
 import org.h2.server.web.WebServlet;
 
+import javax.servlet.ServletConfig;
 import javax.servlet.ServletContext;
+import javax.servlet.ServletException;
+import java.util.Collections;
+import java.util.Enumeration;
+import java.util.HashMap;
+import java.util.Map;
 
 /**
  * H2 Console 的 servlet
+ *
  * @author Robert HG ([email protected]) on 9/26/15.
  */
 public class H2ConsoleWebServlet extends WebServlet {
 
     @Override
-    public void init() {
+    public void init(ServletConfig config) throws ServletException {
+        ServletConfigFacade servletConfigFacade = new ServletConfigFacade(config);
 
-        ServletContext servletContext = this.getServletConfig().getServletContext();
         String monitorDBPath = AppConfigurer.getProperties("lts.admin.data.path",
                 Constants.USER_HOME) + "/.lts/h2/lts-admin";
         // http://h2database.com/html/features.html#connection_modes
         // http://h2database.com/html/features.html#auto_mixed_mode
-        String url = "jdbc:h2:" + monitorDBPath+";AUTO_SERVER=TRUE";
-        servletContext.setInitParameter("url", url);
-        servletContext.setInitParameter("user", "lts");
-        servletContext.setInitParameter("password", "");
+        String url = "jdbc:h2:" + monitorDBPath + ";AUTO_SERVER=TRUE";
+        servletConfigFacade.setInitParameter("url", url);
+        servletConfigFacade.setInitParameter("user", "lts");
+        servletConfigFacade.setInitParameter("password", "");
+        servletConfigFacade.setInitParameter("webAllowOthers", "true");
 
-        super.init();
+        super.init(servletConfigFacade);
     }
 }
+
+/**
+ * 主要为解决 jetty embedded 的问题
+ */
+class ServletConfigFacade implements ServletConfig {
+
+    private ServletConfig servletConfig;
+
+    private Map<String, String> initParams;
+
+    public ServletConfigFacade(ServletConfig servletConfig) {
+        this.servletConfig = servletConfig;
+        this.initParams = new HashMap<String, String>();
+
+        initParams();
+    }
+
+    private void initParams() {
+        Enumeration<?> en = servletConfig.getInitParameterNames();
+        while (en.hasMoreElements()) {
+            String name = en.nextElement().toString();
+            String value = servletConfig.getInitParameter(name);
+            initParams.put(name, value);
+        }
+    }
+
+    @Override
+    public String getServletName() {
+        return servletConfig.getServletName();
+    }
+
+    @Override
+    public ServletContext getServletContext() {
+        return servletConfig.getServletContext();
+    }
+
+    @Override
+    public String getInitParameter(String name) {
+        return initParams.get(name);
+    }
+
+    @Override
+    public Enumeration<String> getInitParameterNames() {
+        return Collections.enumeration(initParams.keySet());
+    }
+
+    public void setInitParameter(String name, String value) {
+        initParams.put(name, value);
+    }
+}

lts-admin/src/main/java/com/lts/web/support/LtsAdminJobClient.java

@@ -1,6 +1,7 @@
 package com.lts.web.support;
 
 import com.lts.core.commons.utils.StringUtils;
+import com.lts.core.constant.Constants;
 import com.lts.core.domain.Job;
 import com.lts.jobclient.JobClient;
 import com.lts.jobclient.domain.Response;
@@ -27,6 +28,7 @@ public void afterPropertiesSet() throws Exception {
         if (StringUtils.isEmpty(clusterName)) {
             throw new IllegalArgumentException("clusterName in lts-admin.cfg can not be null.");
         }
+        jobClient.setFailStorePath(AppConfigurer.getProperties("lts.admin.data.path", Constants.USER_HOME));
         jobClient.setClusterName(clusterName);
         jobClient.setRegistryAddress(AppConfigurer.getProperties("registryAddress"));
 

lts-admin/src/main/resources/spring-web.xml

@@ -38,7 +38,7 @@
 
     <bean id="velocityConfig" class="org.springframework.web.servlet.view.velocity.VelocityConfigurer">
         <property name="configLocation">
-            <value>/views/velocity.properties</value>
+            <value>/WEB-INF/views/velocity.properties</value>
         </property>
     </bean>
     <bean id="viewResolver"