Class AsyncMiddleManServlet

java.lang.Object

jakarta.servlet.GenericServlet

jakarta.servlet.http.HttpServlet

org.eclipse.jetty.ee10.proxy.AbstractProxyServlet

org.eclipse.jetty.ee10.proxy.AsyncMiddleManServlet

All Implemented Interfaces:

jakarta.servlet.Servlet, jakarta.servlet.ServletConfig, Serializable

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
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.TransparentDelegate

Field Summary

Fields inherited from class AbstractProxyServlet

_log, CLIENT_REQUEST_ATTRIBUTE, HOP_HEADERS

Fields inherited from class jakarta.servlet.http.HttpServlet

LEGACY_DO_HEAD

Constructor Summary

Constructors

Constructor	Description
AsyncMiddleManServlet()

Method Summary

Modifier and Type	Method	Description
protected AsyncMiddleManServlet.ContentTransformer	newClientRequestContentTransformer(jakarta.servlet.http.HttpServletRequest clientRequest, Request proxyRequest)
protected jakarta.servlet.ReadListener	newProxyReadListener(jakarta.servlet.http.HttpServletRequest clientRequest, jakarta.servlet.http.HttpServletResponse proxyResponse, Request proxyRequest, AsyncRequestContent content)
protected AsyncRequestContent	newProxyRequestContent(jakarta.servlet.http.HttpServletRequest clientRequest, jakarta.servlet.http.HttpServletResponse proxyResponse, Request proxyRequest)
protected Response.CompleteListener	newProxyResponseListener(jakarta.servlet.http.HttpServletRequest clientRequest, jakarta.servlet.http.HttpServletResponse proxyResponse)
protected AsyncMiddleManServlet.ProxyWriter	newProxyWriteListener(jakarta.servlet.http.HttpServletRequest clientRequest, Response proxyResponse)
protected AsyncMiddleManServlet.ContentTransformer	newServerResponseContentTransformer(jakarta.servlet.http.HttpServletRequest clientRequest, jakarta.servlet.http.HttpServletResponse proxyResponse, Response serverResponse)
protected Runnable	onContinue(jakarta.servlet.http.HttpServletRequest clientRequest, Request proxyRequest)
protected void	sendProxyRequest(jakarta.servlet.http.HttpServletRequest clientRequest, jakarta.servlet.http.HttpServletResponse proxyResponse, Request proxyRequest)
protected void	service(jakarta.servlet.http.HttpServletRequest clientRequest, jakarta.servlet.http.HttpServletResponse proxyResponse)
protected void	writeProxyResponseContent(jakarta.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, newClientConnector, newHttpClient, newHttpClient, newProxyRequest, onClientRequestFailure, onProxyResponseFailure, onProxyResponseSuccess, onProxyRewriteFailed, onServerResponseHeaders, proxyResponseStatus, rewriteTarget, sendProxyResponseError, setTimeout, validateDestination

Methods inherited from class jakarta.servlet.http.HttpServlet

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

Methods inherited from class jakarta.servlet.GenericServlet

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

Methods inherited from class Object

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

Constructor Details

AsyncMiddleManServlet

public AsyncMiddleManServlet()

Method Details

service

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

Overrides:

service in class jakarta.servlet.http.HttpServlet

Throws:

jakarta.servlet.ServletException

IOException

sendProxyRequest

protected void sendProxyRequest(jakarta.servlet.http.HttpServletRequest clientRequest,
 jakarta.servlet.http.HttpServletResponse proxyResponse,
 Request proxyRequest)

Overrides:

sendProxyRequest in class AbstractProxyServlet

newProxyRequestContent

protected AsyncRequestContent newProxyRequestContent(jakarta.servlet.http.HttpServletRequest clientRequest,
 jakarta.servlet.http.HttpServletResponse proxyResponse,
 Request proxyRequest)

newProxyReadListener

protected jakarta.servlet.ReadListener newProxyReadListener(jakarta.servlet.http.HttpServletRequest clientRequest,
 jakarta.servlet.http.HttpServletResponse proxyResponse,
 Request proxyRequest,
 AsyncRequestContent content)

newProxyWriteListener

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

newProxyResponseListener

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

Specified by:

newProxyResponseListener in class AbstractProxyServlet

newClientRequestContentTransformer

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

newServerResponseContentTransformer

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

onContinue

protected Runnable onContinue(jakarta.servlet.http.HttpServletRequest clientRequest,
 Request proxyRequest)

Overrides:

onContinue in class AbstractProxyServlet

writeProxyResponseContent

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

Throws:

IOException