Add support for engine valves

Update TomcatEmbeddedServletContainerFactory to allow registration of
engine valves as well as context values. For clarity the ambiguous
`getValues()` method has been deprecated in favor of
`getContextValves()`

See gh-6311
This commit is contained in:
Christoffer Sawicki 2016-07-18 15:22:25 -07:00 committed by Phillip Webb
parent be80a5878d
commit 150aba2191
1 changed files with 53 additions and 2 deletions

View File

@ -34,6 +34,7 @@ import javax.servlet.ServletContainerInitializer;
import javax.servlet.ServletContext; import javax.servlet.ServletContext;
import org.apache.catalina.Context; import org.apache.catalina.Context;
import org.apache.catalina.Engine;
import org.apache.catalina.Host; import org.apache.catalina.Host;
import org.apache.catalina.Lifecycle; import org.apache.catalina.Lifecycle;
import org.apache.catalina.LifecycleEvent; import org.apache.catalina.LifecycleEvent;
@ -88,6 +89,7 @@ import org.springframework.util.StringUtils;
* @author Stephane Nicoll * @author Stephane Nicoll
* @author Andy Wilkinson * @author Andy Wilkinson
* @author Eddú Meléndez * @author Eddú Meléndez
* @author Christoffer Sawicki
* @see #setPort(int) * @see #setPort(int)
* @see #setContextLifecycleListeners(Collection) * @see #setContextLifecycleListeners(Collection)
* @see TomcatEmbeddedServletContainer * @see TomcatEmbeddedServletContainer
@ -106,6 +108,8 @@ public class TomcatEmbeddedServletContainerFactory
private File baseDirectory; private File baseDirectory;
private List<Valve> engineValves = new ArrayList<Valve>();
private List<Valve> contextValves = new ArrayList<Valve>(); private List<Valve> contextValves = new ArrayList<Valve>();
private List<LifecycleListener> contextLifecycleListeners = new ArrayList<LifecycleListener>(); private List<LifecycleListener> contextLifecycleListeners = new ArrayList<LifecycleListener>();
@ -162,7 +166,7 @@ public class TomcatEmbeddedServletContainerFactory
customizeConnector(connector); customizeConnector(connector);
tomcat.setConnector(connector); tomcat.setConnector(connector);
tomcat.getHost().setAutoDeploy(false); tomcat.getHost().setAutoDeploy(false);
tomcat.getEngine().setBackgroundProcessorDelay(-1); configureEngine(tomcat.getEngine());
for (Connector additionalConnector : this.additionalTomcatConnectors) { for (Connector additionalConnector : this.additionalTomcatConnectors) {
tomcat.getService().addConnector(additionalConnector); tomcat.getService().addConnector(additionalConnector);
} }
@ -170,6 +174,13 @@ public class TomcatEmbeddedServletContainerFactory
return getTomcatEmbeddedServletContainer(tomcat); return getTomcatEmbeddedServletContainer(tomcat);
} }
private void configureEngine(Engine engine) {
engine.setBackgroundProcessorDelay(-1);
for (Valve valve : this.engineValves) {
engine.getPipeline().addValve(valve);
}
}
protected void prepareContext(Host host, ServletContextInitializer[] initializers) { protected void prepareContext(Host host, ServletContextInitializer[] initializers) {
File docBase = getValidDocumentRoot(); File docBase = getValidDocumentRoot();
docBase = (docBase != null ? docBase : createTempDir("tomcat-docbase")); docBase = (docBase != null ? docBase : createTempDir("tomcat-docbase"));
@ -527,9 +538,37 @@ public class TomcatEmbeddedServletContainerFactory
this.protocol = protocol; this.protocol = protocol;
} }
/**
* Set {@link Valve}s that should be applied to the Tomcat {@link Engine}. Calling
* this method will replace any existing valves.
* @param engineValves the valves to set
*/
public void setEngineValves(Collection<? extends Valve> engineValves) {
Assert.notNull(engineValves, "Valves must not be null");
this.engineValves = new ArrayList<Valve>(engineValves);
}
/**
* Returns a mutable collection of the {@link Valve}s that will be applied to the
* Tomcat {@link Engine}.
* @return the engineValves the valves that will be applied
*/
public Collection<Valve> getEngineValves() {
return this.engineValves;
}
/**
* Add {@link Valve}s that should be applied to the Tomcat {@link Engine}.
* @param engineValves the valves to add
*/
public void addEngineValves(Valve... engineValves) {
Assert.notNull(engineValves, "Valves must not be null");
this.engineValves.addAll(Arrays.asList(engineValves));
}
/** /**
* Set {@link Valve}s that should be applied to the Tomcat {@link Context}. Calling * Set {@link Valve}s that should be applied to the Tomcat {@link Context}. Calling
* this method will replace any existing listeners. * this method will replace any existing valves.
* @param contextValves the valves to set * @param contextValves the valves to set
*/ */
public void setContextValves(Collection<? extends Valve> contextValves) { public void setContextValves(Collection<? extends Valve> contextValves) {
@ -541,8 +580,20 @@ public class TomcatEmbeddedServletContainerFactory
* Returns a mutable collection of the {@link Valve}s that will be applied to the * Returns a mutable collection of the {@link Valve}s that will be applied to the
* Tomcat {@link Context}. * Tomcat {@link Context}.
* @return the contextValves the valves that will be applied * @return the contextValves the valves that will be applied
* @deprecated as of 1.4 in favor of {@link #getContextValves()}
*/ */
@Deprecated
public Collection<Valve> getValves() { public Collection<Valve> getValves() {
return getContextValves();
}
/**
* Returns a mutable collection of the {@link Valve}s that will be applied to the
* Tomcat {@link Context}.
* @return the contextValves the valves that will be applied
* @see #getEngineValves()
*/
public Collection<Valve> getContextValves() {
return this.contextValves; return this.contextValves;
} }