spring boot 启动 Spring Boot启动过程（六）之内嵌Tomcat中StandardHost、StandardContext和StandardWrapper的启动教程详解

// Start our child containers, if any
  Container children[] = findChildren();
  List<Future<Void>> results = new ArrayList<>();
  for (int i = 0; i < children.length; i++) {
   results.add(startStopExecutor.submit(new StartChild(children[i])));
  }
  boolean fail = false;
  for (Future<Void> result : results) {
   try {
    result.get();
   } catch (Exception e) {
    log.error(sm.getString("containerBase.threadedStartFailed"), e);
    fail = true;
   }
  }
  if (fail) {
   throw new LifecycleException(
     sm.getString("containerBase.threadedStartFailed"));
  }

 private static class StartChild implements Callable<Void> {
  private Container child;
  public StartChild(Container child) {
   this.child = child;
  }
  @Override
  public Void call() throws LifecycleException {
   child.start();
   return null;
  }
 }

Context context = (Context) event.getLifecycle();
    if (event.getType().equals(Lifecycle.CONFIGURE_START_EVENT)) {
     context.setConfigured(true);
    }
    // LoginConfig is required to process @ServletSecurity
    // annotations
    if (context.getLoginConfig() == null) {
     context.setLoginConfig(
       new LoginConfig("NONE", null, null, null));
     context.getPipeline().addValve(new NonLoginAuthenticator());
    }

Notification notification = new Notification("j2ee.object.created",
     this.getObjectName(), sequenceNumber.getAndIncrement());
   broadcaster.sendNotification(notification);

 /**
  * Sends a notification.
  *
  * If an {@code Executor} was specified in the constructor, it will be given one
  * task per selected listener to deliver the notification to that listener.
  *
  * @param notification The notification to send.
  */
 public void sendNotification(Notification notification) {
  if (notification == null) {
   return;
  }
  boolean enabled;
  for (ListenerInfo li : listenerList) {
   try {
    enabled = li.filter == null ||
     li.filter.isNotificationEnabled(notification);
   } catch (Exception e) {
    if (logger.debugOn()) {
     logger.debug("sendNotification", e);
    }
    continue;
   }
   if (enabled) {
    executor.execute(new SendNotifJob(notification, li));
   }
  }
 }

try {
    setResources(new StandardRoot(this));
   } catch (IllegalArgumentException e) {
    log.error(sm.getString("standardContext.resourcesInit"), e);
    ok = false;
   }

private final List<List<WebResourceSet>> allResources =
   new ArrayList<>();
 {
  allResources.add(preResources);
  allResources.add(mainResources);
  allResources.add(classResources);
  allResources.add(jarResources);
  allResources.add(postResources);
 }

 //-------------------------------------------------------- Lifecycle methods
 @Override
 protected void initInternal() throws LifecycleException {
  super.initInternal();
  // Is this an exploded web application?
  if (getWebAppMount().equals("")) {
   // Look for a manifest
   File mf = file("META-INF/MANIFEST.MF", true);
   if (mf != null && mf.isFile()) {
    try (FileInputStream fis = new FileInputStream(mf)) {
     setManifest(new Manifest(fis));
    } catch (IOException e) {
     log.warn(sm.getString("dirResourceSet.manifestFail", mf.getAbsolutePath()), e);
    }
   }
  }
 }

private void processWebInfLib() {
  WebResource[] possibleJars = listResources("/WEB-INF/lib", false);
  for (WebResource possibleJar : possibleJars) {
   if (possibleJar.isFile() && possibleJar.getName().endsWith(".jar")) {
    createWebResourceSet(ResourceSetType.CLASSES_JAR,
      "/WEB-INF/classes", possibleJar.getURL(), "/");
   }
  }
 }

 // Need to start the newly found resources
  for (WebResourceSet classResource : classResources) {
   classResource.start();
  }

 /**
  * Set an attribute as read only.
  */
 void setAttributeReadOnly(String name) {
  if (attributes.containsKey(name))
   readOnlyAttributes.put(name, name);
 }

 // Validate required extensions
  boolean dependencyCheck = true;
  try {
   dependencyCheck = ExtensionValidator.validateApplication
    (getResources(), this);
  } catch (IOException ioe) {
   log.error(sm.getString("standardContext.extensionValidationError"), ioe);
   dependencyCheck = false;
  }

if (!dependencyCheck) {
   // do not make application available if depency check fails
   ok = false;
  }
  // Reading the "catalina.useNaming" environment variable
  String useNamingProperty = System.getProperty("catalina.useNaming");
  if ((useNamingProperty != null)
   && (useNamingProperty.equals("false"))) {
   useNaming = false;
  }
  if (ok && isUseNaming()) {
   if (getNamingContextListener() == null) {
    NamingContextListener ncl = new NamingContextListener();
    ncl.setName(getNamingContextName());
    ncl.setExceptionOnFailedWrite(getJndiExceptionOnFailedWrite());
    addLifecycleListener(ncl);
    setNamingContextListener(ncl);
   }
  }

 classLoader = createClassLoader();
   classLoader.setResources(context.getResources());
   classLoader.setDelegate(this.delegate);

 while (loader != null) {
   if (!buildClassPath(classpath, loader)) {
    break;
   }
   loader = loader.getParent();
  }
  if (delegate) {
   // Delegation was enabled, go back and add the webapp paths
   loader = getClassLoader();
   if (loader != null) {
    buildClassPath(classpath, loader);
   }
  }

private void setPermissions() {
  if (!Globals.IS_SECURITY_ENABLED)
   return;
  if (context == null)
   return;
  // Tell the class loader the root of the context
  ServletContext servletContext = context.getServletContext();
  // Assigning permissions for the work directory
  File workDir =
   (File) servletContext.getAttribute(ServletContext.TEMPDIR);
  if (workDir != null) {
   try {
    String workDirPath = workDir.getCanonicalPath();
    classLoader.addPermission
     (new FilePermission(workDirPath, "read,write"));
    classLoader.addPermission
     (new FilePermission(workDirPath + File.separator + "-",
          "read,write,delete"));
   } catch (IOException e) {
    // Ignore
   }
  }
  for (URL url : context.getResources().getBaseUrls()) {
   classLoader.addPermission(url);
  }
 }

 public void start() throws LifecycleException {
  state = LifecycleState.STARTING_PREP;
  WebResource classes = resources.getResource("/WEB-INF/classes");
  if (classes.isDirectory() && classes.canRead()) {
   localRepositories.add(classes.getURL());
  }
  WebResource[] jars = resources.listResources("/WEB-INF/lib");
  for (WebResource jar : jars) {
   if (jar.getName().endsWith(".jar") && jar.isFile() && jar.canRead()) {
    localRepositories.add(jar.getURL());
    jarModificationTimes.put(
      jar.getName(), Long.valueOf(jar.getLastModified()));
   }
  }
  state = LifecycleState.STARTED;
 }

 // since the loader just started, the webapp classloader is now
    // created.
    setClassLoaderProperty("clearReferencesRmiTargets",
      getClearReferencesRmiTargets());
    setClassLoaderProperty("clearReferencesStopThreads",
      getClearReferencesStopThreads());
    setClassLoaderProperty("clearReferencesStopTimerThreads",
      getClearReferencesStopTimerThreads());
    setClassLoaderProperty("clearReferencesHttpClientKeepAliveThread",
      getClearReferencesHttpClientKeepAliveThread());

@Override
 public void setManager(Manager manager) {
  if (manager instanceof ManagerBase) {
   ((ManagerBase) manager).setSessionIdGenerator(new LazySessionIdGenerator());
  }
  super.setManager(manager);
 }

@Override
 protected void startInternal() throws LifecycleException {
  setState(LifecycleState.STARTING);
 }
}

 for (ContextResource cr : resources.values()) {
   try {
    MBeanUtils.createMBean(cr);
   } catch (Exception e) {
    log.warn(sm.getString(
      "namingResources.mbeanCreateFail", cr.getName()), e);
   }
  }
  for (ContextEnvironment ce : envs.values()) {
   try {
    MBeanUtils.createMBean(ce);
   } catch (Exception e) {
    log.warn(sm.getString(
      "namingResources.mbeanCreateFail", ce.getName()), e);
   }
  }
  for (ContextResourceLink crl : resourceLinks.values()) {
   try {
    MBeanUtils.createMBean(crl);
   } catch (Exception e) {
    log.warn(sm.getString(
      "namingResources.mbeanCreateFail", crl.getName()), e);
   }
  }

 getServletContext().setAttribute(
      InstanceManager.class.getName(), getInstanceManager());
    InstanceManagerBindings.bind(getLoader().getClassLoader(), getInstanceManager());

 getServletContext().setAttribute(
      JarScanner.class.getName(), getJarScanner());

 for (ServletContextInitializer initializer : this.initializers) {
    initializer.onStartup(servletContext);
   }

private org.springframework.boot.web.servlet.ServletContextInitializer getSelfInitializer() {
  return new ServletContextInitializer() {
   @Override
   public void onStartup(ServletContext servletContext) throws ServletException {
    selfInitialize(servletContext);
   }
  };
 }

 static {
   Set<String> scopes = new LinkedHashSet<String>();
   scopes.add(WebApplicationContext.SCOPE_REQUEST);//request
   scopes.add(WebApplicationContext.SCOPE_SESSION);//session
   scopes.add(WebApplicationContext.SCOPE_GLOBAL_SESSION);//global session
   SCOPES = Collections.unmodifiableSet(scopes);
  }

this.beanFactory = beanFactory;
   for (String scopeName : SCOPES) {
    Scope scope = beanFactory.getRegisteredScope(scopeName);
    if (scope != null) {
     this.scopes.put(scopeName, scope);
    }
   }

 beanFactory.registerScope(WebApplicationContext.SCOPE_REQUEST, new RequestScope());
  beanFactory.registerScope(WebApplicationContext.SCOPE_SESSION, new SessionScope(false));
  beanFactory.registerScope(WebApplicationContext.SCOPE_GLOBAL_SESSION, new SessionScope(true));
  if (sc != null) {
   ServletContextScope appScope = new ServletContextScope(sc);
   beanFactory.registerScope(WebApplicationContext.SCOPE_APPLICATION, appScope);
   // Register as ServletContext attribute, for ContextCleanupListener to detect it.
   sc.setAttribute(ServletContextScope.class.getName(), appScope);
  }
  beanFactory.registerResolvableDependency(ServletRequest.class, new RequestObjectFactory());
  beanFactory.registerResolvableDependency(ServletResponse.class, new ResponseObjectFactory());
  beanFactory.registerResolvableDependency(HttpSession.class, new SessionObjectFactory());
  beanFactory.registerResolvableDependency(WebRequest.class, new WebRequestObjectFactory());
  if (jsfPresent) {
   FacesDependencyRegistrar.registerFacesDependencies(beanFactory);
  }

public void restore() {
   for (Map.Entry<String, Scope> entry : this.scopes.entrySet()) {
    if (logger.isInfoEnabled()) {
     logger.info("Restoring user defined scope " + entry.getKey());
    }
    this.beanFactory.registerScope(entry.getKey(), entry.getValue());
   }
  }

 static {
  Set<Class<?>> types = new HashSet<Class<?>>();
  types.add(ServletContextAttributeListener.class);
  types.add(ServletRequestListener.class);
  types.add(ServletRequestAttributeListener.class);
  types.add(HttpSessionAttributeListener.class);
  types.add(HttpSessionListener.class);
  types.add(ServletContextListener.class);
  SUPPORTED_TYPES = Collections.unmodifiableSet(types);
 }

List<ServletContextInitializer> sortedInitializers = new ArrayList<ServletContextInitializer>();
  for (Map.Entry<?, List<ServletContextInitializer>> entry : this.initializers
    .entrySet()) {
   AnnotationAwareOrderComparator.sort(entry.getValue());
   sortedInitializers.addAll(entry.getValue());
  }
  this.sortedList = Collections.unmodifiableList(sortedInitializers);
 public static void sort(Object[] array) {
  if (array.length > 1) {
   Arrays.sort(array, INSTANCE);
  }
 }
 private int doCompare(Object o1, Object o2, OrderSourceProvider sourceProvider) {
  boolean p1 = (o1 instanceof PriorityOrdered);
  boolean p2 = (o2 instanceof PriorityOrdered);
  if (p1 && !p2) {
   return -1;
  }
  else if (p2 && !p1) {
   return 1;
  }
  // Direct evaluation instead of Integer.compareTo to avoid unnecessary object creation.
  int i1 = getOrder(o1, sourceProvider);
  int i2 = getOrder(o2, sourceProvider);
  return (i1 < i2) ? -1 : (i1 > i2) ? 1 : 0;
 }

 public void onStartup(ServletContext servletContext) throws ServletException {
   if (this.session.getTrackingModes() != null) {
    servletContext.setSessionTrackingModes(this.session.getTrackingModes());
   }
   configureSessionCookie(servletContext.getSessionCookieConfig());
  }

 config.setName(cookie.getName());
    config.setDomain(cookie.getDomain());
    config.setPath(cookie.getPath());
    config.setComment(cookie.getComment());
    config.setHttpOnly(cookie.getHttpOnly());
    config.setSecure(cookie.getSecure());
    config.setMaxAge(cookie.getMaxAge());

 ServletContext sc = sce.getServletContext();
  if(sc.getAttribute("javax.websocket.server.ServerContainer") == null) {
   WsSci.init(sce.getServletContext(), false);
  }

 static {
  GET_BYTES = "GET ".getBytes(StandardCharsets.ISO_8859_1);
  ROOT_URI_BYTES = "/".getBytes(StandardCharsets.ISO_8859_1);
  HTTP_VERSION_BYTES = " HTTP/1.1\r\n".getBytes(StandardCharsets.ISO_8859_1);
 }
 static {
  AUTHENTICATED_HTTP_SESSION_CLOSED = new CloseReason(CloseCodes.VIOLATED_POLICY, "This connection was established under an authenticated HTTP session that has ended.");
 }
 WsServerContainer(ServletContext servletContext) {
  this.enforceNoAddAfterHandshake = Constants.STRICT_SPEC_COMPLIANCE; //Boolean.getBoolean("org.apache.tomcat.websocket.STRICT_SPEC_COMPLIANCE")
  this.addAllowed = true;
  this.authenticatedSessions = new ConcurrentHashMap();
  this.endpointsRegistered = false;
  this.servletContext = servletContext;
 　　//我这里添加了org.apache.tomcat.websocket.server和本地语言en_US（我代码是在英文版ubuntu上跑的）
  this.setInstanceManager((InstanceManager)servletContext.getAttribute(InstanceManager.class.getName())); 
  String value = servletContext.getInitParameter("org.apache.tomcat.websocket.binaryBufferSize");
  if(value != null) {
   this.setDefaultMaxBinaryMessageBufferSize(Integer.parseInt(value));
  }
  value = servletContext.getInitParameter("org.apache.tomcat.websocket.textBufferSize");
  if(value != null) {
   this.setDefaultMaxTextMessageBufferSize(Integer.parseInt(value));
  }
　　　　//Java WebSocket 规范 1.0 并不允许第一个服务端点开始 WebSocket 握手之后进行程序性部署。默认情况下，Tomcat 继续允许额外的程序性部署。
  value = servletContext.getInitParameter("org.apache.tomcat.websocket.noAddAfterHandshake");
  if(value != null) {
   this.setEnforceNoAddAfterHandshake(Boolean.parseBoolean(value));
  }
  Dynamic fr = servletContext.addFilter("Tomcat WebSocket (JSR356) Filter", new WsFilter());
  fr.setAsyncSupported(true);
  EnumSet types = EnumSet.of(DispatcherType.REQUEST, DispatcherType.FORWARD);
  fr.addMappingForUrlPatterns(types, true, new String[]{"/*"});
 }

 public Engine getEngine() {
  Engine e = null;
  for (Container c = getContext(); e == null && c != null ; c = c.getParent()) {
   if (c instanceof Engine) {
    e = (Engine)c;
   }
  }
  return e;
 }

 if (event.getType().equals(Lifecycle.AFTER_START_EVENT)) {
    if (event.getSource() instanceof Context) {
     Context context = ((Context) event.getSource());
     childClassLoaders.put(context.getLoader().getClassLoader(),
       context.getServletContext().getContextPath());
    }
   }