Modifier and Type | Method and Description |
---|---|
void |
CombinedChannelDuplexHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
|
void |
ChannelOutboundHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
调用一次绑定操作。
|
void |
ChannelDuplexHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.channelActive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelActive(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelActive(ChannelHandlerContext ctx)
ChannelHandlerContext 的Channel 现在处于活动状态
|
void |
CombinedChannelDuplexHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelInactive(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelInactive(ChannelHandlerContext ctx)
ChannelHandlerContext 的Channel 已注册,现在处于非活动状态,并已达到其使用期限。
|
void |
SimpleChannelInboundHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
CombinedChannelDuplexHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
ChannelInboundHandlerAdapter.channelRead(ChannelHandlerContext ctx, java.lang.Object msg)
|
void |
ChannelInboundHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg)
当前 Channel 已从对端读取消息时调用。
|
protected abstract void |
SimpleChannelInboundHandler.channelRead0(ChannelHandlerContext ctx, I msg)
请记住,此方法将在5.0中重命名为 messageReceived(ChannelHandlerContext, I) 。
|
void |
CombinedChannelDuplexHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelReadComplete(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelReadComplete(ChannelHandlerContext ctx)
在当前读取操作读取的最后一条消息已被
ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) 使用时
调用 。
|
void |
CombinedChannelDuplexHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInitializer.channelRegistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelRegistered(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelRegistered(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelUnregistered(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelUnregistered(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChannelInboundHandlerAdapter.channelWritabilityChanged(ChannelHandlerContext ctx)
|
void |
ChannelInboundHandler.channelWritabilityChanged(ChannelHandlerContext ctx)
|
void |
CombinedChannelDuplexHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.close(ChannelHandlerContext ctx, ChannelPromise promise)
|
void |
ChannelOutboundHandler.close(ChannelHandlerContext ctx, ChannelPromise promise)
一旦进行了密切的操作,就会被调用。
|
void |
ChannelDuplexHandler.close(ChannelHandlerContext ctx, ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
|
void |
ChannelOutboundHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
连接操作完成后调用。
|
void |
ChannelDuplexHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.deregister(ChannelHandlerContext ctx, ChannelPromise promise)
|
void |
ChannelOutboundHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise)
一旦从当前注册的 EventLoop 开始取消注册操作,就会被调用。
|
void |
ChannelDuplexHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
|
void |
ChannelOutboundHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
调用一次断开操作。
|
void |
ChannelDuplexHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
|
void |
CombinedChannelDuplexHandler.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) |
void |
ChannelInitializer.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause)
通过登录并关闭 Throwable 来处理Throwable 。
|
void |
ChannelInboundHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause)
|
void |
ChannelInboundHandler.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause)
获取如果
Throwable 被抛出。
|
void |
ChannelHandlerAdapter.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause)
|
void |
ChannelHandler.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause)
已过时。
|
void |
CombinedChannelDuplexHandler.flush(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandlerAdapter.flush(ChannelHandlerContext ctx)
致电 flush() 转发到ChannelPipeline 中的下一个ChannelOutboundHandler 。
|
void |
ChannelOutboundHandler.flush(ChannelHandlerContext ctx)
调用一次冲洗操作。
|
void |
ChannelDuplexHandler.flush(ChannelHandlerContext ctx)
致电 flush() 转发到ChannelPipeline 中的下一个ChannelOutboundHandler 。
|
void |
CombinedChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelInitializer.handlerAdded(ChannelHandlerContext ctx)
子类可以忽略这个方法。
|
void |
ChannelHandlerAdapter.handlerAdded(ChannelHandlerContext ctx)
子类可以忽略这个方法。
|
void |
ChannelHandler.handlerAdded(ChannelHandlerContext ctx)
在 ChannelHandler 被添加到实际上下文之后调用,并准备好处理事件。
|
void |
CombinedChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ChannelHandlerAdapter.handlerRemoved(ChannelHandlerContext ctx)
子类可以忽略这个方法。
|
void |
ChannelHandler.handlerRemoved(ChannelHandlerContext ctx)
在 ChannelHandler 已从实际上下文中删除后调用,它不再处理事件。
|
void |
CombinedChannelDuplexHandler.read(ChannelHandlerContext ctx) |
void |
ChannelOutboundHandlerAdapter.read(ChannelHandlerContext ctx)
致电 read() 转发到ChannelPipeline 中的下一个ChannelOutboundHandler 。
|
void |
ChannelOutboundHandler.read(ChannelHandlerContext ctx)
拦截
read() 。
|
void |
ChannelDuplexHandler.read(ChannelHandlerContext ctx)
致电 read() 转发到ChannelPipeline 中的下一个ChannelOutboundHandler 。
|
void |
CombinedChannelDuplexHandler.userEventTriggered(ChannelHandlerContext ctx, java.lang.Object evt) |
void |
ChannelInboundHandlerAdapter.userEventTriggered(ChannelHandlerContext ctx, java.lang.Object evt)
|
void |
ChannelInboundHandler.userEventTriggered(ChannelHandlerContext ctx, java.lang.Object evt)
获取调用是否触发了用户事件。
|
void |
CombinedChannelDuplexHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
ChannelOutboundHandlerAdapter.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
|
void |
ChannelOutboundHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
一旦写入操作被调用,就调用它。
|
void |
ChannelDuplexHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
|
void |
AbstractCoalescingBufferQueue.writeAndRemoveAll(ChannelHandlerContext ctx)
将所有剩余的元素写入此队列中。
|
Constructor and Description |
---|
PendingWriteQueue(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected ChannelHandlerContext |
MessageAggregator.ctx() |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
MessageToByteEncoder.allocateBuffer(ChannelHandlerContext ctx, I msg, boolean preferDirect)
分配一个 ByteBuf ,它将用作#encode(ChannelHandlerContext, I, ByteBuf) 参数。
|
void |
DatagramPacketEncoder.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
protected void |
ReplayingDecoder.callDecode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
ByteToMessageDecoder.callDecode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out)
|
void |
DatagramPacketDecoder.channelActive(ChannelHandlerContext ctx) |
void |
MessageAggregator.channelInactive(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelInactive(ChannelHandlerContext ctx) |
void |
MessageToMessageDecoder.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
MessageToMessageCodec.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
ByteToMessageDecoder.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
ByteToMessageCodec.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
MessageAggregator.channelReadComplete(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.channelReadComplete(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelRegistered(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelUnregistered(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
DatagramPacketEncoder.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
protected java.lang.Object |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf buffer)
从 ByteBuf 中创建一个框架并将其返回。
|
protected java.lang.Object |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in)
从 ByteBuf 中创建一个框架并将其返回。
|
protected java.lang.Object |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in)
从 ByteBuf 中创建一个框架并将其返回。
|
protected java.lang.Object |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf buffer)
从 ByteBuf 中创建一个框架并将其返回。
|
protected void |
LineBasedFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
LengthFieldBasedFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
FixedLengthFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
DelimiterBasedFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected abstract void |
ByteToMessageDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out)
解码从一个 ByteBuf 到另一个。
|
protected abstract void |
ByteToMessageCodec.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
DatagramPacketDecoder.decode(ChannelHandlerContext ctx, DatagramPacket msg, java.util.List<java.lang.Object> out) |
protected abstract void |
MessageToMessageDecoder.decode(ChannelHandlerContext ctx, I msg, java.util.List<java.lang.Object> out)
从一条消息解码到另一条消息。
|
protected void |
MessageAggregator.decode(ChannelHandlerContext ctx, I msg, java.util.List<java.lang.Object> out) |
protected abstract void |
MessageToMessageCodec.decode(ChannelHandlerContext ctx, INBOUND_IN msg, java.util.List<java.lang.Object> out) |
protected void |
ByteToMessageDecoder.decodeLast(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out)
当 ChannelHandlerContext 处于非活动状态时称为最后一次。
|
protected void |
ByteToMessageCodec.decodeLast(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
void |
DatagramPacketEncoder.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
DatagramPacketEncoder.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
protected void |
DatagramPacketEncoder.encode(ChannelHandlerContext ctx, AddressedEnvelope<M,java.net.InetSocketAddress> msg, java.util.List<java.lang.Object> out) |
protected void |
LengthFieldPrepender.encode(ChannelHandlerContext ctx, ByteBuf msg, java.util.List<java.lang.Object> out) |
protected abstract void |
MessageToByteEncoder.encode(ChannelHandlerContext ctx, I msg, ByteBuf out)
将消息编码成 ByteBuf 。
|
protected abstract void |
ByteToMessageCodec.encode(ChannelHandlerContext ctx, I msg, ByteBuf out) |
protected abstract void |
MessageToMessageEncoder.encode(ChannelHandlerContext ctx, I msg, java.util.List<java.lang.Object> out)
从一条消息编码到另一条消息。
|
protected abstract void |
MessageToMessageCodec.encode(ChannelHandlerContext ctx, OUTBOUND_IN msg, java.util.List<java.lang.Object> out) |
void |
DatagramPacketEncoder.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) |
void |
DatagramPacketDecoder.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) |
protected ByteBuf |
LengthFieldBasedFrameDecoder.extractFrame(ChannelHandlerContext ctx, ByteBuf buffer, int index, int length)
提取指定缓冲区的子区域。
|
void |
DatagramPacketEncoder.flush(ChannelHandlerContext ctx) |
protected void |
MessageAggregator.handleOversizedMessage(ChannelHandlerContext ctx, S oversized)
当传入请求超过最大内容长度时调用。
|
void |
MessageAggregator.handlerAdded(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
MessageAggregator.handlerRemoved(ChannelHandlerContext ctx) |
void |
DatagramPacketEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
ByteToMessageDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
ByteToMessageCodec.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
ByteToMessageDecoder.handlerRemoved0(ChannelHandlerContext ctx)
在 ByteToMessageDecoder 从实际上下文中移除并且不再处理事件之后调用。
|
void |
DatagramPacketEncoder.read(ChannelHandlerContext ctx) |
void |
DatagramPacketDecoder.userEventTriggered(ChannelHandlerContext ctx, java.lang.Object evt) |
void |
ByteToMessageDecoder.userEventTriggered(ChannelHandlerContext ctx, java.lang.Object evt) |
void |
MessageToMessageEncoder.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
MessageToMessageCodec.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
MessageToByteEncoder.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
ByteToMessageCodec.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
Base64Decoder.decode(ChannelHandlerContext ctx, ByteBuf msg, java.util.List<java.lang.Object> out) |
protected void |
Base64Encoder.encode(ChannelHandlerContext ctx, ByteBuf msg, java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
ByteArrayDecoder.decode(ChannelHandlerContext ctx, ByteBuf msg, java.util.List<java.lang.Object> out) |
protected void |
ByteArrayEncoder.encode(ChannelHandlerContext ctx, byte[] msg, java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
LzmaFrameEncoder.allocateBuffer(ChannelHandlerContext ctx, ByteBuf in, boolean preferDirect) |
protected ByteBuf |
Lz4FrameEncoder.allocateBuffer(ChannelHandlerContext ctx, ByteBuf msg, boolean preferDirect) |
protected ByteBuf |
JdkZlibEncoder.allocateBuffer(ChannelHandlerContext ctx, ByteBuf msg, boolean preferDirect) |
void |
Lz4FrameEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
JdkZlibEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
JZlibEncoder.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
Bzip2Encoder.close(ChannelHandlerContext ctx, ChannelPromise promise) |
protected void |
SnappyFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
LzfDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
Lz4FrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
JdkZlibDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
JZlibDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
FastLzFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
Bzip2Decoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
SnappyFrameEncoder.encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) |
protected void |
LzmaFrameEncoder.encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) |
protected void |
LzfEncoder.encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) |
protected void |
Lz4FrameEncoder.encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out)
将消息编码成 ByteBuf 。
|
protected void |
JdkZlibEncoder.encode(ChannelHandlerContext ctx, ByteBuf uncompressed, ByteBuf out) |
protected void |
JZlibEncoder.encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) |
protected void |
FastLzFrameEncoder.encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) |
protected void |
Bzip2Encoder.encode(ChannelHandlerContext ctx, ByteBuf in, ByteBuf out) |
void |
Lz4FrameEncoder.flush(ChannelHandlerContext ctx) |
void |
Lz4FrameEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JdkZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
JZlibEncoder.handlerAdded(ChannelHandlerContext ctx) |
void |
Bzip2Encoder.handlerAdded(ChannelHandlerContext ctx) |
void |
Lz4FrameEncoder.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
JdkZlibDecoder.handlerRemoved0(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
DatagramDnsQueryEncoder.allocateBuffer(ChannelHandlerContext ctx, AddressedEnvelope<DnsQuery,java.net.InetSocketAddress> msg)
分配将用于构造数据报包的 ByteBuf 。
|
protected ByteBuf |
DatagramDnsResponseEncoder.allocateBuffer(ChannelHandlerContext ctx, AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> msg)
分配将用于构造数据报包的 ByteBuf 。
|
protected void |
DatagramDnsResponseDecoder.decode(ChannelHandlerContext ctx, DatagramPacket packet, java.util.List<java.lang.Object> out) |
protected void |
DatagramDnsQueryDecoder.decode(ChannelHandlerContext ctx, DatagramPacket packet, java.util.List<java.lang.Object> out) |
protected void |
DatagramDnsQueryEncoder.encode(ChannelHandlerContext ctx, AddressedEnvelope<DnsQuery,java.net.InetSocketAddress> in, java.util.List<java.lang.Object> out) |
protected void |
DatagramDnsResponseEncoder.encode(ChannelHandlerContext ctx, AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> in, java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
void |
HAProxyMessageDecoder.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
protected void |
HAProxyMessageDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
Modifier and Type | Field and Description |
---|---|
protected ChannelHandlerContext |
HttpContentDecoder.ctx |
Modifier and Type | Method and Description |
---|---|
void |
HttpClientUpgradeHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
HttpContentEncoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
HttpServerKeepAliveHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
HttpServerExpectContinueHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
HttpClientUpgradeHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
HttpClientUpgradeHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
protected void |
HttpObjectDecoder.decode(ChannelHandlerContext ctx, ByteBuf buffer, java.util.List<java.lang.Object> out) |
protected void |
HttpServerUpgradeHandler.decode(ChannelHandlerContext ctx, HttpObject msg, java.util.List<java.lang.Object> out) |
protected void |
HttpContentDecoder.decode(ChannelHandlerContext ctx, HttpObject msg, java.util.List<java.lang.Object> out) |
protected void |
HttpClientUpgradeHandler.decode(ChannelHandlerContext ctx, HttpObject msg, java.util.List<java.lang.Object> out) |
protected void |
HttpContentEncoder.decode(ChannelHandlerContext ctx, HttpRequest msg, java.util.List<java.lang.Object> out) |
protected void |
HttpObjectDecoder.decodeLast(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
void |
HttpClientUpgradeHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
HttpClientUpgradeHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
protected void |
HttpContentEncoder.encode(ChannelHandlerContext ctx, HttpObject msg, java.util.List<java.lang.Object> out) |
protected void |
HttpObjectEncoder.encode(ChannelHandlerContext ctx, java.lang.Object msg, java.util.List<java.lang.Object> out) |
void |
HttpClientUpgradeHandler.flush(ChannelHandlerContext ctx) |
protected void |
HttpObjectAggregator.handleOversizedMessage(ChannelHandlerContext ctx, HttpMessage oversized) |
void |
HttpContentDecoder.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentCompressor.handlerAdded(ChannelHandlerContext ctx) |
void |
HttpContentEncoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpContentDecoder.handlerRemoved(ChannelHandlerContext ctx) |
void |
HttpClientUpgradeHandler.SourceCodec.prepareUpgradeFrom(ChannelHandlerContext ctx)
删除或禁用此编解码器的编码器,以便 HttpClientUpgradeHandler.UpgradeCodec 可以发送初始问候语(如果有)。
|
void |
HttpClientCodec.prepareUpgradeFrom(ChannelHandlerContext ctx)
准备从HTTP升级到另一个协议。
|
boolean |
HttpServerUpgradeHandler.UpgradeCodec.prepareUpgradeResponse(ChannelHandlerContext ctx, FullHttpRequest upgradeRequest, HttpHeaders upgradeHeaders)
备
upgradeHeaders 为基于内容的协议更新
upgradeRequest 。
|
void |
HttpClientUpgradeHandler.read(ChannelHandlerContext ctx) |
HttpContent |
HttpChunkedInput.readChunk(ChannelHandlerContext ctx)
已过时。
|
java.util.Collection<java.lang.CharSequence> |
HttpClientUpgradeHandler.UpgradeCodec.setUpgradeHeaders(ChannelHandlerContext ctx, HttpRequest upgradeRequest)
设置升级请求所需的任何协议专用标头。
|
void |
HttpServerUpgradeHandler.SourceCodec.upgradeFrom(ChannelHandlerContext ctx)
从管道中移除此编解码器(即所有关联的处理程序)。
|
void |
HttpServerCodec.upgradeFrom(ChannelHandlerContext ctx)
从HTTP升级到另一个协议。
|
void |
HttpClientUpgradeHandler.SourceCodec.upgradeFrom(ChannelHandlerContext ctx)
从管道中移除此编解码器(即所有关联的处理程序)。
|
void |
HttpClientCodec.upgradeFrom(ChannelHandlerContext ctx)
从HTTP升级到另一个协议。
|
void |
HttpServerUpgradeHandler.UpgradeCodec.upgradeTo(ChannelHandlerContext ctx, FullHttpRequest upgradeRequest)
从源代码编解码器执行HTTP协议升级。
|
void |
HttpClientUpgradeHandler.UpgradeCodec.upgradeTo(ChannelHandlerContext ctx, FullHttpResponse upgradeResponse)
从源代码编解码器执行HTTP协议升级。
|
void |
HttpObjectDecoder.userEventTriggered(ChannelHandlerContext ctx, java.lang.Object evt) |
void |
HttpServerKeepAliveHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
HttpClientUpgradeHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
CorsHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
CorsHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
HttpContent |
HttpPostRequestEncoder.readChunk(ChannelHandlerContext ctx)
已过时。
|
Modifier and Type | Method and Description |
---|---|
void |
Utf8FrameValidator.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
protected void |
WebSocket08FrameDecoder.checkCloseFrameBody(ChannelHandlerContext ctx, ByteBuf buffer) |
protected void |
WebSocket08FrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
WebSocket00FrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
WebSocketServerProtocolHandler.decode(ChannelHandlerContext ctx, WebSocketFrame frame, java.util.List<java.lang.Object> out) |
protected void |
WebSocketClientProtocolHandler.decode(ChannelHandlerContext ctx, WebSocketFrame frame, java.util.List<java.lang.Object> out) |
protected void |
WebSocket08FrameEncoder.encode(ChannelHandlerContext ctx, WebSocketFrame msg, java.util.List<java.lang.Object> out) |
protected void |
WebSocket00FrameEncoder.encode(ChannelHandlerContext ctx, WebSocketFrame msg, java.util.List<java.lang.Object> out) |
void |
WebSocketServerProtocolHandler.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) |
void |
WebSocketServerProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WebSocketClientProtocolHandler.handlerAdded(ChannelHandlerContext ctx) |
WebSocketFrame |
WebSocketChunkedInput.readChunk(ChannelHandlerContext ctx)
已过时。
使用
WebSocketChunkedInput.readChunk(ByteBufAllocator) 。
从流中获取分块的数据。
一旦此方法返回最后一个块并因此流到达末尾,任何后续WebSocketChunkedInput.isEndOfInput() 调用都必须返回true 。
|
Modifier and Type | Method and Description |
---|---|
void |
WebSocketServerExtensionHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
WebSocketClientExtensionHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
WebSocketServerExtensionHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
WebSocketClientExtensionHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
ChannelHandlerContext |
Http2RemoteFlowController.channelHandlerContext()
获取应用流量控制的 ChannelHandlerContext 。
|
ChannelHandlerContext |
DefaultHttp2RemoteFlowController.channelHandlerContext() |
Modifier and Type | Method and Description |
---|---|
void |
Http2ConnectionHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
Http2ConnectionHandler.channelActive(ChannelHandlerContext ctx) |
void |
Http2FlowController.channelHandlerContext(ChannelHandlerContext ctx)
设置应用流量控制的 ChannelHandlerContext 。
|
void |
DefaultHttp2RemoteFlowController.channelHandlerContext(ChannelHandlerContext ctx)
设置应用流量控制的 ChannelHandlerContext 。
|
void |
DefaultHttp2LocalFlowController.channelHandlerContext(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
InboundHttpToHttp2Adapter.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
Http2MultiplexCodec.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
Http2MultiplexCodec.channelReadComplete(ChannelHandlerContext ctx)
通知读取完成的任何子流。
|
void |
Http2ConnectionHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
Http2ConnectionHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
protected void |
Http2ConnectionHandler.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
Http2StreamFrameToHttpObjectCodec.decode(ChannelHandlerContext ctx, Http2StreamFrame frame, java.util.List<java.lang.Object> out) |
void |
Http2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out)
由 Http2ConnectionHandler 调用来解码来自输入缓冲区的下一帧。
|
void |
DefaultHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
void |
DecoratingHttp2ConnectionDecoder.decodeFrame(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
void |
Http2ConnectionHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
Http2ConnectionHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
protected void |
Http2StreamFrameToHttpObjectCodec.encode(ChannelHandlerContext ctx, HttpObject obj, java.util.List<java.lang.Object> out)
|
void |
Http2RemoteFlowController.FlowControlled.error(ChannelHandlerContext ctx, java.lang.Throwable cause)
被调用以指示在可以完全写入此对象之前发生错误。
|
void |
Http2ConnectionHandler.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause)
处理从其他处理程序抛出的对象 Http2Exception 。
|
protected void |
InboundHttp2ToHttpAdapter.fireChannelRead(ChannelHandlerContext ctx, FullHttpMessage msg, boolean release, Http2Stream stream)
设置最终标题并启动频道阅读事件
|
void |
Http2ConnectionHandler.flush(ChannelHandlerContext ctx) |
ChannelFuture |
Http2LifecycleManager.goAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
如果
errorCode 不是
Http2Error.NO_ERROR ,则阻止对等体创建流并关闭连接。
|
ChannelFuture |
Http2ConnectionHandler.goAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
void |
Http2StreamFrameToHttpObjectCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2FrameCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2ConnectionHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2ChannelDuplexHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
CleartextHttp2ServerUpgradeHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
Http2MultiplexCodec.handlerAdded0(ChannelHandlerContext ctx) |
protected void |
Http2ChannelDuplexHandler.handlerAdded0(ChannelHandlerContext ctx) |
void |
Http2ChannelDuplexHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
Http2MultiplexCodec.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
Http2ConnectionHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
Http2ChannelDuplexHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
Http2ConnectionHandler.handleServerHeaderDecodeSizeError(ChannelHandlerContext ctx, Http2Stream stream)
通知客户端此服务器已收到比它愿意接受的头大的头。
|
boolean |
Http2PromisedRequestVerifier.isAuthoritative(ChannelHandlerContext ctx, Http2Headers headers)
确定是否 Http2Headers 权威性的特定ChannelHandlerContext 。
|
protected boolean |
Http2StreamFrameToHttpObjectCodec.isSsl(ChannelHandlerContext ctx) |
void |
Http2FrameLogger.logData(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream) |
void |
Http2FrameLogger.logGoAway(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) |
void |
Http2FrameLogger.logHeaders(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) |
void |
Http2FrameLogger.logHeaders(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) |
void |
Http2FrameLogger.logPing(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, long data) |
void |
Http2FrameLogger.logPingAck(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, long data) |
void |
Http2FrameLogger.logPriority(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) |
void |
Http2FrameLogger.logPushPromise(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) |
void |
Http2FrameLogger.logRstStream(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, long errorCode) |
void |
Http2FrameLogger.logSettings(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, Http2Settings settings) |
void |
Http2FrameLogger.logSettingsAck(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx) |
void |
Http2FrameLogger.logUnknownFrame(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf data) |
void |
Http2FrameLogger.logWindowsUpdate(Http2FrameLogger.Direction direction, ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) |
boolean |
Http2RemoteFlowController.FlowControlled.merge(ChannelHandlerContext ctx, Http2RemoteFlowController.FlowControlled next)
将
next 消息的内容合并到该消息中,以便它们可以作为一个单元写出。
|
protected EmbeddedChannel |
CompressorHttp2ConnectionEncoder.newContentCompressor(ChannelHandlerContext ctx, java.lang.CharSequence contentEncoding)
返回一个新 EmbeddedChannel 编码指定编码的HTTP2消息内容contentEncoding 。
|
protected EmbeddedChannel |
DelegatingDecompressorFrameListener.newContentDecompressor(ChannelHandlerContext ctx, java.lang.CharSequence contentEncoding)
返回一个新的 EmbeddedChannel ,它解码在指定的contentEncoding 编码的contentEncoding 消息内容。
|
protected void |
Http2FrameCodec.onConnectionError(ChannelHandlerContext ctx, boolean outbound, java.lang.Throwable cause, Http2Exception http2Ex) |
protected void |
Http2ConnectionHandler.onConnectionError(ChannelHandlerContext ctx, boolean outbound, java.lang.Throwable cause, Http2Exception http2Ex)
处理程序出现连接错误。
|
int |
InboundHttp2ToHttpAdapter.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) |
int |
Http2FrameListenerDecorator.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) |
int |
Http2FrameListener.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream)
处理入站
DATA 帧。
|
int |
Http2FrameAdapter.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) |
int |
Http2EventAdapter.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) |
int |
DelegatingDecompressorFrameListener.onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream) |
void |
Http2LifecycleManager.onError(ChannelHandlerContext ctx, boolean outbound, java.lang.Throwable cause)
处理给定的错误。
|
void |
Http2ConnectionHandler.onError(ChannelHandlerContext ctx, boolean outbound, java.lang.Throwable cause)
HTTP / 2处理期间捕获的所有异常的中央处理程序。
|
void |
Http2FrameListenerDecorator.onGoAwayRead(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) |
void |
Http2FrameListener.onGoAwayRead(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData)
处理入站
GO_AWAY 框架。
|
void |
Http2FrameAdapter.onGoAwayRead(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) |
void |
Http2EventAdapter.onGoAwayRead(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData) |
void |
InboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endOfStream) |
void |
Http2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) |
void |
Http2FrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endOfStream)
处理入站
HEADERS 框架。
|
void |
Http2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) |
void |
Http2EventAdapter.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) |
void |
DelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) |
void |
InboundHttp2ToHttpAdapter.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream) |
void |
Http2FrameListenerDecorator.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) |
void |
Http2FrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream)
处理带有指定优先级信息的入站
HEADERS 帧。
|
void |
Http2FrameAdapter.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) |
void |
Http2EventAdapter.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) |
void |
DelegatingDecompressorFrameListener.onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream) |
void |
Http2FrameListenerDecorator.onPingAckRead(ChannelHandlerContext ctx, long data) |
void |
Http2FrameListener.onPingAckRead(ChannelHandlerContext ctx, long data)
处理入站
PING 确认。
|
void |
Http2FrameAdapter.onPingAckRead(ChannelHandlerContext ctx, long data) |
void |
Http2EventAdapter.onPingAckRead(ChannelHandlerContext ctx, long data) |
void |
Http2FrameListenerDecorator.onPingRead(ChannelHandlerContext ctx, long data) |
void |
Http2FrameListener.onPingRead(ChannelHandlerContext ctx, long data)
处理入站
PING 框架。
|
void |
Http2FrameAdapter.onPingRead(ChannelHandlerContext ctx, long data) |
void |
Http2EventAdapter.onPingRead(ChannelHandlerContext ctx, long data) |
void |
Http2FrameListenerDecorator.onPriorityRead(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) |
void |
Http2FrameListener.onPriorityRead(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive)
处理入站
PRIORITY 帧。
|
void |
Http2FrameAdapter.onPriorityRead(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) |
void |
Http2EventAdapter.onPriorityRead(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive) |
void |
InboundHttp2ToHttpAdapter.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) |
void |
Http2FrameListenerDecorator.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) |
void |
Http2FrameListener.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding)
处理入站
PUSH_PROMISE 帧。
|
void |
Http2FrameAdapter.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) |
void |
Http2EventAdapter.onPushPromiseRead(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding) |
void |
InboundHttp2ToHttpAdapter.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) |
void |
Http2FrameListenerDecorator.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) |
void |
Http2FrameListener.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode)
处理入站
RST_STREAM 帧。
|
void |
Http2FrameAdapter.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) |
void |
Http2EventAdapter.onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) |
void |
Http2FrameListenerDecorator.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2FrameListener.onSettingsAckRead(ChannelHandlerContext ctx)
处理入站
SETTINGS 确认帧。
|
void |
Http2FrameAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
Http2EventAdapter.onSettingsAckRead(ChannelHandlerContext ctx) |
void |
InboundHttp2ToHttpAdapter.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings) |
void |
Http2FrameListenerDecorator.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings) |
void |
Http2FrameListener.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings)
处理入站
SETTINGS 帧。
|
void |
Http2FrameAdapter.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings) |
void |
Http2EventAdapter.onSettingsRead(ChannelHandlerContext ctx, Http2Settings settings) |
protected void |
Http2FrameCodec.onStreamError(ChannelHandlerContext ctx, boolean outbound, java.lang.Throwable cause, Http2Exception.StreamException streamException)
对于未知数据流的例外情况(即没有附加 Http2FrameStream 对象的数据流)将被记录并通过发送RST_STREAM帧进行回复。
|
protected void |
Http2ConnectionHandler.onStreamError(ChannelHandlerContext ctx, boolean outbound, java.lang.Throwable cause, Http2Exception.StreamException http2Ex)
处理程序的流错误。
|
void |
Http2FrameListenerDecorator.onUnknownFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) |
void |
Http2FrameListener.onUnknownFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload)
处理程序不是由HTTP / 2规范定义的。
|
void |
Http2FrameAdapter.onUnknownFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) |
void |
Http2EventAdapter.onUnknownFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload) |
void |
Http2FrameListenerDecorator.onWindowUpdateRead(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) |
void |
Http2FrameListener.onWindowUpdateRead(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement)
处理入站
WINDOW_UPDATE 帧。
|
void |
Http2FrameAdapter.onWindowUpdateRead(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) |
void |
Http2EventAdapter.onWindowUpdateRead(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement) |
void |
Http2StreamChannelBootstrap.open0(ChannelHandlerContext ctx, Promise<Http2StreamChannel> promise) |
boolean |
Http2ServerUpgradeCodec.prepareUpgradeResponse(ChannelHandlerContext ctx, FullHttpRequest upgradeRequest, HttpHeaders headers) |
protected FullHttpMessage |
InboundHttp2ToHttpAdapter.processHeadersBegin(ChannelHandlerContext ctx, Http2Stream stream, Http2Headers headers, boolean endOfStream, boolean allowAppend, boolean appendToTrailer)
提供HTTP / 2和HTTP头对象之间的转换,同时确保流处于额外头的有效状态。
|
void |
Http2ConnectionHandler.read(ChannelHandlerContext ctx) |
void |
Http2InboundFrameLogger.readFrame(ChannelHandlerContext ctx, ByteBuf input, Http2FrameListener listener) |
void |
Http2FrameReader.readFrame(ChannelHandlerContext ctx, ByteBuf input, Http2FrameListener listener)
尝试从输入缓冲区读取下一帧。
|
void |
DefaultHttp2FrameReader.readFrame(ChannelHandlerContext ctx, ByteBuf input, Http2FrameListener listener) |
ChannelFuture |
Http2LifecycleManager.resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
确保重置由
streamId 标识的流。
|
ChannelFuture |
Http2ConnectionHandler.resetStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
java.util.Collection<java.lang.CharSequence> |
Http2ClientUpgradeCodec.setUpgradeHeaders(ChannelHandlerContext ctx, HttpRequest upgradeRequest) |
static ByteBuf |
Http2CodecUtil.toByteBuf(ChannelHandlerContext ctx, java.lang.Throwable cause)
创建一个包含来自给定异常的错误消息的缓冲区。
|
void |
Http2ServerUpgradeCodec.upgradeTo(ChannelHandlerContext ctx, FullHttpRequest upgradeRequest) |
void |
Http2ClientUpgradeCodec.upgradeTo(ChannelHandlerContext ctx, FullHttpResponse upgradeResponse) |
void |
Http2FrameCodec.userEventTriggered(ChannelHandlerContext ctx, java.lang.Object evt)
处理明文HTTP升级事件。
|
void |
Http2RemoteFlowController.FlowControlled.write(ChannelHandlerContext ctx, int allowedBytes)
将最多
allowedBytes 封装的有效载荷写入流中。
|
void |
HttpToHttp2ConnectionHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
处理 HttpMessage 和HttpContent 到HTTP / 2帧的转换。
|
void |
Http2FrameCodec.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
处理全部 Http2Frame s。
|
void |
Http2ConnectionHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
Http2DataWriter.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise)
将
DATA 帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeData(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
任何HTTP / 2帧的通用写入方法。
|
ChannelFuture |
Http2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise)
将给定的数据写入内部 Http2FrameWriter ,而不对连接/流执行任何状态检查。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeFrame(ChannelHandlerContext ctx, byte frameType, int streamId, Http2Flags flags, ByteBuf payload, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise)
将GO_AWAY帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeGoAway(ChannelHandlerContext ctx, int lastStreamId, long errorCode, ByteBuf debugData, ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise)
将HEADERS帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise)
将指定优先级的HEADERS帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, ChannelPromise promise) |
ChannelFuture |
CompressorHttp2ConnectionEncoder.writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise)
将PING帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise)
将PRIORITY帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePriority(ChannelHandlerContext ctx, int streamId, int streamDependency, short weight, boolean exclusive, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise)
将PUSH_PROMISE帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writePushPromise(ChannelHandlerContext ctx, int streamId, int promisedStreamId, Http2Headers headers, int padding, ChannelPromise promise) |
ChannelFuture |
StreamBufferingEncoder.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise)
将RST_STREAM帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise)
将一个SETTINGS帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettings(ChannelHandlerContext ctx, Http2Settings settings, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise)
将SETTINGS确认写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) |
ChannelFuture |
Http2OutboundFrameLogger.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) |
ChannelFuture |
Http2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise)
将WINDOW_UPDATE帧写入远程端点。
|
ChannelFuture |
DefaultHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) |
ChannelFuture |
DefaultHttp2ConnectionEncoder.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) |
ChannelFuture |
DecoratingHttp2FrameWriter.writeWindowUpdate(ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
JsonObjectDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected ByteBuf |
JsonObjectDecoder.extractObject(ChannelHandlerContext ctx, ByteBuf buffer, int index, int length)
如果要过滤通过管道传递的json对象/数组,则覆盖此方法。
|
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
MarshallingDecoder.decode(ChannelHandlerContext ctx, ByteBuf in) |
protected void |
CompatibleMarshallingDecoder.decode(ChannelHandlerContext ctx, ByteBuf buffer, java.util.List<java.lang.Object> out) |
protected void |
CompatibleMarshallingDecoder.decodeLast(ChannelHandlerContext ctx, ByteBuf buffer, java.util.List<java.lang.Object> out) |
protected void |
MarshallingEncoder.encode(ChannelHandlerContext ctx, java.lang.Object msg, ByteBuf out) |
protected void |
CompatibleMarshallingEncoder.encode(ChannelHandlerContext ctx, java.lang.Object msg, ByteBuf out) |
void |
CompatibleMarshallingDecoder.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) |
protected ByteBuf |
MarshallingDecoder.extractFrame(ChannelHandlerContext ctx, ByteBuf buffer, int index, int length) |
org.jboss.marshalling.Marshaller |
ThreadLocalMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Marshaller |
MarshallerProvider.getMarshaller(ChannelHandlerContext ctx)
找一个 Marshaller 对于给定ChannelHandlerContext
|
org.jboss.marshalling.Marshaller |
DefaultMarshallerProvider.getMarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
UnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx)
获得 Unmarshaller 的Unmarshaller
|
org.jboss.marshalling.Unmarshaller |
ThreadLocalUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
DefaultUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
org.jboss.marshalling.Unmarshaller |
ContextBoundUnmarshallerProvider.getUnmarshaller(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMemcacheObjectEncoder.encode(ChannelHandlerContext ctx, java.lang.Object msg, java.util.List<java.lang.Object> out) |
protected abstract ByteBuf |
AbstractMemcacheObjectEncoder.encodeMessage(ChannelHandlerContext ctx, M msg)
取给定的 MemcacheMessage 并将其编码为可写ByteBuf 。
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractBinaryMemcacheDecoder.channelInactive(ChannelHandlerContext ctx)
当通道不活动时,释放所有帧以防止数据泄漏。
|
protected void |
AbstractBinaryMemcacheDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected ByteBuf |
AbstractBinaryMemcacheEncoder.encodeMessage(ChannelHandlerContext ctx, M msg) |
Modifier and Type | Method and Description |
---|---|
protected void |
MqttDecoder.decode(ChannelHandlerContext ctx, ByteBuf buffer, java.util.List<java.lang.Object> out) |
protected void |
MqttEncoder.encode(ChannelHandlerContext ctx, MqttMessage msg, java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
ProtobufVarint32FrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
ProtobufDecoderNano.decode(ChannelHandlerContext ctx, ByteBuf msg, java.util.List<java.lang.Object> out) |
protected void |
ProtobufDecoder.decode(ChannelHandlerContext ctx, ByteBuf msg, java.util.List<java.lang.Object> out) |
protected void |
ProtobufVarint32LengthFieldPrepender.encode(ChannelHandlerContext ctx, ByteBuf msg, ByteBuf out) |
protected void |
ProtobufEncoder.encode(ChannelHandlerContext ctx, MessageLiteOrBuilder msg, java.util.List<java.lang.Object> out) |
protected void |
ProtobufEncoderNano.encode(ChannelHandlerContext ctx, MessageNano msg, java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
RedisDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
RedisArrayAggregator.decode(ChannelHandlerContext ctx, RedisMessage msg, java.util.List<java.lang.Object> out) |
protected void |
RedisEncoder.encode(ChannelHandlerContext ctx, RedisMessage msg, java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SctpMessageCompletionHandler.decode(ChannelHandlerContext ctx, SctpMessage msg, java.util.List<java.lang.Object> out) |
protected void |
SctpInboundByteStreamHandler.decode(ChannelHandlerContext ctx, SctpMessage msg, java.util.List<java.lang.Object> out) |
protected void |
SctpOutboundByteStreamHandler.encode(ChannelHandlerContext ctx, ByteBuf msg, java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
ObjectDecoder.decode(ChannelHandlerContext ctx, ByteBuf in) |
protected void |
ObjectEncoder.encode(ChannelHandlerContext ctx, java.io.Serializable msg, ByteBuf out) |
protected void |
CompatibleObjectEncoder.encode(ChannelHandlerContext ctx, java.io.Serializable msg, ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected SmtpResponse |
SmtpResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf buffer) |
protected void |
SmtpRequestEncoder.encode(ChannelHandlerContext ctx, java.lang.Object msg, java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SocksInitResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf byteBuf, java.util.List<java.lang.Object> out) |
protected void |
SocksInitRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf byteBuf, java.util.List<java.lang.Object> out) |
protected void |
SocksCmdResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf byteBuf, java.util.List<java.lang.Object> out) |
protected void |
SocksCmdRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf byteBuf, java.util.List<java.lang.Object> out) |
protected void |
SocksAuthResponseDecoder.decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, java.util.List<java.lang.Object> out) |
protected void |
SocksAuthRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf byteBuf, java.util.List<java.lang.Object> out) |
protected void |
SocksMessageEncoder.encode(ChannelHandlerContext ctx, SocksMessage msg, ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected void |
SocksPortUnificationServerHandler.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks4ServerDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
Socks4ClientDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
Socks4ClientEncoder.encode(ChannelHandlerContext ctx, Socks4CommandRequest msg, ByteBuf out) |
protected void |
Socks4ServerEncoder.encode(ChannelHandlerContext ctx, Socks4CommandResponse msg, ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks5PasswordAuthResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
Socks5PasswordAuthRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
Socks5InitialResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
Socks5InitialRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
Socks5CommandResponseDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
Socks5CommandRequestDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
Socks5ServerEncoder.encode(ChannelHandlerContext ctx, Socks5Message msg, ByteBuf out) |
protected void |
Socks5ClientEncoder.encode(ChannelHandlerContext ctx, Socks5Message msg, ByteBuf out) |
Modifier and Type | Method and Description |
---|---|
void |
SpdyFrameCodec.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
SpdySessionHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SpdyHttpDecoder.channelInactive(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
SpdyFrameCodec.channelReadComplete(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
SpdyFrameCodec.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
SpdyFrameCodec.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
protected void |
SpdyFrameCodec.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
SpdyHttpResponseStreamIdHandler.decode(ChannelHandlerContext ctx, java.lang.Object msg, java.util.List<java.lang.Object> out) |
protected void |
SpdyHttpDecoder.decode(ChannelHandlerContext ctx, SpdyFrame msg, java.util.List<java.lang.Object> out) |
void |
SpdyFrameCodec.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
SpdyFrameCodec.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
protected void |
SpdyHttpResponseStreamIdHandler.encode(ChannelHandlerContext ctx, HttpMessage msg, java.util.List<java.lang.Object> out) |
protected void |
SpdyHttpEncoder.encode(ChannelHandlerContext ctx, HttpObject msg, java.util.List<java.lang.Object> out) |
void |
SpdySessionHandler.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) |
void |
SpdyFrameCodec.flush(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.handlerAdded(ChannelHandlerContext ctx) |
void |
SpdyFrameCodec.read(ChannelHandlerContext ctx) |
void |
SpdySessionHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
SpdyFrameCodec.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
StompSubframeDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
StompSubframeEncoder.encode(ChannelHandlerContext ctx, StompSubframe msg, java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
StringDecoder.decode(ChannelHandlerContext ctx, ByteBuf msg, java.util.List<java.lang.Object> out) |
protected void |
StringEncoder.encode(ChannelHandlerContext ctx, java.lang.CharSequence msg, java.util.List<java.lang.Object> out) |
protected void |
LineEncoder.encode(ChannelHandlerContext ctx, java.lang.CharSequence msg, java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
protected void |
XmlDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
XmlFrameDecoder.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
Modifier and Type | Method and Description |
---|---|
void |
FlowControlHandler.channelInactive(ChannelHandlerContext ctx) |
void |
FlowControlHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
FlowControlHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
FlowControlHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
FlowControlHandler.read(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
FlushConsolidationHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
FlushConsolidationHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
FlushConsolidationHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
FlushConsolidationHandler.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) |
void |
FlushConsolidationHandler.flush(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
FlushConsolidationHandler.handlerRemoved(ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
UniqueIpFilter.accept(ChannelHandlerContext ctx, java.net.InetSocketAddress remoteAddress) |
protected boolean |
RuleBasedIpFilter.accept(ChannelHandlerContext ctx, java.net.InetSocketAddress remoteAddress) |
protected abstract boolean |
AbstractRemoteAddressFilter.accept(ChannelHandlerContext ctx, T remoteAddress)
在 Channel 获得注册后立即调用此方法。
|
protected void |
AbstractRemoteAddressFilter.channelAccepted(ChannelHandlerContext ctx, T remoteAddress)
如果这种方法被称为
remoteAddress 得到由接受
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) 。
|
void |
AbstractRemoteAddressFilter.channelActive(ChannelHandlerContext ctx) |
void |
AbstractRemoteAddressFilter.channelRegistered(ChannelHandlerContext ctx) |
protected ChannelFuture |
AbstractRemoteAddressFilter.channelRejected(ChannelHandlerContext ctx, T remoteAddress)
如果这种方法被称为
remoteAddress 被否决
AbstractRemoteAddressFilter.accept(ChannelHandlerContext, SocketAddress) 。
|
Modifier and Type | Method and Description |
---|---|
void |
LoggingHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
LoggingHandler.channelActive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelInactive(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
LoggingHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelUnregistered(ChannelHandlerContext ctx) |
void |
LoggingHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
LoggingHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
LoggingHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
LoggingHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
LoggingHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
LoggingHandler.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) |
void |
LoggingHandler.flush(ChannelHandlerContext ctx) |
protected java.lang.String |
LoggingHandler.format(ChannelHandlerContext ctx, java.lang.String eventName)
格式化事件并返回格式化的消息。
|
protected java.lang.String |
LoggingHandler.format(ChannelHandlerContext ctx, java.lang.String eventName, java.lang.Object arg)
格式化事件并返回格式化的消息。
|
protected java.lang.String |
LoggingHandler.format(ChannelHandlerContext ctx, java.lang.String eventName, java.lang.Object firstArg, java.lang.Object secondArg)
格式化事件并返回格式化的消息。
|
void |
LoggingHandler.userEventTriggered(ChannelHandlerContext ctx, java.lang.Object evt) |
void |
LoggingHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
protected void |
Socks5ProxyHandler.addCodec(ChannelHandlerContext ctx) |
protected void |
Socks4ProxyHandler.addCodec(ChannelHandlerContext ctx) |
protected abstract void |
ProxyHandler.addCodec(ChannelHandlerContext ctx)
添加与代理服务器进行通信所需的编解码器处理程序。
|
protected void |
HttpProxyHandler.addCodec(ChannelHandlerContext ctx) |
void |
ProxyHandler.channelActive(ChannelHandlerContext ctx) |
void |
ProxyHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ProxyHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
ProxyHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
ProxyHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
ProxyHandler.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) |
void |
ProxyHandler.flush(ChannelHandlerContext ctx) |
void |
ProxyHandler.handlerAdded(ChannelHandlerContext ctx) |
protected boolean |
Socks5ProxyHandler.handleResponse(ChannelHandlerContext ctx, java.lang.Object response) |
protected boolean |
Socks4ProxyHandler.handleResponse(ChannelHandlerContext ctx, java.lang.Object response) |
protected abstract boolean |
ProxyHandler.handleResponse(ChannelHandlerContext ctx, java.lang.Object response)
处理从代理服务器收到的消息。
|
protected boolean |
HttpProxyHandler.handleResponse(ChannelHandlerContext ctx, java.lang.Object response) |
protected java.lang.Object |
Socks5ProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
protected java.lang.Object |
Socks4ProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
protected abstract java.lang.Object |
ProxyHandler.newInitialMessage(ChannelHandlerContext ctx)
返回到代理服务器的连接建立后第一次发送的新消息。
|
protected java.lang.Object |
HttpProxyHandler.newInitialMessage(ChannelHandlerContext ctx) |
protected void |
Socks5ProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected void |
Socks4ProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected abstract void |
ProxyHandler.removeDecoder(ChannelHandlerContext ctx)
|
protected void |
HttpProxyHandler.removeDecoder(ChannelHandlerContext ctx) |
protected void |
Socks5ProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
protected void |
Socks4ProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
protected abstract void |
ProxyHandler.removeEncoder(ChannelHandlerContext ctx)
|
protected void |
HttpProxyHandler.removeEncoder(ChannelHandlerContext ctx) |
void |
ProxyHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
SslHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
AbstractSniHandler.bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
SslHandler.channelActive(ChannelHandlerContext ctx)
在客户端模式下使用时连接发起初始TLS握手
|
void |
SslHandler.channelInactive(ChannelHandlerContext ctx) |
void |
SslHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
SslHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
AbstractSniHandler.close(ChannelHandlerContext ctx, ChannelPromise promise) |
protected abstract void |
ApplicationProtocolNegotiationHandler.configurePipeline(ChannelHandlerContext ctx, java.lang.String protocol)
调用成功的初始SSL / TLS握手。
|
void |
SslHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
void |
AbstractSniHandler.connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) |
protected void |
SslHandler.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
OptionalSslHandler.decode(ChannelHandlerContext context, ByteBuf in, java.util.List<java.lang.Object> out) |
protected void |
AbstractSniHandler.decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) |
void |
SslHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
AbstractSniHandler.deregister(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
SslHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
AbstractSniHandler.disconnect(ChannelHandlerContext ctx, ChannelPromise promise) |
void |
SslHandler.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) |
void |
ApplicationProtocolNegotiationHandler.exceptionCaught(ChannelHandlerContext ctx, java.lang.Throwable cause) |
void |
SslHandler.flush(ChannelHandlerContext ctx) |
void |
AbstractSniHandler.flush(ChannelHandlerContext ctx) |
void |
SslHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
SslHandler.handlerRemoved0(ChannelHandlerContext ctx) |
protected void |
ApplicationProtocolNegotiationHandler.handshakeFailure(ChannelHandlerContext ctx, java.lang.Throwable cause)
在失败的初始SSL / TLS握手中调用。
|
protected Future<SslContext> |
SniHandler.lookup(ChannelHandlerContext ctx, java.lang.String hostname)
默认实现将简单地调用
AsyncMapping.map(Object, Promise) ,但用户可以重写此方法来实现自定义行为。
|
protected abstract Future<T> |
AbstractSniHandler.lookup(ChannelHandlerContext ctx, java.lang.String hostname)
开始查找给定的SNI值并返回一个 Future ,这反过来会在完成时通知AbstractSniHandler.onLookupComplete(ChannelHandlerContext, String, Future) 。
|
protected ChannelHandler |
OptionalSslHandler.newNonSslHandler(ChannelHandlerContext context)
重写以配置ChannelHandler。
|
protected SslHandler |
OptionalSslHandler.newSslHandler(ChannelHandlerContext context, SslContext sslContext)
重写配置SslHandler例如。
|
protected void |
SniHandler.onLookupComplete(ChannelHandlerContext ctx, java.lang.String hostname, Future<SslContext> future) |
protected abstract void |
AbstractSniHandler.onLookupComplete(ChannelHandlerContext ctx, java.lang.String hostname, Future<T> future)
|
void |
SslHandler.read(ChannelHandlerContext ctx) |
void |
AbstractSniHandler.read(ChannelHandlerContext ctx) |
protected void |
SniHandler.replaceHandler(ChannelHandlerContext ctx, java.lang.String hostname, SslContext sslContext)
此方法的默认实现将只需更换 this SniHandler 用实例SslHandler 。
|
void |
ApplicationProtocolNegotiationHandler.userEventTriggered(ChannelHandlerContext ctx, java.lang.Object evt) |
void |
SslHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
AbstractSniHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
OcspClientHandler.userEventTriggered(ChannelHandlerContext ctx, java.lang.Object evt) |
protected abstract boolean |
OcspClientHandler.verify(ChannelHandlerContext ctx, ReferenceCountedOpenSslEngine engine) |
Modifier and Type | Method and Description |
---|---|
void |
ChunkedWriteHandler.channelInactive(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.channelWritabilityChanged(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.flush(ChannelHandlerContext ctx) |
void |
ChunkedWriteHandler.handlerAdded(ChannelHandlerContext ctx) |
ByteBuf |
ChunkedStream.readChunk(ChannelHandlerContext ctx)
已过时。
|
ByteBuf |
ChunkedNioStream.readChunk(ChannelHandlerContext ctx)
已过时。
|
ByteBuf |
ChunkedNioFile.readChunk(ChannelHandlerContext ctx)
已过时。
|
B |
ChunkedInput.readChunk(ChannelHandlerContext ctx)
已过时。
使用
ChunkedInput.readChunk(ByteBufAllocator) 。
从流中获取分块的数据。 一旦此方法返回最后一个块并因此流到达末尾,任何后续 |
ByteBuf |
ChunkedFile.readChunk(ChannelHandlerContext ctx)
已过时。
|
void |
ChunkedWriteHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Modifier and Type | Method and Description |
---|---|
void |
IdleStateHandler.channelActive(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.channelIdle(ChannelHandlerContext ctx, IdleStateEvent evt) |
protected void |
IdleStateHandler.channelIdle(ChannelHandlerContext ctx, IdleStateEvent evt)
当 IdleStateEvent 应该被解雇时被调用。
|
void |
IdleStateHandler.channelInactive(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
IdleStateHandler.channelReadComplete(ChannelHandlerContext ctx) |
void |
IdleStateHandler.channelRegistered(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
WriteTimeoutHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
IdleStateHandler.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
ReadTimeoutHandler.readTimedOut(ChannelHandlerContext ctx)
在检测到读取超时时调用。
|
void |
WriteTimeoutHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
IdleStateHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
protected void |
WriteTimeoutHandler.writeTimedOut(ChannelHandlerContext ctx)
在检测到写入超时时调用
|
Modifier and Type | Method and Description |
---|---|
void |
GlobalChannelTrafficShapingHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
AbstractTrafficShapingHandler.channelRead(ChannelHandlerContext ctx, java.lang.Object msg) |
void |
AbstractTrafficShapingHandler.channelRegistered(ChannelHandlerContext ctx) |
protected long |
GlobalChannelTrafficShapingHandler.checkWaitReadTime(ChannelHandlerContext ctx, long wait, long now) |
void |
GlobalTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerAdded(ChannelHandlerContext ctx) |
void |
GlobalTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
GlobalChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
void |
ChannelTrafficShapingHandler.handlerRemoved(ChannelHandlerContext ctx) |
protected void |
GlobalChannelTrafficShapingHandler.informReadOperation(ChannelHandlerContext ctx, long now) |
protected static boolean |
AbstractTrafficShapingHandler.isHandlerActive(ChannelHandlerContext ctx) |
void |
AbstractTrafficShapingHandler.read(ChannelHandlerContext ctx) |
protected void |
AbstractTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long delay, ChannelPromise promise)
已过时。
|
protected void |
GlobalChannelTrafficShapingHandler.submitWrite(ChannelHandlerContext ctx, java.lang.Object msg, long size, long writedelay, long now, ChannelPromise promise) |
void |
GlobalChannelTrafficShapingHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
void |
AbstractTrafficShapingHandler.write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) |
Copyright © 2008–2018 The Netty Project. All rights reserved.