public class ChannelDuplexHandler extends ChannelInboundHandlerAdapter implements ChannelOutboundHandler
ChannelHandler实现,代表ChannelInboundHandler和ChannelOutboundHandler之间的组合。
如果您的ChannelHandler实现需要拦截操作并声明更新,那么这是一个很好的起点。
ChannelHandler.Sharable| Constructor and Description |
|---|
ChannelDuplexHandler() |
| Modifier and Type | Method and Description |
|---|---|
void |
bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise)
|
void |
close(ChannelHandlerContext ctx, ChannelPromise promise)
|
void |
connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
|
void |
deregister(ChannelHandlerContext ctx, ChannelPromise promise)
|
void |
disconnect(ChannelHandlerContext ctx, ChannelPromise promise)
|
void |
flush(ChannelHandlerContext ctx)
|
void |
read(ChannelHandlerContext ctx)
|
void |
write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
|
channelActive, channelInactive, channelRead, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggeredensureNotSharable, handlerAdded, handlerRemoved, isSharableclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitexceptionCaught, handlerAdded, handlerRemovedpublic void bind(ChannelHandlerContext ctx, java.net.SocketAddress localAddress, ChannelPromise promise) throws java.lang.Exception
ChannelOutboundInvoker.bind(SocketAddress, ChannelPromise)转发到ChannelPipeline中的下一个ChannelOutboundHandler 。
子类可以重写此方法来更改行为。
bind接口
ChannelOutboundHandler
ctx - 为其进行绑定操作的ChannelHandlerContext
localAddress - 它应该绑定的
SocketAddress
promise - 在操作完成后通知ChannelPromise
java.lang.Exception - 发生错误时抛出
public void connect(ChannelHandlerContext ctx, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) throws java.lang.Exception
ChannelOutboundInvoker.connect(SocketAddress, SocketAddress, ChannelPromise)转发到87260545859279中的下一个ChannelOutboundHandler 。
子类可以重写此方法来更改行为。
connect接口
ChannelOutboundHandler
ctx - 为其进行连接操作的ChannelHandlerContext
remoteAddress - 它应该连接到的
SocketAddress
localAddress - 用作连接源的
SocketAddress
promise - 在操作完成后通知ChannelPromise
java.lang.Exception - 发生错误时抛出
public void disconnect(ChannelHandlerContext ctx, ChannelPromise promise) throws java.lang.Exception
ChannelOutboundInvoker.disconnect(ChannelPromise)转发到ChannelPipeline中的下一个ChannelOutboundHandler 。
子类可以重写此方法来更改行为。
disconnect接口
ChannelOutboundHandler
ctx - 为其进行断开操作的ChannelHandlerContext
promise - 在操作完成后通知ChannelPromise
java.lang.Exception - 发生错误时抛出
public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws java.lang.Exception
ChannelOutboundInvoker.close(ChannelPromise)转发到ChannelPipeline中的下一个ChannelOutboundHandler 。
子类可以重写此方法来更改行为。
close在界面
ChannelOutboundHandler
ctx - 关闭操作的ChannelHandlerContext
promise - 在操作完成后通知ChannelPromise
java.lang.Exception - 发生错误时抛出
public void deregister(ChannelHandlerContext ctx, ChannelPromise promise) throws java.lang.Exception
ChannelOutboundInvoker.close(ChannelPromise)转发到ChannelPipeline中的下一个ChannelOutboundHandler 。
子类可以重写此方法来更改行为。
deregister在界面
ChannelOutboundHandler
ctx - 进行关闭操作的ChannelHandlerContext
promise - 在操作完成后通知ChannelPromise
java.lang.Exception - 发生错误时抛出
public void read(ChannelHandlerContext ctx) throws java.lang.Exception
ChannelHandlerContext.read()转发到ChannelPipeline中的下一个ChannelOutboundHandler 。
子类可以重写此方法来更改行为。
read接口
ChannelOutboundHandler
java.lang.Exception
public void write(ChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise) throws java.lang.Exception
ChannelOutboundInvoker.write(Object, ChannelPromise)转发到ChannelPipeline中的下一个ChannelOutboundHandler 。
子类可以重写此方法来更改行为。
write接口
ChannelOutboundHandler
ctx - 为其写入操作的ChannelHandlerContext
msg - 写信息
promise - 在操作完成后通知ChannelPromise
java.lang.Exception - 发生错误时抛出
public void flush(ChannelHandlerContext ctx) throws java.lang.Exception
ChannelHandlerContext.flush()转发到ChannelPipeline中的下一个ChannelOutboundHandler 。
子类可以重写此方法来更改行为。
flush接口
ChannelOutboundHandler
ctx - 进行冲洗操作的ChannelHandlerContext
java.lang.Exception - 发生错误时抛出
Copyright © 2008–2018 The Netty Project. All rights reserved.