HttpServer
package com.whatsmars.tomcat.servlet; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; /** * Created by shenhongxi on 16/3/21. */ public class HttpServer { private static final String SHUTDOWN_COMMAND = "/SHUTDOWN"; private boolean shutdown = false; public static void main(String[] args) { HttpServer server = new HttpServer(); server.await(); } private void await() { ServerSocket serverSocket = null; int port = 8080; try { serverSocket = new ServerSocket(port, 1, InetAddress.getByName("127.0.0.1")); System.out.println("Server started!"); } catch (IOException e) { e.printStackTrace(); System.exit(1); } while (!shutdown) { Socket socket = null; InputStream input = null; OutputStream output = null; try { socket = serverSocket.accept(); input = socket.getInputStream(); output = socket.getOutputStream(); Request request = new Request(input); request.parse(); Response response = new Response(output); response.setRequest(request); // check if this is a request for a servlet or a static resource if (request.getUri().startsWith("/servlet/")) { ServletProcessor processor = new ServletProcessor(); processor.process(request, response); } else { StaticResourceProcessor processor = new StaticResourceProcessor(); processor.process(request, response); } socket.close(); shutdown = request.getUri().equals(SHUTDOWN_COMMAND); } catch (Exception e) { e.printStackTrace(); continue; } } } }
Request
package com.whatsmars.tomcat.servlet; import javax.servlet.*; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.UnsupportedEncodingException; import java.util.Enumeration; import java.util.Locale; import java.util.Map; /** * Created by shenhongxi on 16/3/21. */ public class Request implements ServletRequest { private InputStream input; private String uri; // 性能考虑,用byte[] public Request(InputStream input) { this.input = input; } public void parse() { StringBuffer request = new StringBuffer(2048); int i; byte[] buffer = new byte[2048]; try { i = input.read(buffer); } catch (IOException e) { e.printStackTrace(); i = -1; } for (int j = 0; j < i; j++) { request.append((char) buffer[j]); } System.out.println(request.toString()); uri = parseUri(request.toString()); } private String parseUri(String requestStr) { // GET /index.html HTTP/1.1 // Accept: text/plain; text/html // ... int index1 = requestStr.indexOf(' '); int index2; if (index1 != -1) { index2 = requestStr.indexOf(' ', index1 + 1); if (index2 > index1) { return requestStr.substring(index1 + 1, index2); } } return null; } public String getUri() { return uri; } public Object getAttribute(String name) { return null; } public Enumeration<String> getAttributeNames() { return null; } public String getCharacterEncoding() { return null; } public void setCharacterEncoding(String env) throws UnsupportedEncodingException { } public int getContentLength() { return 0; } }
Response
package com.whatsmars.tomcat.servlet; import javax.servlet.ServletOutputStream; import javax.servlet.ServletResponse; import java.io.*; import java.util.Locale; /** * Created by shenhongxi on 16/3/21. */ public class Response implements ServletResponse { private static final int BUFFER_SIZE = 1024; Request request; OutputStream output; PrintWriter writer; public void sendStaticResource() throws IOException { byte[] bytes = new byte[BUFFER_SIZE]; FileInputStream fis = null; try { File file = new File(Constants.WEB_ROOT, request.getUri()); if (file.exists()) { fis = new FileInputStream(file); int ch = fis.read(bytes, 0, BUFFER_SIZE); while (ch != -1) { output.write(bytes, 0, ch); ch = fis.read(bytes, 0, BUFFER_SIZE); } } else { String errorMsg = "HTTP/1.1 404 File Not Found\r\n" + "Content-Type: text/html\r\n" + "Content-Length: 23\r\n" + "\r\n" + "<h1>File Not Found</h1>"; output.write(errorMsg.getBytes()); } } catch (Exception e) { e.printStackTrace(); } finally { if (fis != null) { fis.close(); } } } public Response(OutputStream output) { this.output = output; } public void setRequest(Request request) { this.request = request; } public String getCharacterEncoding() { return null; } public String getContentType() { return null; } public ServletOutputStream getOutputStream() throws IOException { return null; } public PrintWriter getWriter() throws IOException { // autoflush is true, println() will flush, but print() will not writer = new PrintWriter(output, true); return writer; } }
RequestFacade
package com.whatsmars.tomcat.servlet; import javax.servlet.*; import java.io.BufferedReader; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.util.Enumeration; import java.util.Locale; import java.util.Map; /** * Created by shenhongxi on 2016/4/12. */ public class RequestFacade implements ServletRequest { private ServletRequest request; public RequestFacade(Request request) { this.request = request; } public Object getAttribute(String name) { return request.getAttribute(name); } public Enumeration<String> getAttributeNames() { return request.getAttributeNames(); } }
ResponseFacade
package com.whatsmars.tomcat.servlet; import javax.servlet.ServletOutputStream; import javax.servlet.ServletResponse; import java.io.IOException; import java.io.PrintWriter; import java.util.Locale; /** * Created by shenhongxi on 2016/4/12. */ public class ResponseFacade implements ServletResponse { private ServletResponse response; public ResponseFacade(Response response) { this.response = response; } public String getCharacterEncoding() { return response.getCharacterEncoding(); } public String getContentType() { return null; } public ServletOutputStream getOutputStream() throws IOException { return null; } public PrintWriter getWriter() throws IOException { return response.getWriter(); } }
ServletProcessor
package com.whatsmars.tomcat.servlet; import javax.servlet.Servlet; import javax.servlet.ServletRequest; import javax.servlet.ServletResponse; import java.io.File; import java.io.IOException; import java.net.URL; import java.net.URLClassLoader; import java.net.URLStreamHandler; /** * Created by shenhongxi on 2016/4/12. */ public class ServletProcessor { public void process(Request request, Response response) { String uri = request.getUri(); String servletName = uri.substring(uri.lastIndexOf("/") + 1); URLClassLoader loader = null; try { URL[] urls = new URL[1]; URLStreamHandler streamHandler = null; File classPath = new File(Constants.WEB_ROOT); String repository = (new URL("file", null, classPath.getCanonicalPath() + File.separator)).toString(); urls[0] = new URL(null, repository, streamHandler); loader = new URLClassLoader(urls); } catch (IOException E) { E.printStackTrace(); } Class myClass = null; try { myClass = loader.loadClass(servletName); } catch (ClassNotFoundException e) { e.printStackTrace(); } Servlet servlet = null; try { servlet = (Servlet) myClass.newInstance(); RequestFacade requestFacade = new RequestFacade(request); ResponseFacade responseFacade = new ResponseFacade(response); // 为了安全考虑,除了实现ServletRequest/ServletResponse的方法, // Request/Response中的其他公共方法需对servlet隐藏,所以用外观类 servlet.service((ServletRequest) requestFacade, (ServletResponse) responseFacade); } catch (Exception e) { e.printStackTrace(); } catch (Throwable e) { e.printStackTrace(); } } }
StaticResourceProcessor
package com.whatsmars.tomcat.servlet; import java.io.IOException; /** * Created by shenhongxi on 2016/4/12. */ public class StaticResourceProcessor { public void process(Request request, Response response) { try { response.sendStaticResource(); } catch (IOException e) { e.printStackTrace(); } } }
PrimitiveServlet
package com.whatsmars.tomcat.servlet; import javax.servlet.*; import java.io.IOException; import java.io.PrintWriter; /** * Created by shenhongxi on 2016/4/12. */ public class PrimitiveServlet implements Servlet { public void init(ServletConfig config) throws ServletException { System.out.println("init"); } public ServletConfig getServletConfig() { return null; } public void service(ServletRequest req, ServletResponse res) throws ServletException, IOException { System.out.println("from service"); PrintWriter out = res.getWriter(); out.println("Hello. Roses are red."); out.print("Violets are blue"); } public String getServletInfo() { return null; } public void destroy() { System.out.println("destroy"); } }
Constants
package com.whatsmars.tomcat.servlet; import java.io.File; /** * Created by shenhongxi on 2016/4/12. */ public class Constants { public static final String WEB_ROOT = System.getProperty("user.dir") + File.separator + "whatsmars-tomcat/src/main/webapp"; // 资源文件,class文件等 }
相关推荐
简单的servlet容器实现
《深入剖析Tomcat》书中第二章代码,在此基础上做了修改详细请参考博客https://blog.csdn.net/TYOUKAI_/article/details/88540763
主要为大家详细介绍了基于Java web服务器简单实现一个Servlet容器,感兴趣的小伙伴们可以参考一下
这是Servlet过滤器的初始化方法,Servlet容器创建Servlet过滤器实例后将调用这个方法。在这个方法中可以读取web.xml文件中Servlet过滤器的初始化参数。 b、doFilter(ServletRequest,ServletResponse,FilterChain)...
NULL 博文链接:https://ruyi574812039.iteye.com/blog/2113545
JavaServletAPI提供了一个简单的接口,通过这个接口,Servlet引擎可以有效地跟踪用户的会话。 建立Session 因为HTTP是一个请求-响应协议,一个会话在客户机加入之前会被认为是一个新的会话。加入的意思是返回会话...
上篇博客介绍了一下嵌入式Servlet容器怎么修改它的默认属性值,这篇博客简单记录一下嵌入式Servlet容器它是怎么帮我们配置的,以及我们自定义它的属性时,它又是怎么运转的? 说起自动配置,我们现在应该不陌生了,...
Spring MVC是一个基于Servlet容器的Web应用框架,这里的Servlet容器通常指Tomcat等服务容器。Servlet容器会负责监听端口消息并映射为Request/Response对象,然后交给Servlet实例去处理。SpringMVC框架的作用核心就是...
用于创建Clojure友好servlet容器接口的填充程序。 基本原理 java servlet api不适合与clojure编程语言一起使用; 首先,它需要对命名类的引用,这将类生成构造和项目的编译步骤强加给项目。 其次,它传递java对象而...
《servlet和jsp学习指南》共18章:第1章介绍servlet api和几个简单的servlet;第2章讨论session追踪,以及保持状态的4种技术;第3章和第4章系统讲解jsp的语法以及jsp中的重要特性之一:expression language;第5~7章...
简单来说,客户端发送请求,传递到servlet容器,而servlet将数据转换成服务器端可以处理的数据再发送给服务器端,再数据处理之后,再传递到servlet容器,servlet再转译到客户端,完成了一次客户端和服务器端的信息...
《架构探险:从零开始写Java Web框架》首先从一个简单的 Web 应用开始,让读者学会如何使用 IDEA、Maven、Git 等开发工具搭建 Java Web 应用;接着通过一个简单的应用场景,为该 Web 应用添加若干业务功能,从需求...
该博客系统是一个基于Servlet技术开发的Web应用,旨在提供一个简单而功能完备的博客平台。用户可以注册账户、发布博客文章。整个系统使用Java Servlet技术作为后端处理逻辑,并采用MVC(Model-View-Controller)架构...
1.2 什么是 Servlet 容器?...............................................................................................................................13 1.3 例子 .......................................
在Java Web程序开发中,由于...在实际的开发过程中,如果通过每一个业务处理指定中文字符集编码,则操作过于繁琐,而且容易遗漏某一个业务中的字符编码设置;如果通过过滤器来处理字符编码,就可以做到简单又万无一失。
使用 Servlet 来计算这些点击量是非常简单的,因为一个 Servlet 的生命周期是由它运行所在的容器控制的。 以下是实现一个简单的基于 Servlet 生命周期的网页点击计数器需要采取的步骤: 在 init() 方法中初始化一个...
多层次分布式应用模型是指根据功能把应用逻辑分成多个层次,每个层次支持相应的服务器和组件,组件在分布式服务器的组件容器中运行(如Servlet组件在Servlet容器上运行,EJB组件在EJB容器上运行),容器间通过相关的...