diff --git a/src/main/java/cn/x47/RIPService.java b/src/main/java/cn/x47/RIPService.java index 0cc64f4..c67743a 100644 --- a/src/main/java/cn/x47/RIPService.java +++ b/src/main/java/cn/x47/RIPService.java @@ -38,6 +38,7 @@ public class RIPService { scheduler.scheduleAtFixedRate(() -> { RIPPacket packet = createRipResponsePacket(Config.RIP_VERSION); client.sendRipPacket(packet); + System.out.println("客户端 发送了一次消息"); }, 0, 10, TimeUnit.SECONDS); System.out.println("客户端已经启动"); } diff --git a/src/main/java/cn/x47/config/Config.java b/src/main/java/cn/x47/config/Config.java index 5cc6abb..91d71e8 100644 --- a/src/main/java/cn/x47/config/Config.java +++ b/src/main/java/cn/x47/config/Config.java @@ -4,5 +4,5 @@ public class Config { // 设置协议版本,1 表示 RIP v1,2 表示 RIP v2 public static final byte RIP_VERSION = 2; public static final boolean startServer = true; - public static final boolean startClient = true; + public static final boolean startClient = false; } diff --git a/src/main/java/cn/x47/handle/RIPServerHandler.java b/src/main/java/cn/x47/handle/RIPServerHandler.java index dce5a32..8ddbe6d 100644 --- a/src/main/java/cn/x47/handle/RIPServerHandler.java +++ b/src/main/java/cn/x47/handle/RIPServerHandler.java @@ -11,6 +11,7 @@ public class RIPServerHandler extends SimpleChannelInboundHandler { @Override protected void channelRead0(ChannelHandlerContext ctx, RIPPacket msg) throws Exception { + System.out.println(msg); if (msg.getCommand() == 2) { // Response for (RIPEntry entry : msg.getEntries()) { // 更新本地路由表