From 5321e3029faed64b250ec77b329a1ecd78086a23 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期日, 27 七月 2025 13:56:25 +0800
Subject: [PATCH] 抢单处理推广
---
MessagePushTravel/src/main/java/com/sinata/push/util/applets/WebSocketHandler.java | 3 +++
1 files changed, 3 insertions(+), 0 deletions(-)
diff --git a/MessagePushTravel/src/main/java/com/sinata/push/util/applets/WebSocketHandler.java b/MessagePushTravel/src/main/java/com/sinata/push/util/applets/WebSocketHandler.java
index e1086ab..dc420f6 100644
--- a/MessagePushTravel/src/main/java/com/sinata/push/util/applets/WebSocketHandler.java
+++ b/MessagePushTravel/src/main/java/com/sinata/push/util/applets/WebSocketHandler.java
@@ -83,6 +83,7 @@
});
// Http解码失败，向服务器指定传输的协议为Upgrade：websocket
if(!req.getDecoderResult().isSuccess() || !("websocket").equals(req.headers().get("Upgrade"))){
+ System.out.println("Http解码失败");
sendHttpResponse(ctx, req, new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.BAD_REQUEST));
return;
}
@@ -91,9 +92,11 @@
// 根据工厂类和HTTP请求创建握手类
handshaker = wsFactory.newHandshaker(req);
if (handshaker == null) {
+ System.out.println("不支持websocket");
// 不支持websocket
WebSocketServerHandshakerFactory.sendUnsupportedWebSocketVersionResponse(ctx.channel());
} else {
+ System.out.println("通过它构造握手响应消息返回给客户端");
// 通过它构造握手响应消息返回给客户端
handshaker.handshake(ctx.channel(), req);
}
--
Gitblit v1.7.1