ClientConnection优化

src/test/java/org/redkale/test/sncp/SncpSleepService.java

@@ -16,6 +16,7 @@ public class SncpSleepService extends AbstractService {
     public CompletableFuture<String> 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<String> 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<String> sleep500() {
         return (CompletableFuture) CompletableFuture.supplyAsync(() -> {
             Utility.sleep(500);
+            System.out.println("执行完sleep500");
             return "ok500";
         });
     }

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();