添加心跳检测，防止设备干坏事

glaciall · Jul 7, 2021 · 6d27af5 · 6d27af5
1 parent 55d4b1e
commit 6d27af5
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/cn/org/hentai/jtt1078/app/VideoServerApp.java b/src/main/java/cn/org/hentai/jtt1078/app/VideoServerApp.java
@@ -19,8 +19,9 @@
 import org.slf4j.LoggerFactory;
 import sun.misc.Signal;
 import sun.misc.SignalHandler;
-
+import io.netty.handler.timeout.IdleStateHandler;
 import java.net.InetAddress;
+import java.util.concurrent.TimeUnit;
 
 /**
  * Created by matrixy on 2019/4/9.
@@ -71,6 +72,7 @@ private static void start() throws Exception
                         @Override
                         protected void initChannel(final SocketChannel channel) throws Exception {
                             ChannelPipeline p = channel.pipeline();
+                            p.addLast(new IdleStateHandler(10,0,0, TimeUnit.SECONDS));
                             p.addLast(new Jtt1078MessageDecoder());
                             // p.addLast(new Jtt808MessageEncoder());
                             // p.addLast(new JTT808Handler());