Class AsyncMiddleManServlet

java.lang.Object

javax.servlet.GenericServlet

javax.servlet.http.HttpServlet

org.eclipse.jetty.proxy.AbstractProxyServlet

org.eclipse.jetty.proxy.AsyncMiddleManServlet

All Implemented Interfaces:

Serializable, javax.servlet.Servlet, javax.servlet.ServletConfig

Direct Known Subclasses:

AsyncMiddleManServlet.Transparent

public class AsyncMiddleManServlet
extends AbstractProxyServlet

Servlet 3.1 asynchronous proxy servlet with capability to intercept and modify request/response content.

Both the request processing and the I/O are asynchronous.

See Also:

• ProxyServlet
• AsyncProxyServlet
• ConnectHandler
• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	AsyncMiddleManServlet.ContentTransformer	Allows applications to transform upstream and downstream content.
static class	AsyncMiddleManServlet.GZIPContentTransformer
private static class	AsyncMiddleManServlet.IdentityContentTransformer
private class	AsyncMiddleManServlet.ProxyDeferredContentProvider
protected class	AsyncMiddleManServlet.ProxyReader
protected class	AsyncMiddleManServlet.ProxyResponseListener
protected class	AsyncMiddleManServlet.ProxyWriter
static class	AsyncMiddleManServlet.Transparent	Convenience extension of AsyncMiddleManServlet that offers transparent proxy functionalities.

Nested classes/interfaces inherited from class AbstractProxyServlet

AbstractProxyServlet.ProxyContinueProtocolHandler, AbstractProxyServlet.TransparentDelegate

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	CLIENT_TRANSFORMER_ATTRIBUTE
private static final String	CONTINUE_ACTION_ATTRIBUTE
private static final String	PROXY_REQUEST_CONTENT_COMMITTED_ATTRIBUTE
private static final String	SERVER_TRANSFORMER_ATTRIBUTE
private static final String	WRITE_LISTENER_ATTRIBUTE

Fields inherited from class AbstractProxyServlet

_log, CLIENT_REQUEST_ATTRIBUTE, HOP_HEADERS

Constructor Summary

Constructors

Constructor	Description
AsyncMiddleManServlet()

Method Summary

Modifier and Type	Method	Description
private void	cleanup(javax.servlet.http.HttpServletRequest clientRequest)
protected AsyncMiddleManServlet.ContentTransformer	newClientRequestContentTransformer(javax.servlet.http.HttpServletRequest clientRequest, Request proxyRequest)
protected DeferredContentProvider	newProxyContentProvider(javax.servlet.http.HttpServletRequest clientRequest, javax.servlet.http.HttpServletResponse proxyResponse, Request proxyRequest)
protected javax.servlet.ReadListener	newProxyReadListener(javax.servlet.http.HttpServletRequest clientRequest, javax.servlet.http.HttpServletResponse proxyResponse, Request proxyRequest, DeferredContentProvider provider)
protected Response.CompleteListener	newProxyResponseListener(javax.servlet.http.HttpServletRequest clientRequest, javax.servlet.http.HttpServletResponse proxyResponse)
protected AsyncMiddleManServlet.ProxyWriter	newProxyWriteListener(javax.servlet.http.HttpServletRequest clientRequest, Response proxyResponse)
protected AsyncMiddleManServlet.ContentTransformer	newServerResponseContentTransformer(javax.servlet.http.HttpServletRequest clientRequest, javax.servlet.http.HttpServletResponse proxyResponse, Response serverResponse)
protected void	onContinue(javax.servlet.http.HttpServletRequest clientRequest, Request proxyRequest)
(package private) int	readClientRequestContent(javax.servlet.ServletInputStream input, byte[] buffer)
protected void	service(javax.servlet.http.HttpServletRequest clientRequest, javax.servlet.http.HttpServletResponse proxyResponse)
private void	transform(AsyncMiddleManServlet.ContentTransformer transformer, ByteBuffer input, boolean finished, List<ByteBuffer> output)
private static void	write(OutputStream output, ByteBuffer content)
(package private) void	writeProxyResponseContent(javax.servlet.ServletOutputStream output, ByteBuffer content)

Methods inherited from class AbstractProxyServlet

addProxyHeaders, addViaHeader, addViaHeader, addXForwardedHeaders, clientRequestStatus, copyRequestHeaders, createHttpClient, createLogger, destroy, expects100Continue, filterServerResponseHeader, findConnectionHeaders, getBlackListHosts, getHostHeader, getHttpClient, getRequestId, getTimeout, getViaHost, getWhiteListHosts, hasContent, init, newHttpClient, newProxyRequest, onClientRequestFailure, onProxyResponseFailure, onProxyResponseSuccess, onProxyRewriteFailed, onServerResponseHeaders, proxyResponseStatus, rewriteTarget, sendProxyRequest, sendProxyResponseError, setTimeout, validateDestination

Methods inherited from class javax.servlet.http.HttpServlet

doDelete, doGet, doHead, doOptions, doPost, doPut, doTrace, getLastModified, service

Methods inherited from class javax.servlet.GenericServlet

getInitParameter, getInitParameterNames, getServletConfig, getServletContext, getServletInfo, getServletName, init, log, log

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

PROXY_REQUEST_CONTENT_COMMITTED_ATTRIBUTE

private static final String PROXY_REQUEST_CONTENT_COMMITTED_ATTRIBUTE

CLIENT_TRANSFORMER_ATTRIBUTE

private static final String CLIENT_TRANSFORMER_ATTRIBUTE

SERVER_TRANSFORMER_ATTRIBUTE

private static final String SERVER_TRANSFORMER_ATTRIBUTE

CONTINUE_ACTION_ATTRIBUTE

private static final String CONTINUE_ACTION_ATTRIBUTE

WRITE_LISTENER_ATTRIBUTE

private static final String WRITE_LISTENER_ATTRIBUTE

Constructor Details

AsyncMiddleManServlet

public AsyncMiddleManServlet()

Method Details

service

protected void service(javax.servlet.http.HttpServletRequest clientRequest,
 javax.servlet.http.HttpServletResponse proxyResponse)
                throws javax.servlet.ServletException,
IOException

Overrides:

service in class javax.servlet.http.HttpServlet

Throws:

javax.servlet.ServletException

IOException

newProxyContentProvider

protected DeferredContentProvider newProxyContentProvider(javax.servlet.http.HttpServletRequest clientRequest,
 javax.servlet.http.HttpServletResponse proxyResponse,
 Request proxyRequest)
                                                   throws IOException

Throws:

IOException

newProxyReadListener

protected javax.servlet.ReadListener newProxyReadListener(javax.servlet.http.HttpServletRequest clientRequest,
 javax.servlet.http.HttpServletResponse proxyResponse,
 Request proxyRequest,
 DeferredContentProvider provider)

newProxyWriteListener

protected AsyncMiddleManServlet.ProxyWriter newProxyWriteListener(javax.servlet.http.HttpServletRequest clientRequest,
 Response proxyResponse)

newProxyResponseListener

protected Response.CompleteListener newProxyResponseListener(javax.servlet.http.HttpServletRequest clientRequest,
 javax.servlet.http.HttpServletResponse proxyResponse)

Specified by:

newProxyResponseListener in class AbstractProxyServlet

newClientRequestContentTransformer

protected AsyncMiddleManServlet.ContentTransformer newClientRequestContentTransformer(javax.servlet.http.HttpServletRequest clientRequest,
 Request proxyRequest)

newServerResponseContentTransformer

protected AsyncMiddleManServlet.ContentTransformer newServerResponseContentTransformer(javax.servlet.http.HttpServletRequest clientRequest,
 javax.servlet.http.HttpServletResponse proxyResponse,
 Response serverResponse)

onContinue

protected void onContinue(javax.servlet.http.HttpServletRequest clientRequest,
 Request proxyRequest)

Overrides:

onContinue in class AbstractProxyServlet

transform

private void transform(AsyncMiddleManServlet.ContentTransformer transformer,
 ByteBuffer input,
 boolean finished,
 List<ByteBuffer> output)
                throws IOException

Throws:

IOException

readClientRequestContent

int readClientRequestContent(javax.servlet.ServletInputStream input,
 byte[] buffer)
                      throws IOException

Throws:

IOException

writeProxyResponseContent

void writeProxyResponseContent(javax.servlet.ServletOutputStream output,
 ByteBuffer content)
                        throws IOException

Throws:

IOException

write

private static void write(OutputStream output,
 ByteBuffer content)
                   throws IOException

Throws:

IOException

cleanup

private void cleanup(javax.servlet.http.HttpServletRequest clientRequest)