Package io.netty.handler.codec.http2

Class EspressoHttp2MultiplexHandler

java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
io.netty.channel.ChannelDuplexHandler
io.netty.handler.codec.http2.Http2ChannelDuplexHandler
io.netty.handler.codec.http2.EspressoHttp2MultiplexHandler
All Implemented Interfaces:
io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.ChannelOutboundHandler
public final class EspressoHttp2MultiplexHandler extends io.netty.handler.codec.http2.Http2ChannelDuplexHandler
Forked from Netty's Http2MultiplexHandler (4.1.42) (https://github.com/netty/netty/blob/4.1/codec-http2/src/main/java/io/netty/handler/codec/http2/Http2MultiplexHandler.java) In HTTP/1.1, the requests from the client are distributed across 48 workers threads of router. With HTTP/2 there will be only connection between the client -> router, all the requests for a given client are executed on a single I/O worker thread. If there are less than 48 client to a given router, not all threads will be utilized. To mitigate this, this rb forks Netty's multiplex handler and registers the child channels on different I/O workers. This will help distribute the work on to different threads. Design document - https://iwww.corp.linkedin.com/wiki/cf/pages/viewpage.action?pageId=323757534

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    class 
    EspressoHttp2MultiplexHandler.EspressoHttp2MultiplexHandlerStreamChannel
     

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

    io.netty.channel.ChannelHandler.Sharable

  • Constructor Summary

    Constructors
    Constructor
    Description
    EspressoHttp2MultiplexHandler(io.netty.channel.ChannelHandler inboundStreamHandler)
    Creates a new instance
    EspressoHttp2MultiplexHandler(io.netty.channel.ChannelHandler inboundStreamHandler, boolean reuseChildChannels, boolean offloadChildChannels)
     
    EspressoHttp2MultiplexHandler(io.netty.channel.ChannelHandler inboundStreamHandler, io.netty.channel.ChannelHandler upgradeStreamHandler)
    Creates a new instance

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    channelInactive(io.netty.channel.ChannelHandlerContext ctx)
     
    void
    channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
     
    void
    channelReadComplete(io.netty.channel.ChannelHandlerContext ctx)
    Notifies any child streams of the read completion.
    void
    channelWritabilityChanged(io.netty.channel.ChannelHandlerContext ctx)
     
    void
    exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
     
    Queue<io.netty.handler.codec.http2.EspressoAbstractHttp2StreamChannel>
    getChildChannelPool()
     
    protected void
    handlerAdded0(io.netty.channel.ChannelHandlerContext ctx)
     
    protected void
    handlerRemoved0(io.netty.channel.ChannelHandlerContext ctx)
     
    void
    userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)
     

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

    forEachActiveStream, handlerAdded, handlerRemoved, newStream

    Methods inherited from class io.netty.channel.ChannelDuplexHandler

    bind, close, connect, deregister, disconnect, flush, read, write

    Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

    channelActive, 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

  • Constructor Details

    • EspressoHttp2MultiplexHandler

      public EspressoHttp2MultiplexHandler(io.netty.channel.ChannelHandler inboundStreamHandler)
      Creates a new instance
      Parameters:
      inboundStreamHandler - the ChannelHandler that will be added to the { ChannelPipeline} of the Channels created for new inbound streams.

    • EspressoHttp2MultiplexHandler

      public EspressoHttp2MultiplexHandler(io.netty.channel.ChannelHandler inboundStreamHandler, io.netty.channel.ChannelHandler upgradeStreamHandler)
      Creates a new instance
      Parameters:
      inboundStreamHandler - the ChannelHandler that will be added to the { ChannelPipeline} of the Channels created for new inbound streams.
      upgradeStreamHandler - the ChannelHandler that will be added to the { ChannelPipeline} of the upgraded Channel.

    • EspressoHttp2MultiplexHandler

      public EspressoHttp2MultiplexHandler(io.netty.channel.ChannelHandler inboundStreamHandler, boolean reuseChildChannels, boolean offloadChildChannels)

  • Method Details

    • getChildChannelPool

      public Queue<io.netty.handler.codec.http2.EspressoAbstractHttp2StreamChannel> getChildChannelPool()

    • handlerAdded0

      protected void handlerAdded0(io.netty.channel.ChannelHandlerContext ctx)
      Overrides:
      handlerAdded0 in class io.netty.handler.codec.http2.Http2ChannelDuplexHandler

    • handlerRemoved0

      protected void handlerRemoved0(io.netty.channel.ChannelHandlerContext ctx)
      Overrides:
      handlerRemoved0 in class io.netty.handler.codec.http2.Http2ChannelDuplexHandler

    • channelInactive

      public void channelInactive(io.netty.channel.ChannelHandlerContext ctx) throws Exception
      Specified by:
      channelInactive in interface io.netty.channel.ChannelInboundHandler
      Overrides:
      channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter
      Throws:
      Exception

    • 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.channel.ChannelInboundHandlerAdapter
      Throws:
      Exception

    • channelWritabilityChanged

      public void channelWritabilityChanged(io.netty.channel.ChannelHandlerContext ctx) throws Exception
      Specified by:
      channelWritabilityChanged in interface io.netty.channel.ChannelInboundHandler
      Overrides:
      channelWritabilityChanged in class io.netty.channel.ChannelInboundHandlerAdapter
      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.channel.ChannelInboundHandlerAdapter
      Throws:
      Exception

    • 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.channel.ChannelInboundHandlerAdapter
      Throws:
      Exception

    • channelReadComplete

      public void channelReadComplete(io.netty.channel.ChannelHandlerContext ctx) throws Exception
      Notifies any child streams of the read completion.
      Specified by:
      channelReadComplete in interface io.netty.channel.ChannelInboundHandler
      Overrides:
      channelReadComplete in class io.netty.channel.ChannelInboundHandlerAdapter
      Throws:
      Exception