mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-05-24 15:37:04 +00:00
chore[comment]: webSocket handshake instructions
This commit is contained in:
@@ -48,7 +48,7 @@ public class JsonWebsocketClientTest {
|
||||
var client = new JsonWebsocketClient(HostAndPort.valueOf("127.0.0.1:9000"), webSocketClientProtocolConfig);
|
||||
var session = client.start();
|
||||
|
||||
// Websocket在建立tcp连接过后不能立刻通讯,还需要使用Http协议去握手升级成Websocket协议
|
||||
// Websocket在建立tcp连接过后不能立刻通讯,还需要使用Http协议去握手升级成Websocket协议,这里等待一秒让websocket内部协议初始化完毕
|
||||
// WebSocket握手是在客户端和服务器之间建立WebSocket连接的过程。它是通过HTTP/HTTPS协议完成的,后续将升级为WebSocket协议。
|
||||
ThreadUtils.sleep(1000);
|
||||
|
||||
@@ -58,7 +58,6 @@ public class JsonWebsocketClientTest {
|
||||
for (int i = 0; i < 1000; i++) {
|
||||
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));
|
||||
|
||||
@@ -69,6 +68,7 @@ public class JsonWebsocketClientTest {
|
||||
logger.info("async json client receive [packet:{}] from server", JsonUtils.object2String(jsonHelloResponse));
|
||||
}
|
||||
});
|
||||
ThreadUtils.sleep(1000);
|
||||
}
|
||||
|
||||
ThreadUtils.sleep(Long.MAX_VALUE);
|
||||
|
||||
@@ -48,7 +48,7 @@ public class WebsocketClientTest {
|
||||
var client = new WebsocketClient(HostAndPort.valueOf("127.0.0.1:9000"), webSocketClientProtocolConfig);
|
||||
var session = client.start();
|
||||
|
||||
// Websocket在建立tcp连接过后不能立刻通讯,还需要使用Http协议去握手升级成Websocket协议
|
||||
// Websocket在建立tcp连接过后不能立刻通讯,还需要使用Http协议去握手升级成Websocket协议,这里等待一秒让websocket内部协议初始化完毕
|
||||
// WebSocket握手是在客户端和服务器之间建立WebSocket连接的过程。它是通过HTTP/HTTPS协议完成的,后续将升级为WebSocket协议。
|
||||
ThreadUtils.sleep(1000);
|
||||
|
||||
@@ -58,7 +58,6 @@ public class WebsocketClientTest {
|
||||
for (int i = 0; i < 1000; i++) {
|
||||
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));
|
||||
|
||||
@@ -69,6 +68,7 @@ public class WebsocketClientTest {
|
||||
logger.info("async client receive [packet:{}] from server", JsonUtils.object2String(jsonHelloResponse));
|
||||
}
|
||||
});
|
||||
ThreadUtils.sleep(1000);
|
||||
}
|
||||
|
||||
ThreadUtils.sleep(Long.MAX_VALUE);
|
||||
|
||||
Reference in New Issue
Block a user