org.zodiac.server.proxy.impl

类 ClientToProxyConnectionPre

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.HttpRequest>

org.zodiac.server.proxy.impl.ClientToProxyConnectionPre

所有已实现的接口:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

public class ClientToProxyConnectionPre
extends io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.HttpRequest>

嵌套类概要

从接口继承的嵌套类/接口 io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

字段概要

字段

限定符和类型	字段和说明
static String	HTTP_DATE_FORMAT
static String	HTTP_DATE_GMT_TIMEZONE
private HttpProxyConfigOptions	httpProxyConfigOptions
static String	NAME
private HttpRequestWrapper	request

构造器概要

构造器

构造器和说明
ClientToProxyConnectionPre(HttpProxyConfigOptions httpProxyConfigOptions)

方法概要

限定符和类型	方法和说明
private io.netty.handler.codec.http.HttpResponse	addHttp2StreamId(io.netty.handler.codec.http.HttpResponse response)
void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.HttpRequest request)
private void	channelReadHtml(io.netty.channel.ChannelHandlerContext ctx)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
private String	getFilePath(String node)
private void	pageError(io.netty.channel.ChannelHandlerContext ctx, String message)
private void	pageNotFound(io.netty.channel.ChannelHandlerContext ctx)
private void	responseHtml(io.netty.channel.ChannelHandlerContext ctx, File file)
private String	sanitizeUri(ProxyRuleOption htmlObj)
private ProxyRuleOption	selectProxy(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.HttpRequest request, String host)
private void	sendAndCleanupConnection(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.FullHttpResponse response)
private void	sendError(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.HttpResponseStatus status, String message)
private void	sendNotModified(io.netty.channel.ChannelHandlerContext ctx)
private void	setContentTypeHeader(io.netty.handler.codec.http.HttpResponse response, File fileToCache)
private static void	setDateAndCacheHeaders(io.netty.handler.codec.http.HttpResponse response, File fileToCache, HttpHtmlOption httpHtmlOption)
private static void	setDateHeader(io.netty.handler.codec.http.FullHttpResponse response)
private static ByteBuffer	toByteBuffer(RandomAccessFile raf) Mapped File way MappedByteBuffer 可以在处理大文件时，提升性能。
private HttpRequestWrapper	wrapHttpRequest(io.netty.handler.codec.http.HttpRequest request, ProxyRuleOption httpProxy, org.zodiac.commons.model.network.HostAndPort hostAndPort, String serverHostAndPort)

从类继承的方法 io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

从类继承的方法 io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

从类继承的方法 io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

从类继承的方法 java.lang.Object

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

从接口继承的方法 io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

字段详细资料

NAME

public static final String NAME

HTTP_DATE_FORMAT

public static final String HTTP_DATE_FORMAT

另请参阅:

常量字段值

HTTP_DATE_GMT_TIMEZONE

public static final String HTTP_DATE_GMT_TIMEZONE

另请参阅:

常量字段值

httpProxyConfigOptions

private HttpProxyConfigOptions httpProxyConfigOptions

request

private HttpRequestWrapper request

构造器详细资料

ClientToProxyConnectionPre

public ClientToProxyConnectionPre(HttpProxyConfigOptions httpProxyConfigOptions)

方法详细资料

channelRead0

public void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
                         io.netty.handler.codec.http.HttpRequest request)
                  throws Exception

指定者:

channelRead0 在类中 io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.HttpRequest>

抛出:

Exception

channelReadHtml

private void channelReadHtml(io.netty.channel.ChannelHandlerContext ctx)
                      throws Exception

抛出:

Exception

responseHtml

private void responseHtml(io.netty.channel.ChannelHandlerContext ctx,
                          File file)
                   throws Exception

抛出:

Exception

pageError

private void pageError(io.netty.channel.ChannelHandlerContext ctx,
                       String message)
                throws Exception

抛出:

Exception

pageNotFound

private void pageNotFound(io.netty.channel.ChannelHandlerContext ctx)
                   throws Exception

抛出:

Exception

getFilePath

private String getFilePath(String node)

toByteBuffer

private static ByteBuffer toByteBuffer(RandomAccessFile raf)
                                throws IOException

Mapped File way MappedByteBuffer 可以在处理大文件时，提升性能。

参数:

raf - RandomAccessFile

返回:

byte buffer

抛出:

IOException - IOException

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
                            Throwable cause)

指定者:

exceptionCaught 在接口中 io.netty.channel.ChannelHandler

指定者:

exceptionCaught 在接口中 io.netty.channel.ChannelInboundHandler

覆盖:

exceptionCaught 在类中 io.netty.channel.ChannelInboundHandlerAdapter

sanitizeUri

private String sanitizeUri(ProxyRuleOption htmlObj)

sendError

private void sendError(io.netty.channel.ChannelHandlerContext ctx,
                       io.netty.handler.codec.http.HttpResponseStatus status,
                       String message)

sendNotModified

private void sendNotModified(io.netty.channel.ChannelHandlerContext ctx)

sendAndCleanupConnection

private void sendAndCleanupConnection(io.netty.channel.ChannelHandlerContext ctx,
                                      io.netty.handler.codec.http.FullHttpResponse response)

setDateHeader

private static void setDateHeader(io.netty.handler.codec.http.FullHttpResponse response)

setDateAndCacheHeaders

private static void setDateAndCacheHeaders(io.netty.handler.codec.http.HttpResponse response,
                                           File fileToCache,
                                           HttpHtmlOption httpHtmlOption)

setContentTypeHeader

private void setContentTypeHeader(io.netty.handler.codec.http.HttpResponse response,
                                  File fileToCache)

addHttp2StreamId

private io.netty.handler.codec.http.HttpResponse addHttp2StreamId(io.netty.handler.codec.http.HttpResponse response)

selectProxy

private ProxyRuleOption selectProxy(io.netty.channel.ChannelHandlerContext ctx,
                                    io.netty.handler.codec.http.HttpRequest request,
                                    String host)
                             throws Exception

抛出:

Exception

wrapHttpRequest

private HttpRequestWrapper wrapHttpRequest(io.netty.handler.codec.http.HttpRequest request,
                                           ProxyRuleOption httpProxy,
                                           org.zodiac.commons.model.network.HostAndPort hostAndPort,
                                           String serverHostAndPort)