tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-09-05 22:17:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore[comment]: webSocket handshake instructions

Browse Source
This commit is contained in:
godotg
2024-01-19 13:03:12 +08:00
parent a3d3a006c7
commit f9e4b44383
2 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
net/src/test/java/com/zfoo/net/core/json/client/JsonWebsocketClientTest.java
+6 -1
View File
@@ -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<JsonHelloResponse>() {
@Override
net/src/test/java/com/zfoo/net/core/websocket/client/WebsocketClientTest.java
+4 -3
View File
@@ -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<WebsocketHelloResponse>() {
@Override