From 607a2413533f10be28ebbfe1c96a4669a3150ce4 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期三, 25 六月 2025 15:04:23 +0800
Subject: [PATCH] 提交推送服务
---
MessagePushTravel/src/main/java/com/sinata/push/util/applets/WebSocketHandler.java | 14 +++++++++++---
1 files changed, 11 insertions(+), 3 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 5d3b425..e1086ab 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
@@ -1,6 +1,7 @@
package com.sinata.push.util.applets;
import com.alibaba.fastjson.JSONObject;
+import com.sinata.push.util.SpringUtil;
import com.sinata.push.util.echo.Method;
import com.sinata.push.util.echo.NettyChannelMap;
import com.sinata.push.util.echo.NettyMsg;
@@ -15,6 +16,7 @@
import io.netty.handler.timeout.IdleState;
import io.netty.handler.timeout.IdleStateEvent;
import io.netty.util.CharsetUtil;
+import org.springframework.data.redis.core.StringRedisTemplate;
import java.util.HashMap;
@@ -23,7 +25,9 @@
//用于websocket握手的处理类
private WebSocketServerHandshaker handshaker;
- private static final String WEB_SOCKET_URL = "wss://localhost:8808/websocket";
+ private static final String WEB_SOCKET_URL = "ws://localhost:8888/websocket";
+
+ private NettyWebSocketController nettyWebSocketController = SpringUtil.getObject(NettyWebSocketController.class);
@@ -73,6 +77,10 @@
}
private void handleHttpRequest(ChannelHandlerContext ctx, FullHttpRequest req) {
+ HttpHeaders headers = req.headers();
+ headers.names().forEach(name -> {
+ System.out.println(name + ":" + headers.get(name));
+ });
// Http解码失败，向服务器指定传输的协议为Upgrade：websocket
if(!req.getDecoderResult().isSuccess() || !("websocket").equals(req.headers().get("Upgrade"))){
sendHttpResponse(ctx, req, new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.BAD_REQUEST));
@@ -119,8 +127,8 @@
jsonObject.put("data", new JSONObject());
TextWebSocketFrame tws = new TextWebSocketFrame(jsonObject.toJSONString());
// ctx.channel().writeAndFlush(tws);
-
- new NettyWebSocketController().JudgeOperation(ctx,requestmsg);//小程序心跳处理
+
+ nettyWebSocketController.JudgeOperation(ctx,requestmsg);//小程序心跳处理
// 群发服务端心跳响应
Global.group.writeAndFlush(new TextWebSocketFrame((tws).text()));
--
Gitblit v1.7.1