diff --git a/logistics/src/main/java/com/ccsens/logistics/Netty/NettyClient.java b/logistics/src/main/java/com/ccsens/logistics/Netty/NettyClient.java index a3c7a8b1..66872579 100644 --- a/logistics/src/main/java/com/ccsens/logistics/Netty/NettyClient.java +++ b/logistics/src/main/java/com/ccsens/logistics/Netty/NettyClient.java @@ -72,7 +72,7 @@ public class NettyClient { ScheduledExecutorService service = Executors .newSingleThreadScheduledExecutor(); // 第二个参数为首次执行的延时时间,第三个参数为定时执行的间隔时间 - service.scheduleAtFixedRate(runnable, 2, 5, TimeUnit.SECONDS); + service.scheduleAtFixedRate(runnable, 2, 15, TimeUnit.SECONDS); // 创建并执行在给定延迟后启用的 ScheduledFuture。 // 参数: diff --git a/logistics/src/main/java/com/ccsens/logistics/Netty/SimpleClientHandler.java b/logistics/src/main/java/com/ccsens/logistics/Netty/SimpleClientHandler.java index 08cb5751..10e022c6 100644 --- a/logistics/src/main/java/com/ccsens/logistics/Netty/SimpleClientHandler.java +++ b/logistics/src/main/java/com/ccsens/logistics/Netty/SimpleClientHandler.java @@ -6,6 +6,7 @@ import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelHandler; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; +import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; import javax.annotation.Resource; @@ -14,6 +15,7 @@ import java.nio.charset.Charset; /** * @author 逗 */ +@Slf4j @ChannelHandler.Sharable @Component public class SimpleClientHandler extends ChannelInboundHandlerAdapter{ @@ -24,7 +26,9 @@ public class SimpleClientHandler extends ChannelInboundHandlerAdapter{ public void channelRead(ChannelHandlerContext ctx, Object msg) { if (msg instanceof ByteBuf) { String value = ((ByteBuf) msg).toString(Charset.defaultCharset()); - System.out.println("服务器端返回的数据:" + value.substring(value.length()-3,value.length())); + + log.info("服务器端返回的数据:{}",value.substring(value.length() > 500 ? value.length()-300 : 0)); + if(StrUtil.isNotEmpty(value) && value.lastIndexOf("not online") == -1) { thermalImageryService.disposeMessage(value); } diff --git a/util/src/test/java/com/ccsens/util/OtherTest.java b/util/src/test/java/com/ccsens/util/OtherTest.java index 16cc0bcc..4d5d2c78 100644 --- a/util/src/test/java/com/ccsens/util/OtherTest.java +++ b/util/src/test/java/com/ccsens/util/OtherTest.java @@ -125,9 +125,9 @@ public class OtherTest { public void test9(){ String s = "050005BD: The device is not online"; String as = "55"; - - System.out.println(s.lastIndexOf("not online")); - System.out.println(as.lastIndexOf("not online")); + System.out.println(s.substring(s.length() > 200 ? s.length()-190 : 0)); +// System.out.println(s.lastIndexOf("not online")); +// System.out.println(as.lastIndexOf("not online")); } @Test public void test10(){