diff --git a/src/test/java/org/redkale/test/sncp/SncpSleepService.java b/src/test/java/org/redkale/test/sncp/SncpSleepService.java index a056a5e10..c618ed6e2 100644 --- a/src/test/java/org/redkale/test/sncp/SncpSleepService.java +++ b/src/test/java/org/redkale/test/sncp/SncpSleepService.java @@ -16,6 +16,7 @@ public class SncpSleepService extends AbstractService { public CompletableFuture sleep200() { return (CompletableFuture) CompletableFuture.supplyAsync(() -> { Utility.sleep(200); + System.out.println("执行完sleep200"); return "ok200"; }); } @@ -23,6 +24,7 @@ public class SncpSleepService extends AbstractService { public CompletableFuture sleep300() { return (CompletableFuture) CompletableFuture.supplyAsync(() -> { Utility.sleep(300); + System.out.println("执行完sleep300"); return "ok300"; }); } @@ -30,6 +32,7 @@ public class SncpSleepService extends AbstractService { public CompletableFuture sleep500() { return (CompletableFuture) CompletableFuture.supplyAsync(() -> { Utility.sleep(500); + System.out.println("执行完sleep500"); return "ok500"; }); } diff --git a/src/test/java/org/redkale/test/sncp/SncpSleepTest.java b/src/test/java/org/redkale/test/sncp/SncpSleepTest.java index 79e75b887..c340a49dc 100644 --- a/src/test/java/org/redkale/test/sncp/SncpSleepTest.java +++ b/src/test/java/org/redkale/test/sncp/SncpSleepTest.java @@ -44,7 +44,7 @@ public class SncpSleepTest { server.start(); int port = server.getSocketAddress().getPort(); - System.out.println("服务器启动端口: " + port); + System.out.println("SNCP服务器启动端口: " + port); InetSocketAddress sncpAddress = new InetSocketAddress("127.0.0.1", port); final SncpClient client = new SncpClient("", asyncGroup, sncpAddress, new ClientAddress(sncpAddress), "TCP", 16, 100); final SncpRpcGroups rpcGroups = application.getSncpRpcGroups();