From 4872bb7719c4ccaaab99438af3d987787c818c2a Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期二, 05 八月 2025 23:14:48 +0800
Subject: [PATCH] 提交推送服务
---
MessagePushTravel/src/main/java/com/sinata/push/controller/NettyController.java | 7 ++++++-
1 files changed, 6 insertions(+), 1 deletions(-)
diff --git a/MessagePushTravel/src/main/java/com/sinata/push/controller/NettyController.java b/MessagePushTravel/src/main/java/com/sinata/push/controller/NettyController.java
index 178936d..c39c8c9 100644
--- a/MessagePushTravel/src/main/java/com/sinata/push/controller/NettyController.java
+++ b/MessagePushTravel/src/main/java/com/sinata/push/controller/NettyController.java
@@ -3,10 +3,12 @@
import com.alibaba.fastjson.JSON;
import com.sinata.push.util.ResultUtil;
+import com.sinata.push.util.SpringUtil;
import com.sinata.push.util.applets.NettyWebSocketController;
import com.sinata.push.util.echo.NettyChannelMap;
import com.sinata.push.util.echo.NettyServerController;
import io.netty.channel.ChannelHandlerContext;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@@ -15,6 +17,7 @@
@RestController
@RequestMapping("/netty")
public class NettyController {
+
/**
@@ -25,6 +28,7 @@
@ResponseBody
@PostMapping("/sendMsgToClient")
public String sendMsgToClient(Integer id, Integer type, String msg){
+ System.out.println("推送参数：" + id + "---" + type + "---" + msg);
if(type == 1){//用户端
ChannelHandlerContext channel = NettyChannelMap.getData("Applets" + id);//小程序
if(null != channel){
@@ -33,7 +37,7 @@
}
channel = NettyChannelMap.getData("USER" + id);
if(null != channel){
- NettyServerController.sendMsgToClient(channel, msg);
+ NettyServerController.sendMsgToClient(channel, msg);
return JSON.toJSONString(ResultUtil.success());
}
return JSON.toJSONString(ResultUtil.error("推送失败-----用户id=" + id));
@@ -41,6 +45,7 @@
}
if(type == 2){//司机端
+ System.out.println("长链接实例：" + JSON.toJSONString(NettyChannelMap.map));
ChannelHandlerContext channel = NettyChannelMap.getData("DRIVER" + id);
if(null != channel){
NettyServerController.sendMsgToClient(channel, msg);
--
Gitblit v1.7.1