jetty嵌入Web编程多种实现方式案例

package jettyweb4; import java.io.FileNotFoundException; import java.io.IOException; import org.apache.commons.lang.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.eclipse.jetty.server.Handler; import org.eclipse.jetty.server.Server; import org.eclipse.jetty.server.handler.ContextHandlerCollection; import org.eclipse.jetty.server.handler.DefaultHandler; import org.eclipse.jetty.server.handler.HandlerCollection; import org.eclipse.jetty.server.handler.RequestLogHandler; import org.eclipse.jetty.webapp.WebAppContext; import org.eclipse.jetty.xml.XmlConfiguration; import org.eclipse.jetty.server.NCSARequestLog; import org.xml.sax.SAXException; /** * 总的服务类，本质上是一个分发器。使用jetty.xml配置。是通过继承server实现的。 * 还有一个总的日志记录器。 * @author Administrator * */ public class JettyCustomServer extends Server { private String xmlConfigPath; private String contextPath; private String warPath; private String resourceBase = "src/main/webapp"; private String webXmlPath = "src/main/webapp/WEB-INF/web.xml"; private String webDefault = "jetty/contexts/webdefault.xml"; private String logPath = "target/jetty-yyyy_mm_dd.request.log"; private static final Log log = LogFactory.getLog(JettyCustomServer.class); public JettyCustomServer(String xmlConfigPath, String contextPath, String resourceBase, String webXmlPath, String warPath) { super(); if (StringUtils.isNotBlank(xmlConfigPath)) { this.xmlConfigPath = xmlConfigPath; readXmlConfig(); } if (StringUtils.isNotBlank(warPath)) { this.warPath = warPath; if (StringUtils.isNotBlank(contextPath)) { this.contextPath = contextPath; applyHandle(true); } } else { if (StringUtils.isNotBlank(resourceBase)) this.resourceBase = resourceBase; if (StringUtils.isNotBlank(webXmlPath)) this.webXmlPath = webXmlPath; if (StringUtils.isNotBlank(contextPath)) { this.contextPath = contextPath; applyHandle(false); } } } private void readXmlConfig() { try { XmlConfiguration configuration = new XmlConfiguration(JettyCustomServer.class .getClassLoader().getResourceAsStream(this.xmlConfigPath)); configuration.configure(this); } catch (FileNotFoundException e1) { e1.printStackTrace(); } catch (SAXException e1) { e1.printStackTrace(); } catch (IOException e1) { e1.printStackTrace(); } catch (Exception e) { e.printStackTrace(); } } public void applyHandle(Boolean warDeployFlag) { ContextHandlerCollection handler = new ContextHandlerCollection(); WebAppContext webapp = new WebAppContext(); webapp.setContextPath(contextPath); webapp.setDefaultsDescriptor(webDefault); if (!warDeployFlag) { webapp.setResourceBase(resourceBase); webapp.setDescriptor(webXmlPath); } else { webapp.setWar(warPath); } handler.addHandler(webapp); //日志记录, 定义一个handlers集合； HandlerCollection handlers = new HandlerCollection(); ContextHandlerCollection Context = new ContextHandlerCollection(); RequestLogHandler requestLogHandler = new RequestLogHandler(); handlers.setHandlers(new Handler[]{Context,new DefaultHandler(),requestLogHandler}); NCSARequestLog requestLog = new NCSARequestLog(logPath); requestLog.setRetainDays(90); requestLog.setAppend(true); requestLog.setExtended(false); requestLog.setLogTimeZone("GMT"); requestLogHandler.setRequestLog(requestLog); //yaohc 集合中添加日志处理。 //getServer().setHandler(handlers); handlers.addHandler(handler); /////////// //yao_修改：传入一个handler集合，之前是传递一个handler //super.setHandler(handler); super.setHandler(handlers); } public void startServer() { try { log.debug("启动。。。。"); super.start(); System.out.println("current thread:" + super.getThreadPool().getThreads() + "| idle thread:" + super.getThreadPool().getIdleThreads()); super.join(); } catch (Exception e) { e.printStackTrace(); } } }