diff --git a/net/src/test/java/com/zfoo/net/core/json/client/JsonWebsocketClientTest.java b/net/src/test/java/com/zfoo/net/core/json/client/JsonWebsocketClientTest.java index abb48e31..104f301e 100644 --- a/net/src/test/java/com/zfoo/net/core/json/client/JsonWebsocketClientTest.java +++ b/net/src/test/java/com/zfoo/net/core/json/client/JsonWebsocketClientTest.java @@ -48,15 +48,20 @@ public class JsonWebsocketClientTest { var client = new JsonWebsocketClient(HostAndPort.valueOf("127.0.0.1:9000"), webSocketClientProtocolConfig); var session = client.start(); + // Websocket在建立tcp连接过后不能立刻通讯,还需要使用Http协议去握手升级成Websocket协议 + // WebSocket握手是在客户端和服务器之间建立WebSocket连接的过程。它是通过HTTP/HTTPS协议完成的,后续将升级为WebSocket协议。 + ThreadUtils.sleep(1000); + var request = new JsonHelloRequest(); request.setMessage("Hello, this is the json client!"); for (int i = 0; i < 1000; i++) { - ThreadUtils.sleep(1000); NetContext.getRouter().send(session, request); + ThreadUtils.sleep(1000); var response = NetContext.getRouter().syncAsk(session, request, JsonHelloResponse.class, null).packet(); logger.info("sync json client receive [packet:{}] from server", JsonUtils.object2String(response)); + NetContext.getRouter().asyncAsk(session, request, JsonHelloResponse.class, null) .whenComplete(new Consumer() { @Override diff --git a/net/src/test/java/com/zfoo/net/core/websocket/client/WebsocketClientTest.java b/net/src/test/java/com/zfoo/net/core/websocket/client/WebsocketClientTest.java index 1a7473d7..c4017d8b 100644 --- a/net/src/test/java/com/zfoo/net/core/websocket/client/WebsocketClientTest.java +++ b/net/src/test/java/com/zfoo/net/core/websocket/client/WebsocketClientTest.java @@ -48,19 +48,20 @@ public class WebsocketClientTest { var client = new WebsocketClient(HostAndPort.valueOf("127.0.0.1:9000"), webSocketClientProtocolConfig); var session = client.start(); + // Websocket在建立tcp连接过后不能立刻通讯,还需要使用Http协议去握手升级成Websocket协议 + // WebSocket握手是在客户端和服务器之间建立WebSocket连接的过程。它是通过HTTP/HTTPS协议完成的,后续将升级为WebSocket协议。 + ThreadUtils.sleep(1000); + var request = new WebsocketHelloRequest(); request.setMessage("Hello, this is the websocket client!"); for (int i = 0; i < 1000; i++) { - ThreadUtils.sleep(1000); NetContext.getRouter().send(session, request); - ThreadUtils.sleep(1000); var response = NetContext.getRouter().syncAsk(session, request, WebsocketHelloResponse.class, null).packet(); logger.info("sync client receive [packet:{}] from server", JsonUtils.object2String(response)); - NetContext.getRouter().asyncAsk(session, request, WebsocketHelloResponse.class, null) .whenComplete(new Consumer() { @Override