IDEA内嵌Jetty启动SpringMvc项目

package com.train.simulate.web.server; public class JettyServerRun {
public static final int DEFAULT_PORT = 8898;
public static final String DEFAULT_CONTEXT_PATH = "/train";
private static final String DEFAULT_APP_CONTEXT_PATH = "src/main/webapp"; public static void main(String[] args) { runJettyServer(DEFAULT_PORT, DEFAULT_CONTEXT_PATH); } public static void runJettyServer(int port, String contextPath) { new JettyServerForIDEA(DEFAULT_APP_CONTEXT_PATH,port,contextPath).start(); }
}

/**
* Copyright (c) 2011-2017, James Zhan 詹波 (jfinal@126.com).
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/ package com.train.simulate.web.server; import java.io.File;
import java.io.IOException;
import java.net.DatagramSocket;
import java.net.ServerSocket;
import java.util.EnumSet; import com.train.simulate.common.utils.*;
import org.eclipse.jetty.server.DispatcherType;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.server.SessionManager;
import org.eclipse.jetty.server.nio.SelectChannelConnector;
import org.eclipse.jetty.server.session.HashSessionManager;
import org.eclipse.jetty.server.session.SessionHandler;
import org.eclipse.jetty.servlet.FilterHolder;
import org.eclipse.jetty.webapp.WebAppContext;
import org.springframework.web.filter.DelegatingFilterProxy; /**
* IDEA 专用于在 IDEA 之下用 main 方法启动，原启动方式在 IDEA 下会报异常
* 注意：用此方法启动对热加载支持不完全，只支持方法内部修改的热加载，不支持添加、删除方法
* 不支持添加类文件热加载，建议开发者在 IDEA 下使用 jrebel 或者 maven 下的 jetty
* 插件支持列为完全的热加载
*/
public class JettyServerForIDEA implements IServer { private String webAppDir;
private int port;
private String context;
// private int scanIntervalSeconds;
private boolean running = false;
private Server server;
private WebAppContext webApp; public JettyServerForIDEA(String webAppDir, int port, String context) {
if (webAppDir == null) {
throw new IllegalStateException("Invalid webAppDir of web server: " + webAppDir);
}
if (port < 0 || port > 65535) {
throw new IllegalArgumentException("Invalid port of web server: " + port);
}
if (StrKit.isBlank(context)) {
throw new IllegalStateException("Invalid context of web server: " + context);
} this.webAppDir = webAppDir;
this.port = port;
this.context = context;
// this.scanIntervalSeconds = scanIntervalSeconds;
} public void start() {
if (!running) {
try {
running = true;
doStart();
} catch (Exception e) {
System.err.println(e.getMessage());
//LogKit.error(e.getMessage(), e);
}
}
} public void stop() {
if (running) {
try {server.stop();} catch (Exception e) {
//LogKit.error(e.getMessage(), e);
System.err.println(e.getMessage());
}
running = false;
}
} private void doStart() {
if (!available(port)) {
throw new IllegalStateException("port: " + port + " already in use!");
}
deleteSessionData();
System.out.println("Starting Jetty ...... ");
server = new Server();
SelectChannelConnector connector = new SelectChannelConnector();
connector.setPort(port);
server.addConnector(connector);
webApp = new WebAppContext();
webApp.setThrowUnavailableOnStartupException(true); // 在启动过程中允许抛出异常终止启动并退出 JVM
webApp.setContextPath(context);
String rootPath = PathKit.getWebRootPath();
System.out.println(rootPath);
String webDir = rootPath + "/" + webAppDir;
//webApp.setDescriptor(webDir + "/WEB-INF/web.xml");
webApp.setResourceBase(webDir); // webApp.setWar(webAppDir);
//postStart(webApp);
webApp.setWelcomeFiles(new String[]{"/index.do"});
webApp.setInitParameter("org.eclipse.jetty.servlet.Default.dirAllowed", "false");
webApp.setInitParameter("org.eclipse.jetty.servlet.Default.useFileMappedBuffer", "false"); // webApp.setInitParams(Collections.singletonMap("org.mortbay.jetty.servlet.Default.useFileMappedBuffer", "false"));
persistSession(webApp); server.setHandler(webApp);
try {
System.out.println("Starting web server on port: " + port);
server.start();
System.out.println("Starting Complete. Welcome To The Jetty :)");
server.join();
} catch (Exception e) {
//LogKit.error(e.getMessage(), e);
System.err.println(e.getMessage());
System.exit(100);
}
return;
}
private void postStart(WebAppContext root){
/**spring内部过滤器代理 里面包含了默认的11个过滤器 这里的初始化参数可以直接些spring的bean名称*/
FilterHolder filterHolder=new FilterHolder(DelegatingFilterProxy.class);
filterHolder.setName("springSecurityFilterChain");
root.addFilter(filterHolder, "/*", EnumSet.of(DispatcherType.REQUEST));
} private void deleteSessionData() {
try {
FileKit.delete(new File(getStoreDir()));
}
catch (Exception e) {
//LogKit.logNothing(e);
System.err.println(e.getMessage());
}
} private String getStoreDir() {
String storeDir = PathKit.getWebRootPath() + "/../../session_data" + context;
if ("\\".equals(File.separator)) {
storeDir = storeDir.replaceAll("/", "\\\\");
}
return storeDir;
} private void persistSession(WebAppContext webApp) {
String storeDir = getStoreDir(); SessionManager sm = webApp.getSessionHandler().getSessionManager();
if (sm instanceof HashSessionManager) {
try {
((HashSessionManager)sm).setStoreDirectory(new File(storeDir));
} catch (Exception e) {
e.printStackTrace();
}
return ;
} HashSessionManager hsm = new HashSessionManager();
try {
hsm.setStoreDirectory(new File(storeDir));
} catch (Exception e) {
e.printStackTrace();
}
SessionHandler sh = new SessionHandler();
sh.setSessionManager(hsm);
webApp.setSessionHandler(sh);
} private static boolean available(int port) {
if (port <= 0) {
throw new IllegalArgumentException("Invalid start port: " + port);
} ServerSocket ss = null;
DatagramSocket ds = null;
try {
ss = new ServerSocket(port);
ss.setReuseAddress(true);
ds = new DatagramSocket(port);
ds.setReuseAddress(true);
return true;
} catch (IOException e) {
//LogKit.logNothing(e);
System.err.println(e.getMessage());
} finally {
if (ds != null) {
ds.close();
} if (ss != null) {
try {
ss.close();
} catch (IOException e) {
// should not be thrown, just detect port available.
// LogKit.logNothing(e);
System.err.println(e.getMessage());
}
}
}
return false;
}
}

package com.train.simulate.web.server; public interface IServer {
void start();
void stop();
}