|
@@ -8,14 +8,15 @@ import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
|
|
|
@Slf4j
|
|
@Slf4j
|
|
|
public class NettyClientHandler implements ChannelInboundHandler {
|
|
public class NettyClientHandler implements ChannelInboundHandler {
|
|
|
|
|
+
|
|
|
@Override
|
|
@Override
|
|
|
public void channelRegistered(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
public void channelRegistered(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
|
-
|
|
|
|
|
|
|
+ log.info("");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public void channelUnregistered(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
public void channelUnregistered(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
|
-
|
|
|
|
|
|
|
+ log.info("");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -37,7 +38,7 @@ public class NettyClientHandler implements ChannelInboundHandler {
|
|
|
}
|
|
}
|
|
|
@Override
|
|
@Override
|
|
|
public void channelInactive(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
public void channelInactive(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
|
-
|
|
|
|
|
|
|
+ log.info("");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -50,27 +51,27 @@ public class NettyClientHandler implements ChannelInboundHandler {
|
|
|
}
|
|
}
|
|
|
@Override
|
|
@Override
|
|
|
public void channelReadComplete(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
public void channelReadComplete(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
|
-
|
|
|
|
|
|
|
+ log.info("");
|
|
|
}
|
|
}
|
|
|
@Override
|
|
@Override
|
|
|
public void userEventTriggered(ChannelHandlerContext channelHandlerContext, Object o) throws Exception {
|
|
public void userEventTriggered(ChannelHandlerContext channelHandlerContext, Object o) throws Exception {
|
|
|
-
|
|
|
|
|
|
|
+ log.info("");
|
|
|
}
|
|
}
|
|
|
@Override
|
|
@Override
|
|
|
public void channelWritabilityChanged(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
public void channelWritabilityChanged(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
|
-
|
|
|
|
|
|
|
+ log.info("");
|
|
|
}
|
|
}
|
|
|
@Override
|
|
@Override
|
|
|
public void handlerAdded(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
public void handlerAdded(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
|
-
|
|
|
|
|
|
|
+ log.info("");
|
|
|
}
|
|
}
|
|
|
@Override
|
|
@Override
|
|
|
public void handlerRemoved(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
public void handlerRemoved(ChannelHandlerContext channelHandlerContext) throws Exception {
|
|
|
-
|
|
|
|
|
|
|
+ log.info("");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public void exceptionCaught(ChannelHandlerContext channelHandlerContext, Throwable throwable) throws Exception {
|
|
public void exceptionCaught(ChannelHandlerContext channelHandlerContext, Throwable throwable) throws Exception {
|
|
|
-
|
|
|
|
|
|
|
+ log.info("");
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|