io.netty.channel.CombinedChannelDuplexHandler源码实例Demo-ICode联盟

类io.netty.channel.CombinedChannelDuplexHandler源码实例Demo

下面列出了怎么用io.netty.channel.CombinedChannelDuplexHandler的API类实例代码及写法，或者点击链接到github查看源代码。

源代码1 项目： reactor-netty 文件： HttpOperations.java

static void autoAddHttpExtractor(Connection c, String name, ChannelHandler handler){

		if (handler instanceof ByteToMessageDecoder
				|| handler instanceof ByteToMessageCodec
				|| handler instanceof CombinedChannelDuplexHandler) {
			String extractorName = name+"$extractor";

			if(c.channel().pipeline().context(extractorName) != null){
				return;
			}

			c.channel().pipeline().addBefore(name, extractorName, HTTP_EXTRACTOR);

			if(c.isPersistent()){
				c.onTerminate().subscribe(null, null, () -> c.removeHandler(extractorName));
			}

		}
	}

源代码2 项目： xio 文件： ChicagoNode.java

private CombinedChannelDuplexHandler<ChicagoResponseDecoder, ChicagoRequestEncoder>
    newMessageHandler() {
  return new CombinedChannelDuplexHandler<ChicagoResponseDecoder, ChicagoRequestEncoder>(
      new ChicagoResponseDecoder(), new ChicagoRequestEncoder());
}

源代码3 项目： xio 文件： ChicagoNode.java

private CombinedChannelDuplexHandler<Murmur3HashedFrameDecoder, Murmur3HashedFrameEncoder>
    newMurmur3HashHandler() {
  return new CombinedChannelDuplexHandler<Murmur3HashedFrameDecoder, Murmur3HashedFrameEncoder>(
      new Murmur3HashedFrameDecoder(), new Murmur3HashedFrameEncoder());
}

源代码4 项目： xio 文件： ChicagoNode.java

private CombinedChannelDuplexHandler<LengthFieldBasedFrameDecoder, LengthFieldPrepender>
    newLengthFieldBasedFrameHandler() {
  return new CombinedChannelDuplexHandler<LengthFieldBasedFrameDecoder, LengthFieldPrepender>(
      new LengthFieldBasedFrameDecoder(65535, 0, 2, 0, 2), new LengthFieldPrepender(2));
}

类所在包

io.netty.channel

类方法

同包方法

io.netty.channel.ChannelHandlerContext

io.netty.channel.nio.NioEventLoopGroup

io.netty.channel.Channel

io.netty.channel.ChannelInitializer

io.netty.channel.socket.nio.NioServerSocketChannel

io.netty.channel.EventLoopGroup

io.netty.channel.socket.SocketChannel

io.netty.channel.ChannelFuture

io.netty.channel.ChannelOption

io.netty.channel.socket.nio.NioSocketChannel

io.netty.channel.SimpleChannelInboundHandler

io.netty.channel.ChannelFutureListener

io.netty.channel.ChannelPipeline

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelHandler

io.netty.channel.ChannelPromise

io.netty.channel.epoll.EpollEventLoopGroup

io.netty.channel.ChannelDuplexHandler

io.netty.channel.epoll.EpollServerSocketChannel

io.netty.channel.ChannelHandler.Sharable

io.netty.channel.epoll.Epoll

io.netty.channel.group.DefaultChannelGroup

io.netty.channel.group.ChannelGroup

io.netty.channel.epoll.EpollSocketChannel

io.netty.channel.embedded.EmbeddedChannel

io.netty.channel.socket.DatagramPacket

io.netty.channel.ChannelOutboundHandlerAdapter

io.netty.channel.socket.nio.NioDatagramChannel

io.netty.channel.EventLoop

io.netty.channel.ServerChannel

io.netty.channel.ChannelConfig

io.netty.channel.ChannelInboundHandler

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.WriteBufferWaterMark

io.netty.channel.socket.ServerSocketChannel

io.netty.channel.DefaultFileRegion

io.netty.channel.ChannelId

io.netty.channel.ChannelOutboundHandler

io.netty.channel.FileRegion

io.netty.channel.socket.DatagramChannel

io.netty.channel.epoll.EpollChannelOption

io.netty.channel.epoll.EpollDatagramChannel

io.netty.channel.kqueue.KQueueEventLoopGroup

io.netty.channel.unix.DomainSocketAddress

io.netty.channel.ConnectTimeoutException

io.netty.channel.ChannelException

io.netty.channel.DefaultChannelPromise

io.netty.channel.FixedRecvByteBufAllocator

io.netty.channel.AdaptiveRecvByteBufAllocator

io.netty.channel.kqueue.KQueue

io.netty.channel.local.LocalChannel

io.netty.channel.DefaultEventLoopGroup

io.netty.channel.group.ChannelGroupFuture

io.netty.channel.CombinedChannelDuplexHandler

io.netty.channel.kqueue.KQueueSocketChannel

io.netty.channel.ChannelProgressivePromise

io.netty.channel.AbstractChannel

io.netty.channel.ChannelMetadata

io.netty.channel.oio.OioEventLoopGroup

io.netty.channel.epoll.EpollDomainSocketChannel

io.netty.channel.local.LocalAddress

io.netty.channel.ChannelFactory

io.netty.channel.pool.ChannelPoolHandler

io.netty.channel.kqueue.KQueueServerSocketChannel

io.netty.channel.socket.SocketChannelConfig

io.netty.channel.local.LocalServerChannel

io.netty.channel.pool.SimpleChannelPool

io.netty.channel.pool.ChannelPool

io.netty.channel.DefaultEventLoop

io.netty.channel.ChannelProgressiveFuture

io.netty.channel.socket.oio.OioSocketChannel

io.netty.channel.DefaultChannelConfig

io.netty.channel.ChannelOutboundBuffer

io.netty.channel.kqueue.KQueueDomainSocketChannel

io.netty.channel.epoll.EpollServerDomainSocketChannel

io.netty.channel.socket.oio.OioServerSocketChannel

io.netty.channel.ChannelProgressiveFutureListener

io.netty.channel.RecvByteBufAllocator

io.netty.channel.pool.AbstractChannelPoolMap

io.netty.channel.pool.FixedChannelPool

io.netty.channel.MultithreadEventLoopGroup

io.netty.channel.socket.InternetProtocolFamily

io.netty.channel.kqueue.KQueueServerDomainSocketChannel

io.netty.channel.udt.nio.NioUdtProvider

io.netty.channel.pool.AbstractChannelPoolHandler

io.netty.channel.DefaultChannelId

io.netty.channel.pool.ChannelPoolMap

io.netty.channel.ChannelOutboundInvoker

io.netty.channel.MessageSizeEstimator

io.netty.channel.SingleThreadEventLoop

io.netty.channel.epoll.EpollMode

io.netty.channel.sctp.nio.NioSctpServerChannel

io.netty.channel.unix.UnixChannel

io.netty.channel.unix.Errors

io.netty.channel.unix.DomainSocketChannel

io.netty.channel.sctp.nio.NioSctpChannel

io.netty.channel.pool.ChannelHealthChecker

io.netty.channel.AbstractServerChannel

io.netty.channel.local.LocalEventLoopGroup

io.netty.channel.sctp.SctpChannel

io.netty.channel.sctp.SctpMessage

io.netty.channel.group.ChannelGroupFutureListener

io.netty.channel.kqueue.KQueueDatagramChannel

io.netty.channel.socket.DuplexChannel

io.netty.channel.unix.ServerDomainSocketChannel

io.netty.channel.sctp.SctpChannelOption

io.netty.channel.PendingWriteQueue

io.netty.channel.unix.Errors.NativeIoException

io.netty.channel.rxtx.RxtxChannel

io.netty.channel.socket.ServerSocketChannelConfig

io.netty.channel.socket.ChannelInputShutdownEvent

io.netty.channel.ReflectiveChannelFactory

io.netty.channel.socket.ChannelInputShutdownReadComplete

io.netty.channel.nio.NioEventLoop

io.netty.channel.AddressedEnvelope

io.netty.channel.socket.DefaultSocketChannelConfig

io.netty.channel.nio.AbstractNioMessageChannel

io.netty.channel.unix.UnixChannelOption

io.netty.channel.DefaultChannelPipeline

io.netty.channel.DefaultMessageSizeEstimator

io.netty.channel.oio.OioByteStreamChannel

io.netty.channel.Channel.Unsafe

io.netty.channel.PreferHeapByteBufAllocator

io.netty.channel.sctp.SctpServerChannel

io.netty.channel.rxtx.RxtxDeviceAddress

io.netty.channel.udt.UdtChannel