com.aliyun.openservices.iot.api.http2.netty

Class NettyHttp2Handler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.handler.codec.ByteToMessageDecoder

io.netty.handler.codec.http2.Http2ConnectionHandler

com.aliyun.openservices.iot.api.http2.netty.NettyHttp2Handler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.ChannelOutboundHandler, io.netty.handler.codec.http2.Http2FrameListener, io.netty.handler.codec.http2.Http2LifecycleManager

public class NettyHttp2Handler
extends io.netty.handler.codec.http2.Http2ConnectionHandler
implements io.netty.handler.codec.http2.Http2FrameListener

Author:

brhao

Date:

19/03/2018

Nested Class Summary

Nested classes/interfaces inherited from class io.netty.handler.codec.ByteToMessageDecoder

io.netty.handler.codec.ByteToMessageDecoder.Cumulator

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields inherited from class io.netty.handler.codec.ByteToMessageDecoder

COMPOSITE_CUMULATOR, MERGE_CUMULATOR

Method Summary

Modifier and Type	Method and Description
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
Connection	getConnection()
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
int	onDataRead(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.buffer.ByteBuf data, int padding, boolean endOfStream)
void	onError(io.netty.channel.ChannelHandlerContext ctx, boolean outbound, Throwable cause)
void	onGoAwayRead(io.netty.channel.ChannelHandlerContext ctx, int lastStreamId, long errorCode, io.netty.buffer.ByteBuf debugData)
void	onHeadersRead(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.handler.codec.http2.Http2Headers headers, int padding, boolean endOfStream)
void	onHeadersRead(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.handler.codec.http2.Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream)
void	onPingAckRead(io.netty.channel.ChannelHandlerContext ctx, long data)
void	onPingRead(io.netty.channel.ChannelHandlerContext ctx, long data)
void	onPriorityRead(io.netty.channel.ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive)
void	onPushPromiseRead(io.netty.channel.ChannelHandlerContext ctx, int streamId, int promisedStreamId, io.netty.handler.codec.http2.Http2Headers headers, int padding)
void	onRstStreamRead(io.netty.channel.ChannelHandlerContext ctx, int streamId, long errorCode)
void	onSettingsAckRead(io.netty.channel.ChannelHandlerContext ctx)
void	onSettingsRead(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http2.Http2Settings settings)
void	onUnknownFrame(io.netty.channel.ChannelHandlerContext ctx, byte frameType, int streamId, io.netty.handler.codec.http2.Http2Flags flags, io.netty.buffer.ByteBuf payload)
void	onWindowUpdateRead(io.netty.channel.ChannelHandlerContext ctx, int streamId, int windowSizeIncrement)
void	userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)

Methods inherited from class io.netty.handler.codec.http2.Http2ConnectionHandler

bind, channelActive, channelInactive, channelReadComplete, channelWritabilityChanged, close, closeStream, closeStreamLocal, closeStreamRemote, connect, connection, decode, decoder, deregister, disconnect, encoder, flush, frameWriter, goAway, gracefulShutdownTimeoutMillis, gracefulShutdownTimeoutMillis, handlerRemoved0, handleServerHeaderDecodeSizeError, isGracefulShutdownComplete, onConnectionError, onHttpClientUpgrade, onHttpServerUpgrade, onStreamError, read, resetStream, write

Methods inherited from class io.netty.handler.codec.ByteToMessageDecoder

actualReadableBytes, callDecode, decodeLast, discardSomeReadBytes, handlerRemoved, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelRegistered, channelUnregistered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerRemoved

Method Detail

getConnection

public Connection getConnection()

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        Object msg)
                 throws Exception

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.handler.codec.ByteToMessageDecoder

Throws:

Exception

handlerAdded

public void handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
                  throws Exception

Specified by:

handlerAdded in interface io.netty.channel.ChannelHandler

Overrides:

handlerAdded in class io.netty.handler.codec.http2.Http2ConnectionHandler

Throws:

Exception

onDataRead

public int onDataRead(io.netty.channel.ChannelHandlerContext ctx,
                      int streamId,
                      io.netty.buffer.ByteBuf data,
                      int padding,
                      boolean endOfStream)
               throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onDataRead in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

onHeadersRead

public void onHeadersRead(io.netty.channel.ChannelHandlerContext ctx,
                          int streamId,
                          io.netty.handler.codec.http2.Http2Headers headers,
                          int padding,
                          boolean endOfStream)
                   throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onHeadersRead in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

onHeadersRead

public void onHeadersRead(io.netty.channel.ChannelHandlerContext ctx,
                          int streamId,
                          io.netty.handler.codec.http2.Http2Headers headers,
                          int streamDependency,
                          short weight,
                          boolean exclusive,
                          int padding,
                          boolean endOfStream)
                   throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onHeadersRead in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

onPriorityRead

public void onPriorityRead(io.netty.channel.ChannelHandlerContext ctx,
                           int streamId,
                           int streamDependency,
                           short weight,
                           boolean exclusive)
                    throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onPriorityRead in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

onRstStreamRead

public void onRstStreamRead(io.netty.channel.ChannelHandlerContext ctx,
                            int streamId,
                            long errorCode)
                     throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onRstStreamRead in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

onSettingsAckRead

public void onSettingsAckRead(io.netty.channel.ChannelHandlerContext ctx)
                       throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onSettingsAckRead in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

onError

public void onError(io.netty.channel.ChannelHandlerContext ctx,
                    boolean outbound,
                    Throwable cause)

Specified by:

onError in interface io.netty.handler.codec.http2.Http2LifecycleManager

Overrides:

onError in class io.netty.handler.codec.http2.Http2ConnectionHandler

onSettingsRead

public void onSettingsRead(io.netty.channel.ChannelHandlerContext ctx,
                           io.netty.handler.codec.http2.Http2Settings settings)
                    throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onSettingsRead in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

onPingRead

public void onPingRead(io.netty.channel.ChannelHandlerContext ctx,
                       long data)
                throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onPingRead in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

onPingAckRead

public void onPingAckRead(io.netty.channel.ChannelHandlerContext ctx,
                          long data)
                   throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onPingAckRead in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

onPushPromiseRead

public void onPushPromiseRead(io.netty.channel.ChannelHandlerContext ctx,
                              int streamId,
                              int promisedStreamId,
                              io.netty.handler.codec.http2.Http2Headers headers,
                              int padding)
                       throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onPushPromiseRead in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

onGoAwayRead

public void onGoAwayRead(io.netty.channel.ChannelHandlerContext ctx,
                         int lastStreamId,
                         long errorCode,
                         io.netty.buffer.ByteBuf debugData)
                  throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onGoAwayRead in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

onWindowUpdateRead

public void onWindowUpdateRead(io.netty.channel.ChannelHandlerContext ctx,
                               int streamId,
                               int windowSizeIncrement)
                        throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onWindowUpdateRead in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

onUnknownFrame

public void onUnknownFrame(io.netty.channel.ChannelHandlerContext ctx,
                           byte frameType,
                           int streamId,
                           io.netty.handler.codec.http2.Http2Flags flags,
                           io.netty.buffer.ByteBuf payload)
                    throws io.netty.handler.codec.http2.Http2Exception

Specified by:

onUnknownFrame in interface io.netty.handler.codec.http2.Http2FrameListener

Throws:

io.netty.handler.codec.http2.Http2Exception

exceptionCaught

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

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.handler.codec.http2.Http2ConnectionHandler

Throws:

Exception

userEventTriggered

public void userEventTriggered(io.netty.channel.ChannelHandlerContext ctx,
                               Object evt)
                        throws Exception

Specified by:

userEventTriggered in interface io.netty.channel.ChannelInboundHandler

Overrides:

userEventTriggered in class io.netty.handler.codec.ByteToMessageDecoder

Throws:

Exception