deployed 1.0.2.RELEASE 增加异常断开连接的详细错误日志
parent
83253f8fed
commit
6fa7ee97ef
2
pom.xml
2
pom.xml
|
@ -3,7 +3,7 @@
|
||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
<groupId>io.github.yezhihao</groupId>
|
<groupId>io.github.yezhihao</groupId>
|
||||||
<artifactId>netmc</artifactId>
|
<artifactId>netmc</artifactId>
|
||||||
<version>1.0.1.RELEASE</version>
|
<version>1.0.2.RELEASE</version>
|
||||||
<packaging>jar</packaging>
|
<packaging>jar</packaging>
|
||||||
|
|
||||||
<name>Netmc</name>
|
<name>Netmc</name>
|
||||||
|
|
|
@ -90,7 +90,7 @@ public class TCPServerHandler extends ChannelInboundHandlerAdapter {
|
||||||
@Override
|
@Override
|
||||||
public void exceptionCaught(ChannelHandlerContext ctx, Throwable e) {
|
public void exceptionCaught(ChannelHandlerContext ctx, Throwable e) {
|
||||||
Session session = ctx.channel().attr(Session.KEY).get();
|
Session session = ctx.channel().attr(Session.KEY).get();
|
||||||
log.info("<<<<<终端异常断开连接" + session);
|
log.warn("<<<<<异常断开连接" + session, e);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -12,13 +12,13 @@ import java.lang.annotation.*;
|
||||||
@Documented
|
@Documented
|
||||||
public @interface AsyncBatch {
|
public @interface AsyncBatch {
|
||||||
|
|
||||||
//线程数量
|
/** 线程数量 */
|
||||||
int poolSize() default 2;
|
int poolSize() default 2;
|
||||||
|
|
||||||
//最大累计消息数
|
/** 最大累计消息数 */
|
||||||
int maxElements() default 400;
|
int maxElements() default 4000;
|
||||||
|
|
||||||
//最大等待时间
|
/** 最大等待时间 */
|
||||||
int maxWait() default 1000;
|
int maxWait() default 1000;
|
||||||
|
|
||||||
}
|
}
|
Loading…
Reference in New Issue