Package com.linkedin.alpini.netty4.handlers

Class HttpServerStatisticsHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

com.linkedin.alpini.netty4.handlers.ChannelInitializer<C>

com.linkedin.alpini.netty4.handlers.SimpleChannelInitializer<io.netty.channel.Channel>

com.linkedin.alpini.netty4.handlers.HttpServerStatisticsHandler

All Implemented Interfaces:

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

@Sharable
public abstract class HttpServerStatisticsHandler
extends SimpleChannelInitializer<io.netty.channel.Channel>

An abstract handler which may be used to examine latencies in the Netty4 HTTP request processing. It is intended to be placed immediately after HttpServerCodec or BasicHttpServerCodec handlers. When the BasicHttpServerCodec is used, the request start time is the time when the first line of the request containing the URI was received. Extend this class, overriding the complete(Stats) method to process the HttpServerStatisticsHandler.Stats objects. The instance is sharable.

   final HttpServerStatisticsHandler _stats = new HttpServerStatisticsHandler() {
     &at;Override
     protected void complete(Stats stats) {
       ...
     }
   };

   final ChannelHandler _initialization = new ChannelInitializer<Channel>() {
     &at;Override
     protected void initChannel(Channel ch) {
       ChannelPipeline p = ch.pipeline();

       ...

       p.addLast("http-server-codec", new HttpServerCodec());
       p.addLast("http-server-stats", _stats);

       ...
     }
   }

 

Created by acurtis on 5/1/18.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HttpServerStatisticsHandler.Stats

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

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor	Description
HttpServerStatisticsHandler()

Method Summary

Modifier and Type	Method	Description
protected abstract void	complete(HttpServerStatisticsHandler.Stats stats)	This method is invoked for every complete HttpServerStatisticsHandler.Stats object.
protected void	initChannel(io.netty.channel.Channel ch)	This method will be called once the Channel was registered.

Methods inherited from class com.linkedin.alpini.netty4.handlers.SimpleChannelInitializer

addAfter, addAfter, addAfter, addAfter, addAfter, addAfter, addAfter

Methods inherited from class com.linkedin.alpini.netty4.handlers.ChannelInitializer

channelRegistered, currentContext, exceptionCaught, handlerAdded, handlerRemoved

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggered

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

Constructor Detail

HttpServerStatisticsHandler

public HttpServerStatisticsHandler()

Method Detail

initChannel

protected void initChannel(io.netty.channel.Channel ch)
                    throws java.lang.Exception

Description copied from class: ChannelInitializer

This method will be called once the Channel was registered. After the method returns this instance will be removed from the ChannelPipeline of the Channel.

Specified by:

initChannel in class ChannelInitializer<io.netty.channel.Channel>

Parameters:

ch - the Channel which was registered.

Throws:

java.lang.Exception - is thrown if an error occurs. In that case it will be handled by ChannelInitializer.exceptionCaught(ChannelHandlerContext, Throwable) which will by default close the Channel.

complete

protected abstract void complete(HttpServerStatisticsHandler.Stats stats)

This method is invoked for every complete HttpServerStatisticsHandler.Stats object.

Parameters:

stats - statistics