学完微型服务器（Tomcat）对其工作流程的理解，自己着手写个简单的tomcat

以你之姓@ 2021-12-22 13:57 133阅读 0赞

# 学完微型服务器（Tomcat）对其工作流程的理解，自己着手写个简单的tomcat #

####                                                                                                                               ####

### ###

####                                                                                                                                                                                       2019-05-09   19:28:42  ####

注：项目(MyEclipse)创建的时候选择：Web Service Project

## 第一步 对Tomcat工作流程进行分析 ##

![1652870-20190509192649498-109444630.png][]

## 第二步 对其项目进行全局的把关 ##

首先看看Project(FirstTomcat)的目录结构

|-FirstTomcat

|——src

|   |-org.mrzhangxd.com

|     |-FirstRequest.java

|     |-FirstResponse.java

|     |-FirstServlet.java

|     |-FirstTomcat.java

|     |-FirstServletMapping.java

|     |\_FirstServletMappingConfig.java

|   |-JRE System Library\[JavaSE-x.y\]

|   |-JAXB x.y.z Libraries

|   |-JavaEE x.y Generic Library

|   |-JSTL x.y.z Library

|   |-JAX-RS x.y Libraries(Project Jersey x.y)

|\_\_\_|\_WebRoot

## 第三步 代码实现 ##

处理请求：

1.  1.  创建一个request对象并填充那些有可能被所引用的Servlet使用的信息，如参数，头部、cookies、查询字符串等。
    2.  创建一个response对象，所引用的servlet使用它来给客户端发送响应。
    3.  调用servlet的service方法，并传入request和response对象。这里servlet会从request对象取值，给response写值。
    4.  根据servlet返回的response生成相应的HTTP响应报文。

接下来一一实现

请求：FirstRequest.java

回应：FirstResponse.java

Servlet请求处理基类：FirstServlet.java

下一步servlet配置：FirstServletMapping.java

其他配置：FirstServletMappingConfig.java

核心处理类：FirstTomcat.java,处理流程如下：

1)   提供Socket服务

2)   封装请求/响应对象

3)   将不同的请求映射到具体的Servlet处理

这里重点说的是，要利用 ServerSocket 通过服务器上的端口通信 以及 accpt方法一直等待客户端的请求

<table style="margin-left:60px;"> 
 <tbody style="margin-left:60px;"> 
 <tr style="margin-left:60px;"> 
 <td style="margin-left:60px;"> package org.mrzhangxd.com; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; import java.util.HashMap; import java.util.Map; /** &nbsp;* &nbsp;* @author mrzhangxd &nbsp;* &nbsp;*/ public class FirstTomcat { &nbsp;&nbsp;&nbsp; private Integer port = 8080;&nbsp;&nbsp;&nbsp;&nbsp; //定义8080端口&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; private Map&lt;String, String&gt; urlServletMapping = new HashMap&lt;&gt;();&nbsp;&nbsp;&nbsp; //存储url和对应的类 &nbsp;&nbsp;&nbsp; public FirstTomcat(Integer port) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; super(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.port = port; &nbsp;&nbsp;&nbsp; }&nbsp; &nbsp;&nbsp;&nbsp; @SuppressWarnings("resource") &nbsp;&nbsp;&nbsp; public void start() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; initServletMapping();&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ServerSocket serverSocket = null;&nbsp;&nbsp;&nbsp;&nbsp; //实例化一个 ServerSocket 对象，表示通过服务器上的端口通信 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; serverSocket = new ServerSocket(port);&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("MyTomcat is starting..."); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; while(true) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Socket socket = serverSocket.accept();&nbsp;&nbsp;&nbsp;&nbsp; //服务器调用 ServerSocket 类的 accept() 方法，该方法将一直等待，直到客户端连接到服务器上给定的端口 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; InputStream inputStream = socket.getInputStream(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; OutputStream outputStream = socket.getOutputStream();&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; FirstRequest myRequest = new FirstRequest(inputStream); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; FirstResponse myResponse = new FirstResponse (outputStream);&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; dispatch(myRequest, myResponse);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; socket.close();&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }catch(Exception e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; //初始化映射 &nbsp;&nbsp;&nbsp; public void initServletMapping() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for(FirstServletMapping servletMapping : FirstServletMappingConfig.servletMappingList) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; urlServletMapping.put(servletMapping.getUrl(), servletMapping.getClazz()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; //分发请求 &nbsp;&nbsp;&nbsp; @SuppressWarnings("unchecked") &nbsp;&nbsp;&nbsp; public void dispatch(FirstRequest firstRequest, FirstResponse firstResponse) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String clazz = urlServletMapping.get(firstRequest.getUrl());&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Class&lt;FirstServlet&gt; firstServletClass = (Class&lt;FirstServlet&gt;)Class.forName(clazz); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; FirstServlet firstservlet = firstServletClass.newInstance(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; firstservlet.service(firstRequest, firstResponse); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }catch(ClassNotFoundException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }catch(InstantiationException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }catch(IllegalAccessException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public static void main(String[] args) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; FirstTomcat myTomcat = new FirstTomcat(8080); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; myTomcat.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } } </td> 
 </tr> 
 </tbody> 
</table>

测试类按照上面类里的注释自己解决，测试结果略。

注：

编码格式、注释都参考《代码整洁之道》

转载于:https://www.cnblogs.com/MrZhangxd/p/10840519.html

[1652870-20190509192649498-109444630.png]: /images/20211220/15831eb082ec48d9a99c3f17c58ea906.png