Jetty非常适合做嵌入式web开发,正如Jetty的口号"Don’t deploy your application in Jetty, deploy Jetty in your application!"。
这个简单的例子是使用Jetty提供文件下载:
首先pom.xml配置文件如下
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.luangeng</groupId> <artifactId>jettydownload</artifactId> <version>1.0-SNAPSHOT</version> <packaging>jar</packaging> <name>jettydownload</name> <url>http://maven.apache.org</url> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <jetty.version>8.1.9.v20130131</jetty.version> </properties> <dependencies> <!-- jetty --> <dependency> <groupId>org.eclipse.jetty.aggregate</groupId> <artifactId>jetty-webapp</artifactId> <version>${jetty.version}</version> </dependency> <dependency> <groupId>org.eclipse.jetty</groupId> <artifactId>jetty-jsp</artifactId> <version>${jetty.version}</version> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>3.8.1</version> <scope>test</scope> </dependency> </dependencies> </project>
---
main方法启动Jetty:
package com.luangeng;
import org.eclipse.jetty.server.Connector;
import org.eclipse.jetty.server.Handler;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.server.handler.DefaultHandler;
import org.eclipse.jetty.server.handler.HandlerCollection;
import org.eclipse.jetty.server.nio.SelectChannelConnector;
import org.eclipse.jetty.servlet.ServletContextHandler;
import org.eclipse.jetty.webapp.WebAppContext;
public class App
{
public static void main( String[] args ) throws Exception {
Server server = new Server();
server.setStopAtShutdown(true);
SelectChannelConnector connector = new SelectChannelConnector();
connector.setPort(8080);
connector.setReuseAddress(true);
server.setConnectors(new Connector[] { connector });
ServletContextHandler context = new ServletContextHandler();
context.setContextPath("/lg");
context.addServlet(DownLoadServlet.class, "/download");
context.addServlet(TestServlet.class, "/test/*");
HandlerCollection handlers = new HandlerCollection();
handlers.setHandlers(new Handler[] { context, new DefaultHandler() });
server.setHandler(handlers);
server.start();
server.join();
}
}
---
提供简单的测试 TestServlet.java
package com.luangeng; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.io.PrintWriter; /** * Created by LG. */ public class TestServlet extends HttpServlet { public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { response.setContentType("text/html"); PrintWriter out = response.getWriter(); out.println("<HTML>"); out.println("<HEAD><TITLE>test</TITLE></HEAD>"); out.println("<BODY>"); out.println("GET method"); out.println("</BODY>"); out.println("</HTML>"); out.flush(); out.close(); } public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { response.setContentType("text/html"); PrintWriter out = response.getWriter(); out.println("<HTML>"); out.println("<HEAD><TITLE>test</TITLE></HEAD>"); out.println("<BODY>"); out.println("POST method"); out.println("</BODY>"); out.println("</HTML>"); out.flush(); out.close(); } }
---
完成下载功能的Servlet:
DownloadServlet.java
package com.luangeng; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.*; import java.net.URLEncoder; /** * Created by LG. */ public class DownLoadServlet extends HttpServlet { public void doGet(HttpServletRequest request, HttpServletResponse response) { //PrintWriter pw = null; FileInputStream in = null; OutputStream outs = null; //String path = request.getParameter("filepath"); String path = "/Users/LG/test.txt"; //path = new String(fileName.getBytes("iso8859-1"),"UTF-8"); try { File file = new File(path); if(!file.exists()) { response.setStatus(404); //pw.println("file not found!"); //request.getRequestDispatcher("/err.jsp").forward(request, response); return; } response.setContentType("text/html"); String realname = path.substring(path.indexOf("/")+1); response.setHeader("content-disposition", "attachment;filename=" + URLEncoder.encode(realname, "UTF-8")); in = new FileInputStream(path); outs = response.getOutputStream(); byte buffer[] = new byte[1024]; int len = 0; while ((len = in.read(buffer)) > 0) { outs.write(buffer, 0, len); } System.out.println(response.getStatus()); } catch(Exception e) { //pw.println(e.getMessage()); response.setStatus(300); //log } finally { response.setStatus(200); try { if(outs != null) { outs.flush(); outs.close(); } if(in != null) { in.close(); } } catch (IOException e) { } // if(pw!=null) { // pw.flush(); // pw.close(); // } } } public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { doGet(request, response); } }
---
浏览器访问网址 http://localhost:8080/lg/download 即可看到下载
end