1计维、類圖

image.png

2财异、處理過程（以Wrapper為例）

在連接器部分了解到，對于客戶端的處理婉称，連接器是在解析相關(guān)的協(xié)議后踩寇，最終調(diào)用了Container的invoke方法來處理的，這里看一下Wrapper的處理過程，Wrapper的標準實現(xiàn)為StandardWrapper：

public StandardWrapper() {
        super();
        // 設置基本的 Value
        pipeline.setBasic(new StandardWrapperValve());
    }

根據(jù)類圖可知，invoke方法在ContainerBase中實現(xiàn)：

protected Pipeline pipeline = new StandardPipeline(this);

public void invoke(Request request, Response response)
        throws IOException, ServletException {
        pipeline.invoke(request, response);
    }

其調(diào)用了Pipeline的invoke方法：

public void invoke(Request request, Response response)
        throws IOException, ServletException {
        // Invoke the first Valve in this pipeline for this request
        (new StandardPipelineValveContext()).invokeNext(request, response);
    }

protected class StandardPipelineValveContext implements ValveContext {

        protected int stage = 0;

        public void invokeNext(Request request, Response response)
            throws IOException, ServletException {

            int subscript = stage;// 下標
            stage = stage + 1;// 級別

            // Invoke the requested Valve for the current request thread
            if (subscript < valves.length) {
                valves[subscript].invoke(request, response, this);
            } else if ((subscript == valves.length) && (basic != null)) {
                basic.invoke(request, response, this);
            } else {
                throw new ServletException
                    (sm.getString("standardPipeline.noValve"));
            }
        }
}

以ClientIPLoggerValve為例：

public void invoke(Request request, Response response, ValveContext valveContext)
    throws IOException, ServletException {
    // Pass this request on to the next valve in our pipeline
// 這里先調(diào)用了ValveContext的invokeNext方法
    valveContext.invokeNext(request, response);
// 然后才是處理自己的邏輯
    System.out.println("Client IP Logger Valve");
    ServletRequest sreq = request.getRequest();
    System.out.println(sreq.getRemoteAddr());
    System.out.println("------------------------------------");
  }

每一個Pipeline維持著一個基本的Valve和一個Valve[]草丧，Valve通過addValve()方法加入到pipeline中，當Container的invoke被Connector調(diào)用的時候莹桅，Container內(nèi)部調(diào)用了pipeline的invoke方法昌执，而pipeline內(nèi)部則是通過ValveContext的invokeNext方法來實現(xiàn)Valve的依次執(zhí)行，根據(jù)每個Valve的內(nèi)部實現(xiàn)统翩，這里的執(zhí)行順序為basic valve會被優(yōu)先執(zhí)行，然后其他的Valve是按照后進先出的順序執(zhí)行此洲，這個從Valve中的invoke方法實現(xiàn)也可以驗證厂汗，每個Valve在執(zhí)行前都是先執(zhí)行了ValveContext的invokeNext方法。

// 構(gòu)建一個包裝容器呜师，一個包裝容器代表一個具體的servlet
    Wrapper wrapper = new SimpleWrapper();
    wrapper.setServletClass("ModernServlet");
    // 構(gòu)建兩個Valve
    Valve valve1 = new HeaderLoggerValve();
    Valve valve2 = new ClientIPLoggerValve();
    // 添加閥門（任務）
    ((Pipeline) wrapper).addValve(valve1);
    ((Pipeline) wrapper).addValve(valve2);

Basic Valve:

public void invoke(Request request, Response response, ValveContext valveContext)
    throws IOException, ServletException {
    System.out.println("00000000000 SimpleWrapperValve Basic Valve ");
    SimpleWrapper wrapper = (SimpleWrapper) getContainer();
    ServletRequest sreq = request.getRequest();
    ServletResponse sres = response.getResponse();
    Servlet servlet = null;
    HttpServletRequest hreq = null;
    if (sreq instanceof HttpServletRequest)
      hreq = (HttpServletRequest) sreq;
    HttpServletResponse hres = null;
    if (sres instanceof HttpServletResponse)
      hres = (HttpServletResponse) sres;
    // Allocate a servlet instance to process this request
    try {
      servlet = wrapper.allocate();
      if (hres!=null && hreq!=null) {
        servlet.service(hreq, hres);
      }
      else {
        servlet.service(sreq, sres);
      }
    }
    catch (ServletException e) {
    }
  }

#######Basic Valve被優(yōu)先執(zhí)行
00000000000 SimpleWrapperValve Basic Valve 
ModernServlet -- init
#######Client IP Logger Valve被執(zhí)行
00000000000 Client IP Logger Valve
0:0:0:0:0:0:0:1
------------------------------------
#######Header Logger Valve被執(zhí)行
00000000000 Header Logger Valve
host:localhost:8080
connection:keep-alive
upgrade-insecure-requests:1
user-agent:Mozilla/5.0 (Windows NT 10.0; WOW64) ...
accept:text/html,application/xhtml+xml,application/xml;...
accept-encoding:gzip, deflate, br
accept-language:zh-CN,zh;q=0.9,en;q=0.8
------------------------------------

3娶桦、多Wrapper容器處理

在tomcat4中，如果包含多個wrapper容器汁汗，這時需要一個mapper來處理這些wrapper

HttpConnector connector = new HttpConnector();
    // wrapper 1
    Wrapper wrapper1 = new SimpleWrapper();
    wrapper1.setName("Primitive");
    wrapper1.setServletClass("PrimitiveServlet");
    // wrapper 2
    Wrapper wrapper2 = new SimpleWrapper();
    wrapper2.setName("Modern");
    wrapper2.setServletClass("ModernServlet");
    // context
    Context context = new SimpleContext();
    // wrapper add to context
    context.addChild(wrapper1);
    context.addChild(wrapper2);
    // create 2 Valve
    Valve valve1 = new HeaderLoggerValve();
    Valve valve2 = new ClientIPLoggerValve();
    // 閥門加入到了Context容器中
    ((Pipeline) context).addValve(valve1);
    ((Pipeline) context).addValve(valve2);
    // create a mapper
    Mapper mapper = new SimpleContextMapper();
    // set protocol
    mapper.setProtocol("http");
    // add mapper to context
    context.addMapper(mapper);
    Loader loader = new SimpleLoader();
    context.setLoader(loader);
    // context.addServletMapping(pattern, name);
    context.addServletMapping("/Primitive", "Primitive");
    context.addServletMapping("/Modern", "Modern");
    connector.setContainer(context);

Basic Valve:

public void invoke(Request request, Response response, ValveContext valveContext)
    throws IOException, ServletException {
    // Validate the request and response object types
    if (!(request.getRequest() instanceof HttpServletRequest) ||
      !(response.getResponse() instanceof HttpServletResponse)) {
      return;     // NOTE - Not much else we can do generically
    }

    // Disallow any direct access to resources under WEB-INF or META-INF
    HttpServletRequest hreq = (HttpServletRequest) request.getRequest();
    String contextPath = hreq.getContextPath();
    String requestURI = ((HttpRequest) request).getDecodedRequestURI();
    String relativeURI =
      requestURI.substring(contextPath.length()).toUpperCase();

    Context context = (Context) getContainer();
    // Select the Wrapper to be used for this Request
    Wrapper wrapper = null;
    try {
// ##############1衷畦、從context中獲取一個wrapper
      wrapper = (Wrapper) context.map(request, true);
    }
    catch (IllegalArgumentException e) {
      badRequest(requestURI, (HttpServletResponse) response.getResponse());
      return;
    }
    if (wrapper == null) {
      notFound(requestURI, (HttpServletResponse) response.getResponse());
      return;
    }
    // Ask this Wrapper to process this Request
    response.setContext(context);
//  ##############2、調(diào)用wrapper的invoke方法
    wrapper.invoke(request, response);
  }

看一下Context是如何找wrapper的：

public Container map(Request request, boolean update) {
    //this method is taken from the map method in org.apache.cataline.core.ContainerBase
    //the findMapper method always returns the default mapper, if any, regardless the
    //request's protocol
// 根據(jù)協(xié)議來找到對應的Mapper
    Mapper mapper = findMapper(request.getRequest().getProtocol());
    if (mapper == null)
      return (null);
    // Use this Mapper to perform this mapping
// 然后從Mapper中來找到wrapper
    return (mapper.map(request, update));
  }

Mapper查找wrapper過程

public Container map(Request request, boolean update) {
    // Identify the context-relative URI to be mapped
    String contextPath =
      ((HttpServletRequest) request.getRequest()).getContextPath();
    String requestURI = ((HttpRequest) request).getDecodedRequestURI();
    String relativeURI = requestURI.substring(contextPath.length());
    // Apply the standard request URI mapping rules from the specification
    Wrapper wrapper = null;
    String servletPath = relativeURI;
    String pathInfo = null;
// 找到servlet的名稱
    String name = context.findServletMapping(relativeURI);
    if (name != null)
// 根據(jù)名稱來找wrapper知牌，在tomcat中祈争，一個wrapper對應一個servlet
      wrapper = (Wrapper) context.findChild(name);
    return (wrapper);
  }

總的過程就是根據(jù)協(xié)議先找到Mapper，然后再根據(jù)servlet name找到wrapper角寸。