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, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
exceptionCaught, handlerAdded, handlerRemoved
public 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.