public class MessageSendHandler
extends io.netty.channel.ChannelInboundHandlerAdapter
| 限定符和类型 | 字段和说明 |
|---|---|
static MessageSendHandler |
ERROR_HANDLER |
| 构造器和说明 |
|---|
MessageSendHandler() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
channelActive(io.netty.channel.ChannelHandlerContext ctx) |
void |
channelRead(io.netty.channel.ChannelHandlerContext ctx,
java.lang.Object msg) |
void |
channelRegistered(io.netty.channel.ChannelHandlerContext ctx) |
void |
close() |
void |
exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
java.lang.Throwable cause) |
io.netty.channel.Channel |
getChannel() |
java.net.SocketAddress |
getRemoteAddr() |
MessageCallBack |
sendRequest(MessageRequest request) |
channelInactive, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggeredensureNotSharable, handlerAdded, handlerRemoved, isSharablepublic static final MessageSendHandler ERROR_HANDLER
public io.netty.channel.Channel getChannel()
public java.net.SocketAddress getRemoteAddr()
public void channelActive(io.netty.channel.ChannelHandlerContext ctx)
throws java.lang.Exception
channelActive 在接口中 io.netty.channel.ChannelInboundHandlerchannelActive 在类中 io.netty.channel.ChannelInboundHandlerAdapterjava.lang.Exceptionpublic void channelRegistered(io.netty.channel.ChannelHandlerContext ctx)
throws java.lang.Exception
channelRegistered 在接口中 io.netty.channel.ChannelInboundHandlerchannelRegistered 在类中 io.netty.channel.ChannelInboundHandlerAdapterjava.lang.Exceptionpublic void channelRead(io.netty.channel.ChannelHandlerContext ctx,
java.lang.Object msg)
throws java.lang.Exception
channelRead 在接口中 io.netty.channel.ChannelInboundHandlerchannelRead 在类中 io.netty.channel.ChannelInboundHandlerAdapterjava.lang.Exceptionpublic void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
java.lang.Throwable cause)
throws java.lang.Exception
exceptionCaught 在接口中 io.netty.channel.ChannelHandlerexceptionCaught 在接口中 io.netty.channel.ChannelInboundHandlerexceptionCaught 在类中 io.netty.channel.ChannelInboundHandlerAdapterjava.lang.Exceptionpublic void close()
public MessageCallBack sendRequest(MessageRequest request)